Bloom_Filter.h

Go to the documentation of this file.

/* ############################ MALP License ############################## */
/* # Fri Jan 18 14:00:00 CET 2013                                         # */
/* # Copyright or (C) or Copr. Commissariat a l'Energie Atomique          # */
/* #                                                                      # */
/* # This software is governed by the CeCILL-C license under French law   # */
/* # and abiding by the rules of distribution of free software.  You can  # */
/* # use, modify and/ or redistribute the software under the terms of     # */
/* # the CeCILL-C license as circulated by CEA, CNRS and INRIA at the     # */
/* # following URL http://www.cecill.info.                                # */
/* #                                                                      # */
/* # The fact that you are presently reading this means that you have     # */
/* # had knowledge of the CeCILL-C license and that you accept its        # */
/* # terms.                                                               # */
/* #                                                                      # */
/* # Authors:                                                             # */
/* #   - BESNARD Jean-Baptiste jean-baptiste.besnard@cea.fr               # */
/* #                                                                      # */
/* ######################################################################## */

#ifndef BLOOM_FILTER_H
#define BLOOM_FILTER_H

#include "Bit_Array.h"
#include "Spinlock.h"
#include "CRC64.h"

#ifdef __cplusplus
  extern "C"
  {
#endif

struct Bloom_Filter
{
    struct Bit_Array array; 
    MALP_Spinlock lock;     
    uint64_t size;          
    size_t sizeof_payload;  
};

void Bloom_Filter_init( struct Bloom_Filter *bf , uint64_t size, size_t sizeof_payload );

void Bloom_Filter_release( struct Bloom_Filter *bf );

static inline uint64_t Bloom_Filter_get_cell(  struct Bloom_Filter *bf , void *payload )
{
    uint64_t key = MALP_Trace_crc64( (char *)payload, bf->sizeof_payload );
    
    return (key % bf->size);
}

static inline void Bloom_Filter_push( struct Bloom_Filter *bf , void *payload )
{
    uint64_t cell = Bloom_Filter_get_cell( bf , payload );
    
    MALP_Spinlock_lock( &bf->lock );
    Bit_Array_set( &bf->array, cell, 1 );
    MALP_Spinlock_unlock( &bf->lock );
}

static inline int Bloom_Filter_test( struct Bloom_Filter *bf , void *payload )
{
    uint64_t ret = 0;
    uint64_t cell = Bloom_Filter_get_cell( bf , payload );

    MALP_Spinlock_lock( &bf->lock );
    ret = Bit_Array_get( &bf->array, cell);
    MALP_Spinlock_unlock( &bf->lock );

    return ret;
}

void Bloom_Filter_replicate( struct Bloom_Filter *dest , struct Bloom_Filter *src );


#ifdef __cplusplus
}
#endif

#endif /* BLOOM_FILTER_H */