Merge branch 'master' into cxxmph

Conflicts:
	INSTALL
	Makefile.am
	cxxmph/Makefile.am
	cxxmph/cmph_hash_map.h
	cxxmph/cmph_hash_map_test.cc
	cxxmph/mphtable.cc
	cxxmph/mphtable.h

src/bdz.c

@@ -107,7 +107,7 @@ static void bdz_add_edge(bdz_graph3_t * graph3, cmph_uint32 v0, cmph_uint32 v1,
 
 static void bdz_dump_graph(bdz_graph3_t* graph3, cmph_uint32 nedges, cmph_uint32 nvertices)
 {
-	int i;
+	cmph_uint32 i;
 	for(i=0;i<nedges;i++){
 		printf("\nedge %d %d %d %d ",i,graph3->edges[i].vertices[0],
 			graph3->edges[i].vertices[1],graph3->edges[i].vertices[2]);
@@ -223,7 +223,7 @@ static void assigning(bdz_config_data_t *bdz, bdz_graph3_t* graph3, bdz_queue_t
 static void ranking(bdz_config_data_t *bdz);
 static cmph_uint32 rank(cmph_uint32 b, cmph_uint32 * ranktable, cmph_uint8 * g, cmph_uint32 vertex);
 
-bdz_config_data_t *bdz_config_new()
+bdz_config_data_t *bdz_config_new(void)
 {
 	bdz_config_data_t *bdz;
 	bdz = (bdz_config_data_t *)malloc(sizeof(bdz_config_data_t));
@@ -568,19 +568,6 @@ void bdz_load(FILE *f, cmph_t *mphf)
 }
 		
 
-cmph_uint32 bdz_search_ph(cmph_t *mphf, const char *key, cmph_uint32 keylen)
-{
-	bdz_data_t *bdz = mphf->data;
-	cmph_uint32 hl[3];
-	hash_vector(bdz->hl, key, keylen, hl);
-	cmph_uint32 vertex;
-	hl[0] = hl[0] % bdz->r;
-	hl[1] = hl[1] % bdz->r + bdz->r;
-	hl[2] = hl[2] % bdz->r + (bdz->r << 1);
-	vertex = hl[(GETVALUE(bdz->g, hl[0]) + GETVALUE(bdz->g, hl[1]) + GETVALUE(bdz->g, hl[2])) % 3];
-	return vertex;
-}
-
 static inline cmph_uint32 rank(cmph_uint32 b, cmph_uint32 * ranktable, cmph_uint8 * g, cmph_uint32 vertex)
 {
 	register cmph_uint32 index = vertex >> b;

src/bdz.h

@@ -6,7 +6,7 @@
 typedef struct __bdz_data_t bdz_data_t;
 typedef struct __bdz_config_data_t bdz_config_data_t;
 
-bdz_config_data_t *bdz_config_new();
+bdz_config_data_t *bdz_config_new(void);
 void bdz_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void bdz_config_destroy(cmph_config_t *mph);
 void bdz_config_set_b(cmph_config_t *mph, cmph_uint32 b);

src/bdz_ph.c

@@ -94,7 +94,7 @@ static void bdz_ph_add_edge(bdz_ph_graph3_t * graph3, cmph_uint32 v0, cmph_uint3
 
 static void bdz_ph_dump_graph(bdz_ph_graph3_t* graph3, cmph_uint32 nedges, cmph_uint32 nvertices)
 {
-	int i;
+	cmph_uint32 i;
 	for(i=0;i<nedges;i++){
 		printf("\nedge %d %d %d %d ",i,graph3->edges[i].vertices[0],
 			graph3->edges[i].vertices[1],graph3->edges[i].vertices[2]);
@@ -202,7 +202,7 @@ static int bdz_ph_mapping(cmph_config_t *mph, bdz_ph_graph3_t* graph3, bdz_ph_qu
 static void assigning(bdz_ph_config_data_t *bdz_ph, bdz_ph_graph3_t* graph3, bdz_ph_queue_t queue);
 static void bdz_ph_optimization(bdz_ph_config_data_t *bdz_ph);
 
-bdz_ph_config_data_t *bdz_ph_config_new()
+bdz_ph_config_data_t *bdz_ph_config_new(void)
 {
 	bdz_ph_config_data_t *bdz_ph;
 	bdz_ph = (bdz_ph_config_data_t *)malloc(sizeof(bdz_ph_config_data_t));

src/bdz_ph.h

@@ -6,7 +6,7 @@
 typedef struct __bdz_ph_data_t bdz_ph_data_t;
 typedef struct __bdz_ph_config_data_t bdz_ph_config_data_t;
 
-bdz_ph_config_data_t *bdz_ph_config_new();
+bdz_ph_config_data_t *bdz_ph_config_new(void);
 void bdz_ph_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void bdz_ph_config_destroy(cmph_config_t *mph);
 cmph_t *bdz_ph_new(cmph_config_t *mph, double c);

src/bitbool.h

@@ -31,15 +31,6 @@ static const cmph_uint8 valuemask[] = { 0xfc, 0xf3, 0xcf, 0x3f};
  */
 #define SETBIT(array, i) (array[i >> 3] |= bitmask[i & 0x00000007])
 
-/** \def UNSETBIT(array, i)
- *  \brief set 0 to an 1-bit integer stored in an array. 
- *  \param array to store 1-bit integer values
- *  \param i is the index in array to set the the bit to 0
- * 
- * UNSETBIT(array, i) is a macro that sets 0 to an 1-bit integer stored in an array.
- */
-#define UNSETBIT(array, i) (array[i >> 3] ^= ((bitmask[i & 0x00000007])))
-
 //#define GETBIT(array, i) (array[(i) / 8] & bitmask[(i) % 8])
 //#define SETBIT(array, i) (array[(i) / 8] |= bitmask[(i) % 8])
 //#define UNSETBIT(array, i) (array[(i) / 8] ^= ((bitmask[(i) % 8])))

src/bm_numbers.c

@@ -40,7 +40,6 @@ static lsmap_t *g_expected_probes = NULL;
 static lsmap_t *g_mphf_probes = NULL;
 
 void bm_create(CMPH_ALGO algo, int iters) {
-  cmph_uint32 i = 0;
   cmph_io_adapter_t* source = NULL;
   cmph_config_t* config = NULL;
   cmph_t* mphf = NULL;
@@ -124,8 +123,9 @@ int main(int argc, char** argv) {
 
   verify();
   free(g_numbers);
-  lsmap_foreach_key(g_created_mphf, free);
-  lsmap_foreach_value(g_created_mphf, cmph_destroy);
+  lsmap_foreach_key(g_created_mphf, (void(*)(const char*))free);
+  lsmap_foreach_value(g_created_mphf, (void(*)(void*))cmph_destroy);
   lsmap_destroy(g_created_mphf);
+  return 0;
 }
 

src/bmz.c

@@ -20,7 +20,7 @@ static cmph_uint8 bmz_traverse_critical_nodes(bmz_config_data_t *bmz, cmph_uint3
 static cmph_uint8 bmz_traverse_critical_nodes_heuristic(bmz_config_data_t *bmz, cmph_uint32 v, cmph_uint32 * biggest_g_value, cmph_uint32 * biggest_edge_value, cmph_uint8 * used_edges, cmph_uint8 * visited);
 static void bmz_traverse_non_critical_nodes(bmz_config_data_t *bmz, cmph_uint8 * used_edges, cmph_uint8 * visited);
 
-bmz_config_data_t *bmz_config_new()
+bmz_config_data_t *bmz_config_new(void)
 {
 	bmz_config_data_t *bmz = NULL;
 	bmz = (bmz_config_data_t *)malloc(sizeof(bmz_config_data_t));

src/bmz.h

@@ -6,7 +6,7 @@
 typedef struct __bmz_data_t bmz_data_t;
 typedef struct __bmz_config_data_t bmz_config_data_t;
 
-bmz_config_data_t *bmz_config_new();
+bmz_config_data_t *bmz_config_new(void);
 void bmz_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void bmz_config_destroy(cmph_config_t *mph);
 cmph_t *bmz_new(cmph_config_t *mph, double c);

src/bmz8.c

@@ -19,7 +19,7 @@ static cmph_uint8 bmz8_traverse_critical_nodes(bmz8_config_data_t *bmz8, cmph_ui
 static cmph_uint8 bmz8_traverse_critical_nodes_heuristic(bmz8_config_data_t *bmz8, cmph_uint32 v, cmph_uint8 * biggest_g_value, cmph_uint8 * biggest_edge_value, cmph_uint8 * used_edges, cmph_uint8 * visited);
 static void bmz8_traverse_non_critical_nodes(bmz8_config_data_t *bmz8, cmph_uint8 * used_edges, cmph_uint8 * visited);
 
-bmz8_config_data_t *bmz8_config_new()
+bmz8_config_data_t *bmz8_config_new(void)
 {
 	bmz8_config_data_t *bmz8;
 	bmz8 = (bmz8_config_data_t *)malloc(sizeof(bmz8_config_data_t));

src/bmz8.h

@@ -6,7 +6,7 @@
 typedef struct __bmz8_data_t bmz8_data_t;
 typedef struct __bmz8_config_data_t bmz8_config_data_t;
 
-bmz8_config_data_t *bmz8_config_new();
+bmz8_config_data_t *bmz8_config_new(void);
 void bmz8_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void bmz8_config_destroy(cmph_config_t *mph);
 cmph_t *bmz8_new(cmph_config_t *mph, double c);

src/brz.c

@@ -24,7 +24,7 @@ static cmph_uint32 brz_min_index(cmph_uint32 * vector, cmph_uint32 n);
 static void brz_destroy_keys_vd(cmph_uint8 ** keys_vd, cmph_uint32 nkeys);
 static char * brz_copy_partial_fch_mphf(brz_config_data_t *brz, fch_data_t * fchf, cmph_uint32 index,  cmph_uint32 *buflen);
 static char * brz_copy_partial_bmz8_mphf(brz_config_data_t *brz, bmz8_data_t * bmzf, cmph_uint32 index,  cmph_uint32 *buflen);
-brz_config_data_t *brz_config_new()
+brz_config_data_t *brz_config_new(void)
 {
 	brz_config_data_t *brz = NULL; 	
 	brz = (brz_config_data_t *)malloc(sizeof(brz_config_data_t));

src/brz.h

@@ -6,7 +6,7 @@
 typedef struct __brz_data_t brz_data_t;
 typedef struct __brz_config_data_t brz_config_data_t;
 
-brz_config_data_t *brz_config_new();
+brz_config_data_t *brz_config_new(void);
 void brz_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void brz_config_set_tmp_dir(cmph_config_t *mph, cmph_uint8 *tmp_dir);
 void brz_config_set_mphf_fd(cmph_config_t *mph, FILE *mphf_fd);

src/buffer_entry.c

@@ -43,7 +43,7 @@ cmph_uint32 buffer_entry_get_capacity(buffer_entry_t * buffer_entry)
 	return buffer_entry->capacity;
 }
 
-void buffer_entry_load(buffer_entry_t * buffer_entry)
+static void buffer_entry_load(buffer_entry_t * buffer_entry)
 {
 	free(buffer_entry->buff);
 	buffer_entry->buff = (cmph_uint8 *)calloc((size_t)buffer_entry->capacity, sizeof(cmph_uint8));

src/chd_ph.c

@@ -77,7 +77,7 @@ void chd_ph_bucket_clean(chd_ph_bucket_t * buckets, cmph_uint32 nbuckets)
 	for(i = 0; i < nbuckets; i++)
 		buckets[i].size = 0;
 }
-cmph_uint8 chd_ph_bucket_insert(chd_ph_bucket_t * buckets,chd_ph_map_item_t * map_items, chd_ph_item_t * items,
+static cmph_uint8 chd_ph_bucket_insert(chd_ph_bucket_t * buckets,chd_ph_map_item_t * map_items, chd_ph_item_t * items,
 				cmph_uint32 nbuckets,cmph_uint32 item_idx)
 {
 	register cmph_uint32 i = 0;
@@ -141,7 +141,7 @@ static inline double chd_ph_get_entropy(cmph_uint32 * disp_table, cmph_uint32 n,
 	return entropy;
 };
 
-chd_ph_config_data_t *chd_ph_config_new()
+chd_ph_config_data_t *chd_ph_config_new(void)
 {
 	chd_ph_config_data_t *chd_ph;
 	chd_ph = (chd_ph_config_data_t *)malloc(sizeof(chd_ph_config_data_t));
@@ -625,7 +625,7 @@ cmph_t *chd_ph_new(cmph_config_t *mph, double c)
 	chd_ph_data_t *chd_phf = NULL;
 	chd_ph_config_data_t *chd_ph = (chd_ph_config_data_t *)mph->data;
 	
-	register double load_factor = 0.6;
+	register double load_factor = c;
 	register cmph_uint8 searching_success = 0;
 	register cmph_uint32 max_probes = 1 << 20; // default value for max_probes
 	register cmph_uint32 iterations = 100;
@@ -641,7 +641,6 @@ cmph_t *chd_ph_new(cmph_config_t *mph, double c)
 	double construction_time = 0.0;
 	ELAPSED_TIME_IN_SECONDS(&construction_time_begin);
 	#endif
-	c = load_factor;
 
 
 	chd_ph->m = mph->key_source->nkeys;

src/chd_ph.h

@@ -7,7 +7,7 @@ typedef struct __chd_ph_data_t chd_ph_data_t;
 typedef struct __chd_ph_config_data_t chd_ph_config_data_t;
 
 /* Config API */
-chd_ph_config_data_t *chd_ph_config_new();
+chd_ph_config_data_t *chd_ph_config_new(void);
 void chd_ph_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 
 /** \fn void chd_ph_config_set_keys_per_bin(cmph_config_t *mph, cmph_uint32 keys_per_bin);

src/chm.c

@@ -17,7 +17,7 @@
 static int chm_gen_edges(cmph_config_t *mph);
 static void chm_traverse(chm_config_data_t *chm, cmph_uint8 *visited, cmph_uint32 v);
 
-chm_config_data_t *chm_config_new()
+chm_config_data_t *chm_config_new(void)
 {
 	chm_config_data_t *chm = NULL;
 	chm = (chm_config_data_t *)malloc(sizeof(chm_config_data_t));

src/chm.h

@@ -6,7 +6,7 @@
 typedef struct __chm_data_t chm_data_t;
 typedef struct __chm_config_data_t chm_config_data_t;
 
-chm_config_data_t *chm_config_new();
+chm_config_data_t *chm_config_new(void);
 void chm_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void chm_config_destroy(cmph_config_t *mph);
 cmph_t *chm_new(cmph_config_t *mph, double c);

src/cmph_benchmark_test.c

@@ -18,5 +18,6 @@ int main(int argc, char** argv) {
   BM_REGISTER(bm_sleep, 1);
   BM_REGISTER(bm_increment, 1);
   run_benchmarks(argc, argv);
+  return 0;
 }
 

src/cmph_structs.c

@@ -8,8 +8,8 @@
 cmph_config_t *__config_new(cmph_io_adapter_t *key_source)
 {
 	cmph_config_t *mph = (cmph_config_t *)malloc(sizeof(cmph_config_t));
-	memset(mph, 0, sizeof(cmph_config_t));
 	if (mph == NULL) return NULL;
+	memset(mph, 0, sizeof(cmph_config_t));
 	mph->key_source = key_source;
 	mph->verbosity = 0;
 	mph->data = NULL;

src/fch.h

@@ -12,7 +12,7 @@ double fch_calc_p1(cmph_uint32 m);
 double fch_calc_p2(cmph_uint32 b);
 cmph_uint32 mixh10h11h12(cmph_uint32 b, double p1, double p2, cmph_uint32 initial_index);
 
-fch_config_data_t *fch_config_new();
+fch_config_data_t *fch_config_new(void);
 void fch_config_set_hashfuncs(cmph_config_t *mph, CMPH_HASH *hashfuncs);
 void fch_config_destroy(cmph_config_t *mph);
 cmph_t *fch_new(cmph_config_t *mph, double c);

src/fch_buckets.c

@@ -172,7 +172,7 @@ cmph_uint32 fch_buckets_get_nbuckets(fch_buckets_t * buckets)
 
 cmph_uint32 * fch_buckets_get_indexes_sorted_by_size(fch_buckets_t * buckets) 
 {
-	int i = 0;
+	cmph_uint32 i = 0;
 	cmph_uint32 sum = 0, value;
 	cmph_uint32 *nbuckets_size = (cmph_uint32 *) calloc((size_t)buckets->max_size + 1, sizeof(cmph_uint32));
 	cmph_uint32 * sorted_indexes = (cmph_uint32 *) calloc((size_t)buckets->nbuckets, sizeof(cmph_uint32));

src/hash.c

@@ -59,7 +59,9 @@ void hash_state_dump(hash_state_t *state, char **buf, cmph_uint32 *buflen)
 	{
 		case CMPH_HASH_JENKINS:
 			jenkins_state_dump((jenkins_state_t *)state, &algobuf, buflen);
-			if (*buflen == UINT_MAX) return;
+			if (*buflen == UINT_MAX) {
+                goto cmph_cleanup;
+            }
 			break;
 		default:
 			assert(0);
@@ -70,6 +72,7 @@ void hash_state_dump(hash_state_t *state, char **buf, cmph_uint32 *buflen)
 	len = *buflen;
 	memcpy(*buf + strlen(cmph_hash_names[state->hashfunc]) + 1, algobuf, len);
 	*buflen  = (cmph_uint32)strlen(cmph_hash_names[state->hashfunc]) + 1 + *buflen;
+cmph_cleanup:
 	free(algobuf);
 	return;
 }

src/jenkins_hash.c

@@ -98,7 +98,7 @@ void jenkins_state_destroy(jenkins_state_t *state)
 }
 
 
-inline void __jenkins_hash_vector(cmph_uint32 seed, const char *k, cmph_uint32 keylen, cmph_uint32 * hashes)
+static inline void __jenkins_hash_vector(cmph_uint32 seed, const char *k, cmph_uint32 keylen, cmph_uint32 * hashes)
 {
         int i;
         for (i = 0; i < 3; ++i) {
@@ -270,7 +270,7 @@ void jenkins_state_pack(jenkins_state_t *state, void *jenkins_packed)
  *  \brief Return the amount of space needed to pack a jenkins function.
  *  \return the size of the packed function or zero for failures
  */ 
-cmph_uint32 jenkins_state_packed_size()
+cmph_uint32 jenkins_state_packed_size(void)
 {
 	return sizeof(cmph_uint32);
 }

src/jenkins_hash.h

@@ -43,7 +43,7 @@ void jenkins_state_pack(jenkins_state_t *state, void *jenkins_packed);
  *  \brief Return the amount of space needed to pack a jenkins function.
  *  \return the size of the packed function or zero for failures
  */ 
-cmph_uint32 jenkins_state_packed_size();
+cmph_uint32 jenkins_state_packed_size(void);
 
 
 /** \fn cmph_uint32 jenkins_hash_packed(void *jenkins_packed, const char *k, cmph_uint32 keylen);

src/vstack.c

@@ -13,7 +13,7 @@ struct __vstack_t
 	cmph_uint32 capacity;
 };
 
-vstack_t *vstack_new()
+vstack_t *vstack_new(void)
 {
 	vstack_t *stack = (vstack_t *)malloc(sizeof(vstack_t));
 	assert(stack);