X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=urcu%2Frculfhash.h;h=c13d3dff91bb7d6dd77ddb81d389420347e8988a;hb=6f554439fc4efcaa55dbf4fcb8a9d2dac5a4a91e;hp=6e4f6040094f81eba2736718263eaf66f88ea97e;hpb=a6b3a718379cfd3c61fd9fcde32efcfda55dfc91;p=urcu.git diff --git a/urcu/rculfhash.h b/urcu/rculfhash.h index 6e4f604..c13d3df 100644 --- a/urcu/rculfhash.h +++ b/urcu/rculfhash.h @@ -26,6 +26,7 @@ */ #include +#include #include #ifdef __cplusplus @@ -70,8 +71,6 @@ struct cds_lfht; * Ensure reader and writer threads are registered as urcu readers. */ -typedef unsigned long (*cds_lfht_hash_fct)(void *key, size_t length, - unsigned long seed); typedef int (*cds_lfht_match_fct)(struct cds_lfht_node *node, void *key); /* @@ -178,15 +177,17 @@ void cds_lfht_count_nodes(struct cds_lfht *ht, /* * cds_lfht_lookup - lookup a node by key. * @ht: the hash table. - * @match: the key match function. * @hash: the key hash. + * @match: the key match function. + * @key: the current node key. * @iter: Node, if found (output). *iter->node set to NULL if not found. * * Call with rcu_read_lock held. * Threads calling this API need to be registered RCU read-side threads. */ -void cds_lfht_lookup(struct cds_lfht *ht, cds_lfht_match_fct match, - unsigned long hash, void *key, struct cds_lfht_iter *iter); +void cds_lfht_lookup(struct cds_lfht *ht, unsigned long hash, + cds_lfht_match_fct match, void *key, + struct cds_lfht_iter *iter); /* * cds_lfht_next_duplicate - get the next item with same key (after a lookup). @@ -247,9 +248,9 @@ void cds_lfht_add(struct cds_lfht *ht, unsigned long hash, /* * cds_lfht_add_unique - add a node to hash table, if key is not present. * @ht: the hash table. + * @hash: the node's hash. * @match: the key match function. * @key: the node's key. - * @hash: the node's hash. * @node: the node to try adding. * * Return the node added upon success. @@ -265,17 +266,17 @@ void cds_lfht_add(struct cds_lfht *ht, unsigned long hash, * add_unique and add_replace (see below). */ struct cds_lfht_node *cds_lfht_add_unique(struct cds_lfht *ht, + unsigned long hash, cds_lfht_match_fct match, void *key, - unsigned long hash, struct cds_lfht_node *node); /* * cds_lfht_add_replace - replace or add a node within hash table. * @ht: the hash table. + * @hash: the node's hash. * @match: the key match function. * @key: the node's key. - * @hash: the node's hash. * @node: the node to add. * * Return the node replaced upon success. If no node matching the key @@ -297,9 +298,9 @@ struct cds_lfht_node *cds_lfht_add_unique(struct cds_lfht *ht, * will never generate duplicated keys. */ struct cds_lfht_node *cds_lfht_add_replace(struct cds_lfht *ht, + unsigned long hash, cds_lfht_match_fct match, void *key, - unsigned long hash, struct cds_lfht_node *node); /* @@ -361,6 +362,43 @@ int cds_lfht_del(struct cds_lfht *ht, struct cds_lfht_iter *iter); */ void cds_lfht_resize(struct cds_lfht *ht, unsigned long new_size); +/* + * Note: cds_lfht_for_each are safe for element removal during + * iteration. + */ +#define cds_lfht_for_each(ht, iter, node) \ + for (cds_lfht_first(ht, iter), \ + node = cds_lfht_iter_get_node(iter); \ + node != NULL; \ + cds_lfht_next(ht, iter), \ + node = cds_lfht_iter_get_node(iter)) + +#define cds_lfht_for_each_duplicate(ht, hash, match, key, iter, node) \ + for (cds_lfht_lookup(ht, hash, match, key, iter), \ + node = cds_lfht_iter_get_node(iter); \ + node != NULL; \ + cds_lfht_next_duplicate(ht, match, key, iter), \ + node = cds_lfht_iter_get_node(iter)) + +#define cds_lfht_for_each_entry(ht, iter, pos, member) \ + for (cds_lfht_first(ht, iter), \ + pos = caa_container_of(cds_lfht_iter_get_node(iter), \ + typeof(*(pos)), member); \ + &(pos)->member != NULL; \ + cds_lfht_next(ht, iter), \ + pos = caa_container_of(cds_lfht_iter_get_node(iter), \ + typeof(*(pos)), member)) + +#define cds_lfht_for_each_entry_duplicate(ht, hash, match, key, \ + iter, pos, member) \ + for (cds_lfht_lookup(ht, hash, match, key, iter), \ + pos = caa_container_of(cds_lfht_iter_get_node(iter), \ + typeof(*(pos)), member); \ + &(pos)->member != NULL; \ + cds_lfht_next_duplicate(ht, match, key, iter), \ + pos = caa_container_of(cds_lfht_iter_get_node(iter), \ + typeof(*(pos)), member)) + #ifdef __cplusplus } #endif