X-Git-Url: https://pd.if.org/git/?a=blobdiff_plain;f=test%2Frcu_test.c;h=b2dedaae418d974406b0697cbdef7457efb107c5;hb=86fd9c8abfbacea2902b4fe42a8a4664b2a531cf;hp=518125379f58336ab4e19324491a815c5529d027;hpb=6b4f3ea4891b6c0e65dfd6d41f49aee2daa9e23d;p=nbds diff --git a/test/rcu_test.c b/test/rcu_test.c index 5181253..b2dedaa 100644 --- a/test/rcu_test.c +++ b/test/rcu_test.c @@ -30,18 +30,18 @@ static lifo_t *lifo_alloc (void) { static void lifo_aba_push (lifo_t *stk, node_t *x) { node_t *head; do { - head = ((volatile lifo_t *)stk)->head; - ((volatile node_t *)x)->next = head; - } while (__sync_val_compare_and_swap(&stk->head, head, x) != head); + head = VOLATILE_DEREF(stk).head; + VOLATILE_DEREF(x).next = head; + } while (SYNC_CAS(&stk->head, head, x) != head); } node_t *lifo_aba_pop (lifo_t *stk) { node_t *head; do { - head = ((volatile lifo_t *)stk)->head; + head = VOLATILE_DEREF(stk).head; if (head == NULL) return NULL; - } while (__sync_val_compare_and_swap(&stk->head, head, head->next) != head); + } while (SYNC_CAS(&stk->head, head, head->next) != head); head->next = NULL; return head; } @@ -80,7 +80,7 @@ void *worker (void *arg) { int main (int argc, char **argv) { lwt_set_trace_level("m3r3"); - int num_threads = 2; + int num_threads = MAX_NUM_THREADS; if (argc == 2) { errno = 0;