diff options
Diffstat (limited to 'src/protocol/reqrep0/req.c')
| -rw-r--r-- | src/protocol/reqrep0/req.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/protocol/reqrep0/req.c b/src/protocol/reqrep0/req.c index 3ecc8604..bbb0b886 100644 --- a/src/protocol/reqrep0/req.c +++ b/src/protocol/reqrep0/req.c @@ -638,7 +638,7 @@ req0_ctx_recv(void *arg, nni_aio *aio) if ((msg = ctx->repmsg) == NULL) { int rv; - rv = nni_aio_schedule_verify(aio, req0_ctx_cancel_recv, ctx); + rv = nni_aio_schedule(aio, req0_ctx_cancel_recv, ctx); if (rv != 0) { nni_mtx_unlock(&s->mtx); nni_aio_finish_error(aio, rv); @@ -740,7 +740,7 @@ req0_ctx_send(void *arg, nni_aio *aio) } // If no pipes are ready, and the request was a poll (no background // schedule), then fail it. Should be NNG_TIMEDOUT. - rv = nni_aio_schedule_verify(aio, req0_ctx_cancel_send, ctx); + rv = nni_aio_schedule(aio, req0_ctx_cancel_send, ctx); if ((rv != 0) && (nni_list_empty(&s->readypipes))) { nni_idhash_remove(s->reqids, id); nni_mtx_unlock(&s->mtx); |