diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-16 19:35:51 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-16 19:35:51 -0800 |
| commit | 50e1484af0d443b46aa04fd4a8096b157dc160aa (patch) | |
| tree | ab517217c82e785b0c851c986ee44dfc4a4a65fe /src/core/event.h | |
| parent | ac8415c24ffea645105c3859e814843e81c97f8a (diff) | |
| download | nng-50e1484af0d443b46aa04fd4a8096b157dc160aa.tar.gz nng-50e1484af0d443b46aa04fd4a8096b157dc160aa.tar.bz2 nng-50e1484af0d443b46aa04fd4a8096b157dc160aa.zip | |
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.
Diffstat (limited to 'src/core/event.h')
| -rw-r--r-- | src/core/event.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/core/event.h b/src/core/event.h index d7faad2e..8b160a89 100644 --- a/src/core/event.h +++ b/src/core/event.h @@ -32,4 +32,10 @@ struct nng_notify { int n_mask; }; +extern void nni_notifier(void *); +extern int nni_ev_init(nni_event *, int, nni_sock *); +extern void nni_ev_fini(nni_event *); +extern void nni_ev_submit(nni_event *); // call holding sock lock +extern void nni_ev_wait(nni_event *); // call holding sock lock + #endif // CORE_EVENT_H |