diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-06-27 21:52:27 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-06-27 21:52:27 -0700 |
| commit | 9a39b3cd0ef1d0439851ecfae757c6a93757b1b5 (patch) | |
| tree | f46ae8b72bf3db75c880574d4d770dce3b0ba062 | |
| parent | e2d17be2a7081888aaafea150d587a7ef9517e17 (diff) | |
| download | nng-9a39b3cd0ef1d0439851ecfae757c6a93757b1b5.tar.gz nng-9a39b3cd0ef1d0439851ecfae757c6a93757b1b5.tar.bz2 nng-9a39b3cd0ef1d0439851ecfae757c6a93757b1b5.zip | |
Put errors go on the putq.
| -rw-r--r-- | src/core/msgqueue.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/core/msgqueue.c b/src/core/msgqueue.c index 37d6d5ff..a58aff41 100644 --- a/src/core/msgqueue.c +++ b/src/core/msgqueue.c @@ -164,8 +164,8 @@ nni_msgq_set_put_error(nni_msgq *mq, int error) if (error != 0) { naio = nni_list_first(&mq->mq_aio_putq); while ((aio = naio) != NULL) { - naio = nni_list_next(&mq->mq_aio_getq, aio); - nni_list_remove(&mq->mq_aio_getq, aio); + naio = nni_list_next(&mq->mq_aio_putq, aio); + nni_list_remove(&mq->mq_aio_putq, aio); nni_aio_finish(aio, error, 0); } } @@ -191,8 +191,8 @@ nni_msgq_set_error(nni_msgq *mq, int error) } naio = nni_list_first(&mq->mq_aio_putq); while ((aio = naio) != NULL) { - naio = nni_list_next(&mq->mq_aio_getq, aio); - nni_list_remove(&mq->mq_aio_getq, aio); + naio = nni_list_next(&mq->mq_aio_putq, aio); + nni_list_remove(&mq->mq_aio_putq, aio); nni_aio_finish(aio, error, 0); } } |