diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-05 18:49:49 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-05 18:49:49 -0800 |
| commit | a933bbbbf2399a3440442970e17b140e77c1203c (patch) | |
| tree | 032d25d14418a70d6b3d7640ea59b4a79f3de276 /src/core/msgqueue.c | |
| parent | 1b6e9985960a1079be81a576d52aa7f3fe47c92b (diff) | |
| download | nng-a933bbbbf2399a3440442970e17b140e77c1203c.tar.gz nng-a933bbbbf2399a3440442970e17b140e77c1203c.tar.bz2 nng-a933bbbbf2399a3440442970e17b140e77c1203c.zip | |
PUB protocol (untested).
Diffstat (limited to 'src/core/msgqueue.c')
| -rw-r--r-- | src/core/msgqueue.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/core/msgqueue.c b/src/core/msgqueue.c index 0f1872dc..a95057d2 100644 --- a/src/core/msgqueue.c +++ b/src/core/msgqueue.c @@ -323,6 +323,15 @@ nni_msgq_put(nni_msgq *mq, nni_msg *msg) int +nni_msgq_tryput(nni_msgq *mq, nni_msg *msg) +{ + nni_signal nosig = 0; + + return (nni_msgq_put_(mq, msg, NNI_TIME_ZERO, &nosig)); +} + + +int nni_msgq_put_sig(nni_msgq *mq, nni_msg *msg, nni_signal *signal) { return (nni_msgq_put_(mq, msg, NNI_TIME_NEVER, signal)); |