X-Git-Url: http://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu.c;h=162ce00fa2d4c5516ef6093722d4dfc7b17cda23;hp=9542b264a6dbf53d36d2fb63e7578b4e7ff2b2f5;hb=b715b99eb0d52e0744bfea46c62849f260a5ec58;hpb=5464000f823e493703feb49d7580a479d3ba54d4 diff --git a/urcu.c b/urcu.c index 9542b26..162ce00 100644 --- a/urcu.c +++ b/urcu.c @@ -43,7 +43,9 @@ unsigned int __thread rand_yield; static struct reader_data *reader_data; static int num_readers, alloc_readers; +#ifndef DEBUG_FULL_MB static int sig_done; +#endif void internal_urcu_lock(void) { @@ -77,14 +79,14 @@ static void switch_next_urcu_qparity(void) #ifdef DEBUG_FULL_MB static void force_mb_all_threads(void) { - mb(); + smp_mb(); } #else static void force_mb_all_threads(void) { struct reader_data *index; /* - * Ask for each threads to execute a mb() so we can consider the + * Ask for each threads to execute a smp_mb() so we can consider the * compiler barriers around rcu read lock as real memory barriers. */ if (!reader_data) @@ -92,7 +94,7 @@ static void force_mb_all_threads(void) debug_yield_write(); sig_done = 0; debug_yield_write(); - mb(); /* write sig_done before sending the signals */ + smp_mb(); /* write sig_done before sending the signals */ debug_yield_write(); for (index = reader_data; index < reader_data + num_readers; index++) { pthread_kill(index->tid, SIGURCU); @@ -105,7 +107,7 @@ static void force_mb_all_threads(void) while (sig_done < num_readers) barrier(); debug_yield_write(); - mb(); /* read sig_done before ending the barrier */ + smp_mb(); /* read sig_done before ending the barrier */ debug_yield_write(); } #endif @@ -147,7 +149,7 @@ void synchronize_rcu(void) * waiting forever while new readers are always accessing data (no * progress). */ - mb(); + smp_mb(); /* * Wait for previous parity to be empty of readers. @@ -161,7 +163,7 @@ void synchronize_rcu(void) * the writer waiting forever while new readers are always accessing * data (no progress). */ - mb(); + smp_mb(); switch_next_urcu_qparity(); /* 1 -> 0 */ debug_yield_write(); @@ -172,7 +174,7 @@ void synchronize_rcu(void) * waiting forever while new readers are always accessing data (no * progress). */ - mb(); + smp_mb(); /* * Wait for previous parity to be empty of readers. @@ -256,7 +258,7 @@ void urcu_unregister_thread(void) #ifndef DEBUG_FULL_MB void sigurcu_handler(int signo, siginfo_t *siginfo, void *context) { - mb(); + smp_mb(); atomic_inc(&sig_done); }