Recv/Send event plumbing implemented (msgqueue and up).

This change provides for a private callback in the message queues,
which can be used to notify the socket, and which than arranges for
the appropriate event thread to run.

Upper layer hooks to access this still need to be written.

1 files changed, 11 insertions, 0 deletions

diff --git a/src/core/msgqueue.h b/src/core/msgqueue.h
index 450c55a4..07f6aebb 100644
--- a/src/core/msgqueue.h
+++ b/src/core/msgqueue.h
@@ -131,4 +131,15 @@ extern int nni_msgq_cap(nni_msgq *mq);
 // nni_msgq_len returns the number of messages currently in the queue.
 extern int nni_msgq_len(nni_msgq *mq);
 
+#define NNI_MSGQ_NOTIFY_CANPUT		1
+#define NNI_MSGQ_NOTIFY_CANGET		2
+
+typedef void (*nni_msgq_notify_fn)(nni_msgq *, int, void *);
+
+// nni_msgq_notify registers a function to be called when the message
+// queue state changes.  It notifies that the queue is readable, or writeable.
+// Only one function can be registered (for simplicity), and it is called
+// outside of the queue's lock.
+extern void nni_msgq_notify(nni_msgq *, nni_msgq_notify_fn, void *);
+
 #endif  // CORE_MSQUEUE_H