We don't need putback on message queues after all.

1 files changed, 0 insertions, 39 deletions

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)
 {