From 2a11fd60767335660dc506237a9302dcbc5da91e Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Fri, 11 Aug 2017 17:51:09 -0700 Subject: Fence post error in queue drain, close or fini. --- src/core/msgqueue.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/core/msgqueue.c b/src/core/msgqueue.c index 3972e07a..8d0c3dbc 100644 --- a/src/core/msgqueue.c +++ b/src/core/msgqueue.c @@ -106,7 +106,7 @@ nni_msgq_fini(nni_msgq *mq) while (mq->mq_len > 0) { msg = mq->mq_msgs[mq->mq_get]; mq->mq_get++; - if (mq->mq_get > mq->mq_alloc) { + if (mq->mq_get >= mq->mq_alloc) { mq->mq_get = 0; } mq->mq_len--; @@ -471,7 +471,7 @@ nni_msgq_drain(nni_msgq *mq, nni_time expire) // Free any remaining messages in the queue. while (mq->mq_len > 0) { nni_msg *msg = mq->mq_msgs[mq->mq_get++]; - if (mq->mq_get > mq->mq_alloc) { + if (mq->mq_get >= mq->mq_alloc) { mq->mq_get = 0; } mq->mq_len--; @@ -492,7 +492,7 @@ nni_msgq_close(nni_msgq *mq) // Free the messages orphaned in the queue. while (mq->mq_len > 0) { nni_msg *msg = mq->mq_msgs[mq->mq_get++]; - if (mq->mq_get > mq->mq_alloc) { + if (mq->mq_get >= mq->mq_alloc) { mq->mq_get = 0; } mq->mq_len--; -- cgit v1.2.3-70-g09d2