int me = (long)arg;
long long n_reads_local = 0;
- urcu_register_thread();
+ rcu_register_thread();
run_on(me);
- __atomic_inc(&nthreadsrunning);
+ atomic_inc(&nthreadsrunning);
while (goflag == GOFLAG_INIT)
poll(NULL, 0, 1);
mark_rcu_quiescent_state();
}
__get_thread_var(n_reads_pt) += n_reads_local;
put_thread_offline();
- urcu_unregister_thread();
+ rcu_unregister_thread();
return (NULL);
}
{
long long n_updates_local = 0;
- __atomic_inc(&nthreadsrunning);
+ atomic_inc(&nthreadsrunning);
while (goflag == GOFLAG_INIT)
poll(NULL, 0, 1);
while (goflag == GOFLAG_RUN) {
struct rcu_stress *p;
int pc;
- urcu_register_thread();
+ rcu_register_thread();
while (goflag == GOFLAG_INIT)
poll(NULL, 0, 1);
mark_rcu_quiescent_state();
}
}
put_thread_offline();
- urcu_unregister_thread();
+ rcu_unregister_thread();
return (NULL);
}