X-Git-Url: https://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu-bp.c;h=b0d0d44c579d6c651a2fed0b64723ddae0a71901;hp=fc6eedf56a545dde91e1fa8b96456af5bc593158;hb=18c3778a6e548f0926cada96db00f8da7cc81454;hpb=2dfb8b5e30bc2d268bcbc57eceb9c54d21b36d90 diff --git a/urcu-bp.c b/urcu-bp.c index fc6eedf..b0d0d44 100644 --- a/urcu-bp.c +++ b/urcu-bp.c @@ -122,7 +122,7 @@ void update_counter_and_wait(void) int wait_loops = 0; struct rcu_reader *index, *tmp; - /* Switch parity: 1 -> 0, 0 -> 1 */ + /* Switch parity: 0 -> 1, 1 -> 0 */ STORE_SHARED(rcu_gp_ctr, rcu_gp_ctr ^ RCU_GP_CTR_PHASE); /* @@ -144,9 +144,9 @@ void update_counter_and_wait(void) */ for (;;) { wait_loops++; - list_for_each_entry_safe(index, tmp, ®istry, head) { + list_for_each_entry_safe(index, tmp, ®istry, node) { if (!rcu_old_gp_ongoing(&index->ctr)) - list_move(&index->head, &qsreaders); + list_move(&index->node, &qsreaders); } if (list_empty(®istry)) { @@ -279,7 +279,7 @@ static void add_thread(void) /* Add to registry */ rcu_reader_reg->tid = pthread_self(); assert(rcu_reader_reg->ctr == 0); - list_add(&rcu_reader_reg->head, ®istry); + list_add(&rcu_reader_reg->node, ®istry); rcu_reader = rcu_reader_reg; } @@ -299,7 +299,8 @@ static void rcu_gc_registry(void) ret = pthread_kill(tid, 0); assert(ret != EINVAL); if (ret == ESRCH) { - list_del(&rcu_reader_reg->head); + list_del(&rcu_reader_reg->node); + rcu_reader_reg->ctr = 0; rcu_reader_reg->alloc = 0; registry_arena.used -= sizeof(struct rcu_reader); }