aboutsummaryrefslogtreecommitdiff
path: root/lib/seq.h
diff options
context:
space:
mode:
authorBen Pfaff <blp@nicira.com>2013-08-12 13:45:01 -0700
committerBen Pfaff <blp@nicira.com>2013-08-12 13:59:02 -0700
commit5d389d55c78a20bd18b68b35f0e6cabae2686dcb (patch)
treea3408972027b67f650f4b1c51916de681478eeb8 /lib/seq.h
parent5e1de67fa16019acac301dd410ead42833dc3256 (diff)
seq: Add some comments.
Signed-off-by: Ben Pfaff <blp@nicira.com>
Diffstat (limited to 'lib/seq.h')
-rw-r--r--lib/seq.h40
1 files changed, 39 insertions, 1 deletions
diff --git a/lib/seq.h b/lib/seq.h
index 3423e217..c764809e 100644
--- a/lib/seq.h
+++ b/lib/seq.h
@@ -20,7 +20,7 @@
/* Thread-safe, pollable sequence number.
*
*
- * Background
+ * Motivation
* ==========
*
* It is sometimes desirable to take an action whenever an object changes.
@@ -66,6 +66,44 @@
* poll_block();
*
*
+ * Alternate Usage
+ * ===============
+ *
+ * struct seq can also be used as a sort of pollable condition variable.
+ * Suppose that we want a thread to process items in a queue, and thus to be
+ * able to wake up whenever the queue is nonempty. This requires a lock to
+ * protect the queue and a seq to signal that the queue has become nonempty,
+ * e.g.:
+ *
+ * struct ovs_mutex mutex;
+ * struct list queue OVS_GUARDED_BY(mutex);
+ * struct seq nonempty_seq;
+ *
+ * To add an element to the queue:
+ *
+ * ovs_mutex_lock(&mutex);
+ * list_push_back(&queue, ...element...);
+ * if (list_is_singleton(&queue)) { // The 'if' test here is optional.
+ * seq_change(&nonempty_seq);
+ * }
+ * ovs_mutex_unlock(&mutex);
+ *
+ * To wait for the queue to become nonempty:
+ *
+ * ovs_mutex_lock(&mutex);
+ * if (list_is_empty(&queue)) {
+ * seq_wait(&nonempty_seq, seq_read(&nonempty_seq));
+ * } else {
+ * poll_immediate_wake();
+ * }
+ * ovs_mutex_unlock(&mutex);
+ *
+ * (In the above code 'mutex' prevents the queue from changing between
+ * seq_read() and seq_wait(). Otherwise, it would be necessary to seq_read(),
+ * check for a nonempty queue, and then seq_wait() on the previously read
+ * sequence number, as under Usage above.)
+ *
+ *
* Thread-safety
* =============
*