X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=urcu-bp.c;h=836ef92fe1f8ba92335ab9b8a3047e51f520d190;hb=f21aa7d91c98ea2d7dd71f44c3dd3aa3c8583505;hp=387a52bf892df54cfcac0f14868ad70b2e8d1959;hpb=8c1bd0782ff0ce28b96d394a5b27a294af6156e0;p=urcu.git

diff --git a/urcu-bp.c b/urcu-bp.c
index 387a52b..836ef92 100644
--- a/urcu-bp.c
+++ b/urcu-bp.c
@@ -91,6 +91,9 @@ void *mremap_wrapper(void *old_address, size_t old_size,
  */
 #define RCU_QS_ACTIVE_ATTEMPTS 100
 
+static
+int rcu_bp_refcount;
+
 static
 void __attribute__((constructor)) rcu_bp_init(void);
 static
@@ -105,7 +108,7 @@ static pthread_key_t urcu_bp_key;
 
 #ifdef DEBUG_YIELD
 unsigned int rcu_yield_active;
-DEFINE_URCU_TLS(unsigned int, rcu_rand_yield);
+__DEFINE_URCU_TLS_GLOBAL(unsigned int, rcu_rand_yield);
 #endif
 
 struct rcu_gp rcu_gp = { .ctr = RCU_GP_COUNT };
@@ -114,7 +117,7 @@ struct rcu_gp rcu_gp = { .ctr = RCU_GP_COUNT };
  * Pointer to registry elements. Written to only by each individual reader. Read
  * by both the reader and the writers.
  */
-DEFINE_URCU_TLS(struct rcu_reader *, rcu_reader);
+__DEFINE_URCU_TLS_GLOBAL(struct rcu_reader *, rcu_reader);
 
 static CDS_LIST_HEAD(registry);
 
@@ -454,11 +457,8 @@ struct registry_chunk *find_chunk(struct rcu_reader *rcu_reader_reg)
 
 /* Called with signals off and mutex locked */
 static
-void remove_thread(void)
+void remove_thread(struct rcu_reader *rcu_reader_reg)
 {
-	struct rcu_reader *rcu_reader_reg;
-
-	rcu_reader_reg = URCU_TLS(rcu_reader);
 	cleanup_thread(find_chunk(rcu_reader_reg), rcu_reader_reg);
 	URCU_TLS(rcu_reader) = NULL;
 }
@@ -499,7 +499,7 @@ end:
 
 /* Disable signals, take mutex, remove from registry */
 static
-void rcu_bp_unregister(void)
+void rcu_bp_unregister(struct rcu_reader *rcu_reader_reg)
 {
 	sigset_t newmask, oldmask;
 	int ret;
@@ -512,11 +512,12 @@ void rcu_bp_unregister(void)
 		abort();
 
 	mutex_lock(&rcu_gp_lock);
-	remove_thread();
+	remove_thread(rcu_reader_reg);
 	mutex_unlock(&rcu_gp_lock);
 	ret = pthread_sigmask(SIG_SETMASK, &oldmask, NULL);
 	if (ret)
 		abort();
+	rcu_bp_exit();
 }
 
 /*
@@ -526,15 +527,14 @@ void rcu_bp_unregister(void)
 static
 void urcu_bp_thread_exit_notifier(void *rcu_key)
 {
-	assert(rcu_key == URCU_TLS(rcu_reader));
-	rcu_bp_unregister();
+	rcu_bp_unregister(rcu_key);
 }
 
 static
 void rcu_bp_init(void)
 {
 	mutex_lock(&init_lock);
-	if (!initialized) {
+	if (!rcu_bp_refcount++) {
 		int ret;
 
 		ret = pthread_key_create(&urcu_bp_key,
@@ -549,16 +549,21 @@ void rcu_bp_init(void)
 static
 void rcu_bp_exit(void)
 {
-	struct registry_chunk *chunk, *tmp;
-	int ret;
+	mutex_lock(&init_lock);
+	if (!--rcu_bp_refcount) {
+		struct registry_chunk *chunk, *tmp;
+		int ret;
 
-	cds_list_for_each_entry_safe(chunk, tmp,
-			&registry_arena.chunk_list, node) {
-		munmap(chunk, chunk->data_len + sizeof(struct registry_chunk));
+		cds_list_for_each_entry_safe(chunk, tmp,
+				&registry_arena.chunk_list, node) {
+			munmap(chunk, chunk->data_len
+					+ sizeof(struct registry_chunk));
+		}
+		ret = pthread_key_delete(urcu_bp_key);
+		if (ret)
+			abort();
 	}
-	ret = pthread_key_delete(urcu_bp_key);
-	if (ret)
-		abort();
+	mutex_unlock(&init_lock);
 }
 
 /*