aboutsummaryrefslogtreecommitdiff
path: root/src/core/msgqueue.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2016-12-23 02:04:58 -0800
committerGarrett D'Amore <garrett@damore.org>2016-12-23 02:04:58 -0800
commit471a454900ab6142e5a3c1f53866996172d2aad4 (patch)
tree8238d500faeefce1d970f6f62e648bae9d66736e /src/core/msgqueue.c
parentd708b178f049839bfdbaf0289e400363eac78a30 (diff)
downloadnng-471a454900ab6142e5a3c1f53866996172d2aad4.tar.gz
nng-471a454900ab6142e5a3c1f53866996172d2aad4.tar.bz2
nng-471a454900ab6142e5a3c1f53866996172d2aad4.zip
Don't linger if there are no possible readers present.
Diffstat (limited to 'src/core/msgqueue.c')
-rw-r--r--src/core/msgqueue.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/core/msgqueue.c b/src/core/msgqueue.c
index 823f6e45..fd89b7ad 100644
--- a/src/core/msgqueue.c
+++ b/src/core/msgqueue.c
@@ -42,7 +42,7 @@ nni_msgqueue_create(nni_msgqueue **mqp, int cap)
// We allocate 2 extra cells in the fifo. One to accommodate a
// waiting writer when cap == 0. (We can "briefly" move the message
- // through. This lets us behave the same as unbuffered Go channels.
+ // through.) This lets us behave the same as unbuffered Go channels.
// The second cell is to permit pushback later, e.g. for REQ to stash
// a message back at the end to do a retry.
alloc = cap + 2;