X-Git-Url: https://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu.c;h=d0d61385385d713bf221e078767295bd3ecfb2d6;hp=7e79207be6a88eaaf6d2b74c0b16b4543368a6fd;hb=cdcb92bbb9e54201e0982844e3ca9cb4fd9b31e5;hpb=41718ff94c4a07cb5f56d68084267798e471d1b1 diff --git a/urcu.c b/urcu.c index 7e79207..d0d6138 100644 --- a/urcu.c +++ b/urcu.c @@ -1,3 +1,13 @@ +/* + * urcu.c + * + * Userspace RCU library + * + * Copyright February 2009 - Mathieu Desnoyers + * + * Distributed under GPLv2 + */ + #include #include #include @@ -91,7 +101,7 @@ void wait_for_quiescent_state(int parity) /* * BUSY-LOOP. */ - while (*index->urcu_active_readers != 0) + while (index->urcu_active_readers[parity] != 0) barrier(); } /* @@ -109,7 +119,7 @@ void wait_for_quiescent_state(int parity) */ void *urcu_publish_content(void **ptr, void *new) { - int ret, prev_parity; + int prev_parity; void *oldptr; /* @@ -124,8 +134,8 @@ void *urcu_publish_content(void **ptr, void *new) */ oldptr = *ptr; *ptr = new; - wmb(); /* Write ptr before changing the qparity */ /* All threads should read qparity before ptr */ + /* Write ptr before changing the qparity */ force_mb_all_threads(); prev_parity = switch_next_urcu_qparity(); @@ -197,7 +207,6 @@ void urcu_register_thread(void) void urcu_unregister_thread(void) { - pthread_t self = pthread_self(); rcu_write_lock(); urcu_remove_reader(pthread_self()); rcu_write_unlock();