From a933bbbbf2399a3440442970e17b140e77c1203c Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Thu, 5 Jan 2017 18:49:49 -0800 Subject: PUB protocol (untested). --- src/core/msgqueue.c | 9 +++++++++ 1 file changed, 9 insertions(+) (limited to 'src/core/msgqueue.c') 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 @@ -322,6 +322,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) { -- cgit v1.2.3-70-g09d2