Skip to content

Commit 23c9510

Browse files
committed
spmc: Resolve data race
1 parent 1d26c11 commit 23c9510

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spmc/spmc.c

+1-1
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ bool spmc_dequeue(spmc_ref_t spmc, uintptr_t *slot)
149149
if (node != spmc->curr_enqueue)
150150
atomic_compare_exchange_strong(
151151
&spmc->curr_dequeue, &node,
152-
atomic_load_explicit(&node->next, memory_order_relaxed));
152+
atomic_load_explicit(&node->next, memory_order_consume));
153153
goto no_increment;
154154
} else
155155
*slot = node->buf[INDEX_OF(idx, node)];

0 commit comments

Comments
 (0)