From eb0d439ac82c49b244615fba4226a0351c4efd64 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Sat, 18 Feb 2017 18:38:54 -0800 Subject: We don't need putback on message queues after all. --- src/core/msgqueue.c | 39 --------------------------------------- 1 file changed, 39 deletions(-) (limited to 'src/core/msgqueue.c') diff --git a/src/core/msgqueue.c b/src/core/msgqueue.c index 09f58a33..b09bb817 100644 --- a/src/core/msgqueue.c +++ b/src/core/msgqueue.c @@ -343,45 +343,6 @@ nni_msgq_put_(nni_msgq *mq, nni_msg *msg, nni_time expire, nni_signal *sig) } -// nni_msgq_putback will attempt to put a single message back -// to the head of the queue. It never blocks. Message queues always -// have room for at least one putback. -int -nni_msgq_putback(nni_msgq *mq, nni_msg *msg) -{ - nni_mtx_lock(&mq->mq_lock); - - // if closed, we don't put more... this check is first! - if (mq->mq_closed) { - nni_mtx_unlock(&mq->mq_lock); - return (NNG_ECLOSED); - } - - // room in the queue? - if (mq->mq_len >= mq->mq_cap) { - nni_mtx_unlock(&mq->mq_lock); - return (NNG_EAGAIN); - } - - // Subtract one from the get index, possibly wrapping. - mq->mq_get--; - if (mq->mq_get == 0) { - mq->mq_get = mq->mq_cap; - } - mq->mq_msgs[mq->mq_get] = msg; - mq->mq_len++; - if (mq->mq_rwait) { - mq->mq_rwait = 0; - nni_cv_wake(&mq->mq_readable); - } - - nni_msgq_kick(mq, NNI_MSGQ_NOTIFY_CANGET); - nni_mtx_unlock(&mq->mq_lock); - - return (0); -} - - static int nni_msgq_get_(nni_msgq *mq, nni_msg **msgp, nni_time expire, nni_signal *sig) { -- cgit v1.2.3-70-g09d2