aboutsummaryrefslogtreecommitdiff
path: root/src/core/event.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/event.c')
-rw-r--r--src/core/event.c18
1 files changed, 7 insertions, 11 deletions
diff --git a/src/core/event.c b/src/core/event.c
index 73bc1c00..98156a92 100644
--- a/src/core/event.c
+++ b/src/core/event.c
@@ -49,6 +49,13 @@ nni_ev_submit(nni_event *event)
return;
}
+ // XXX: taskq_dispatch the event processing.
+ // This probably should bump a reference count on the socket
+ // first.
+ // XXX: One question of note... the aio structures we use elsewhere
+ // would be better than this. So instead of the handler doing two
+ // context switches we can just do one.
+
// Call with socket mutex owned!
if (event->e_pending == 0) {
event->e_pending = 1;
@@ -60,17 +67,6 @@ nni_ev_submit(nni_event *event)
void
-nni_ev_wait(nni_event *event)
-{
- // Call with socket mutex owned!
- // Note that the socket mutex is dropped during the call.
- while ((event->e_pending) && (!event->e_done)) {
- nni_cv_wait(&event->e_cv);
- }
-}
-
-
-void
nni_notifier(void *arg)
{
nni_sock *sock = arg;