diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-03-10 21:02:57 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-03-10 21:02:57 -0800 |
| commit | 97fb819ccfd0d4cb7f02d7fc521d9478ba050776 (patch) | |
| tree | f9517083e33473cfa790611c6cbec4650ceed6f4 /src/core/msgqueue.h | |
| parent | b89a02106c3388f40ab4cd3610de102259fa5da0 (diff) | |
| download | nng-97fb819ccfd0d4cb7f02d7fc521d9478ba050776.tar.gz nng-97fb819ccfd0d4cb7f02d7fc521d9478ba050776.tar.bz2 nng-97fb819ccfd0d4cb7f02d7fc521d9478ba050776.zip | |
Surveyor pattern callback-driven.
Diffstat (limited to 'src/core/msgqueue.h')
| -rw-r--r-- | src/core/msgqueue.h | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/src/core/msgqueue.h b/src/core/msgqueue.h index de23ebac..51143706 100644 --- a/src/core/msgqueue.h +++ b/src/core/msgqueue.h @@ -72,23 +72,6 @@ extern int nni_msgq_put_until(nni_msgq *, nni_msg *, nni_time); // a message from the queue, it will return NNG_ETIMEDOUT. extern int nni_msgq_get_until(nni_msgq *, nni_msg **, nni_time); -// nni_msgq_put_sig is an enhanced version of nni_msgq_put, but it -// can be interrupted by nni_msgqueue_signal using the same final pointer, -// which can be thought of as a turnstile. If interrupted it returns EINTR. -// The turnstile should be initialized to zero. -extern int nni_msgq_put_sig(nni_msgq *, nni_msg *, nni_signal *); - -// nni_msgq_get_sig is an enhanced version of nni_msgq_get_t, but it -// can be interrupted by nni_msgq_signal using the same final pointer, -// which can be thought of as a turnstile. If interrupted it returns EINTR. -// The turnstile should be initialized to zero. -extern int nni_msgq_get_sig(nni_msgq *, nni_msg **, nni_signal *); - -// nni_msgq_signal delivers a signal / interrupt to waiters blocked in -// the msgq, if they have registered an interest in the same turnstile. -// It modifies the turnstile's value under the lock to a non-zero value. -extern void nni_msgq_signal(nni_msgq *, nni_signal *); - // nni_msgq_set_error sets an error condition on the message queue, // which causes all current and future readers/writes to return the // given error condition (if non-zero). Threads waiting to put or get |
