Changeset 4ec9ea41 in mainline for kernel/test/synch/rcu1.c

Timestamp:

2012-07-27T13:37:31Z (12 years ago)

Author:

Adam Hraska <adam.hraska+hos@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

14c9aa6

Parents:

2bcf6c6

Message:

rcu: Added rcu_barrier() that waits for all outstanding rcu_calls to complete.

File:

• kernel/test/synch/rcu1.c (modified) (2 diffs)

kernel/test/synch/rcu1.c

@@ -806 +806 @@
 
 /*-------------------------------------------------------------------*/
+typedef struct {
+        rcu_item_t rcu_item;
+        atomic_t done;
+} barrier_t;
+
+static void barrier_callback(rcu_item_t *item)
+{
+        barrier_t *b = member_to_inst(item, barrier_t, rcu_item);
+        atomic_set(&b->done, 1);
+}
+
+static bool do_barrier(void)
+{
+        TPRINTF("\nrcu_barrier: Wait for outstanding rcu callbacks to complete\n");
+        
+        barrier_t *barrier = malloc(sizeof(barrier_t), FRAME_ATOMIC);
+        
+        if (!barrier) {
+                TPRINTF("[out-of-mem]\n");
+                return false;
+        }
+        
+        atomic_set(&barrier->done, 0);
+        
+        rcu_call(&barrier->rcu_item, barrier_callback);
+        rcu_barrier();
+        
+        if (1 == atomic_get(&barrier->done)) {
+                free(barrier);
+                return true;
+        } else {
+                TPRINTF("rcu_barrier() exited prematurely.\n");
+                /* Leak some mem. */
+                return false;
+        }
+}
+
+/*-------------------------------------------------------------------*/
 
 typedef struct {
@@ -969 +1007 @@
                 { 1, do_reader_preempt, "do_reader_preempt" },
                 { 1, do_synch, "do_synch" },
+                { 1, do_barrier, "do_barrier" },
                 { 1, do_reader_exit, "do_reader_exit" },
                 { 1, do_nop_readers, "do_nop_readers" },