diff options
Diffstat (limited to 'src/core/event.c')
| -rw-r--r-- | src/core/event.c | 18 |
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; |
