diff options
Diffstat (limited to 'src/protocol/reqrep0/xreq.c')
| -rw-r--r-- | src/protocol/reqrep0/xreq.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/protocol/reqrep0/xreq.c b/src/protocol/reqrep0/xreq.c index 2f0a3652..a98c713e 100644 --- a/src/protocol/reqrep0/xreq.c +++ b/src/protocol/reqrep0/xreq.c @@ -173,7 +173,7 @@ xreq0_getq_cb(void *arg) xreq0_pipe *p = arg; if (nni_aio_result(p->aio_getq) != 0) { - nni_pipe_stop(p->pipe); + nni_pipe_close(p->pipe); return; } @@ -191,7 +191,7 @@ xreq0_send_cb(void *arg) if (nni_aio_result(p->aio_send) != 0) { nni_msg_free(nni_aio_get_msg(p->aio_send)); nni_aio_set_msg(p->aio_send, NULL); - nni_pipe_stop(p->pipe); + nni_pipe_close(p->pipe); return; } @@ -207,7 +207,7 @@ xreq0_putq_cb(void *arg) if (nni_aio_result(p->aio_putq) != 0) { nni_msg_free(nni_aio_get_msg(p->aio_putq)); nni_aio_set_msg(p->aio_putq, NULL); - nni_pipe_stop(p->pipe); + nni_pipe_close(p->pipe); return; } nni_aio_set_msg(p->aio_putq, NULL); @@ -224,7 +224,7 @@ xreq0_recv_cb(void *arg) uint32_t id; if (nni_aio_result(p->aio_recv) != 0) { - nni_pipe_stop(p->pipe); + nni_pipe_close(p->pipe); return; } @@ -236,7 +236,7 @@ xreq0_recv_cb(void *arg) if (nni_msg_len(msg) < 4) { // Peer gave us garbage, so kick it. nni_msg_free(msg); - nni_pipe_stop(p->pipe); + nni_pipe_close(p->pipe); return; } id = nni_msg_trim_u32(msg); |