rculfhash: Move "struct rcu_head head" out of "struct cds_lfht_node"
authorLai Jiangshan <laijs@cn.fujitsu.com>
Wed, 2 Nov 2011 17:22:30 +0000 (13:22 -0400)
committerMathieu Desnoyers <mathieu.desnoyers@efficios.com>
Wed, 2 Nov 2011 17:22:30 +0000 (13:22 -0400)
It is user's responsibility to free it by call_rcu(),
synchronize_rcu() or defer_rcu().

Signed-off-by: Lai Jiangshan <laijs@cn.fujitsu.com>
Signed-off-by: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
tests/test_urcu_hash.c
urcu/rculfhash.h

index dbacf73a5615c9912a89a9e71a3697ae6da92aa8..e28c14afc750c7ffe09ec879b44f05488f76dc44 100644 (file)
@@ -107,6 +107,8 @@ struct test_data {
 
 struct lfht_test_node {
        struct cds_lfht_node node;
+       /* cache-cold for iteration */
+       struct rcu_head head;
 };
 
 static inline struct lfht_test_node *
@@ -516,7 +518,7 @@ static
 void free_node_cb(struct rcu_head *head)
 {
        struct lfht_test_node *node =
-               caa_container_of(head, struct lfht_test_node, node.head);
+               caa_container_of(head, struct lfht_test_node, head);
        free(node);
 }
 
@@ -562,7 +564,7 @@ void *thr_writer(void *_count)
                                nr_addexist++;
                        } else {
                                if (add_replace && ret_node) {
-                                       call_rcu(&to_test_node(ret_node)->node.head,
+                                       call_rcu(&to_test_node(ret_node)->head,
                                                        free_node_cb);
                                        nr_addexist++;
                                } else {
@@ -579,7 +581,7 @@ void *thr_writer(void *_count)
                        rcu_read_unlock();
                        if (ret == 0) {
                                node = cds_lfht_iter_get_test_node(&iter);
-                               call_rcu(&node->node.head, free_node_cb);
+                               call_rcu(&node->head, free_node_cb);
                                nr_del++;
                        } else
                                nr_delnoent++;
@@ -653,7 +655,7 @@ static int populate_hash(void)
                        nr_addexist++;
                } else {
                        if (add_replace && ret_node) {
-                               call_rcu(&to_test_node(ret_node)->node.head, free_node_cb);
+                               call_rcu(&to_test_node(ret_node)->head, free_node_cb);
                                nr_addexist++;
                        } else {
                                nr_add++;
@@ -677,7 +679,7 @@ void test_delete_all_nodes(struct cds_lfht *ht)
 
                ret = cds_lfht_del(test_ht, &iter);
                assert(!ret);
-               call_rcu(&node->node.head, free_node_cb);
+               call_rcu(&node->head, free_node_cb);
                cds_lfht_next(ht, &iter);
                count++;
        }
index 008b1d49f55ae86ae4bcdf86c2ce2a8c0a1c7617..f4f3373298492b3dee1e71f35277a310af735dd7 100644 (file)
@@ -62,8 +62,6 @@ struct cds_lfht_node {
        struct _cds_lfht_node p;          /* needs to be first field */
        void *key;
        unsigned int key_len;
-       /* cache-cold for iteration */
-       struct rcu_head head;
 };
 
 /* cds_lfht_iter: Used to track state while traversing a hash chain. */
This page took 0.034656 seconds and 4 git commands to generate.