X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=doc%2Fexamples%2Frculfqueue%2Fcds_lfq_enqueue.c;h=12024676a3af7ef362ce2aa7f2a777427d1845cb;hb=HEAD;hp=a8c6f8653814d4d9e7ab7b785599586ffe9d7373;hpb=d4b7140809acb8a9429fa97a4620c96674bd0c3c;p=urcu.git diff --git a/doc/examples/rculfqueue/cds_lfq_enqueue.c b/doc/examples/rculfqueue/cds_lfq_enqueue.c index a8c6f86..b0ea030 100644 --- a/doc/examples/rculfqueue/cds_lfq_enqueue.c +++ b/doc/examples/rculfqueue/cds_lfq_enqueue.c @@ -1,15 +1,8 @@ +// SPDX-FileCopyrightText: 2013 Mathieu Desnoyers +// +// SPDX-License-Identifier: MIT + /* - * Copyright (C) 2013 Mathieu Desnoyers - * - * THIS MATERIAL IS PROVIDED AS IS, WITH ABSOLUTELY NO WARRANTY EXPRESSED - * OR IMPLIED. ANY USE IS AT YOUR OWN RISK. - * - * Permission is hereby granted to use or copy this program for any - * purpose, provided the above notices are retained on all copies. - * Permission to modify the code and to distribute modified code is - * granted, provided the above notices are retained, and a notice that - * the code was modified is included with the above copyright notice. - * * This example shows how to enqueue nodes into a RCU lock-free queue. * This queue requires using a RCU scheme. */ @@ -17,7 +10,7 @@ #include #include -#include /* RCU flavor */ +#include /* RCU flavor */ #include /* RCU Lock-free queue */ #include /* For CAA_ARRAY_SIZE */ @@ -29,7 +22,7 @@ struct mynode { struct cds_lfq_node_rcu node; /* Chaining in queue */ }; -int main(int argc, char **argv) +int main(void) { int values[] = { -5, 42, 36, 24, }; struct cds_lfq_queue_rcu myqueue; /* Queue */ @@ -40,9 +33,9 @@ int main(int argc, char **argv) * Each thread need using RCU read-side need to be explicitly * registered. */ - rcu_register_thread(); + urcu_memb_register_thread(); - cds_lfq_init_rcu(&myqueue, call_rcu); + cds_lfq_init_rcu(&myqueue, urcu_memb_call_rcu); /* * Enqueue nodes. @@ -62,12 +55,12 @@ int main(int argc, char **argv) * Both enqueue and dequeue need to be called within RCU * read-side critical section. */ - rcu_read_lock(); + urcu_memb_read_lock(); cds_lfq_enqueue_rcu(&myqueue, &node->node); - rcu_read_unlock(); + urcu_memb_read_unlock(); } end: - rcu_unregister_thread(); + urcu_memb_unregister_thread(); return ret; }