diff --git a/src/sp/protocol/pair1/pair.c b/src/sp/protocol/pair1/pair.c index ee5d8a265..b4d136997 100644 --- a/src/sp/protocol/pair1/pair.c +++ b/src/sp/protocol/pair1/pair.c @@ -199,8 +199,8 @@ pair1_pipe_stop(void *arg) pair1_pipe *p = arg; pair1_sock *s = p->pair; - nni_aio_stop(&p->aio_send); - nni_aio_stop(&p->aio_recv); + nni_aio_close(&p->aio_send); + nni_aio_close(&p->aio_recv); nni_mtx_lock(&s->mtx); if (s->p == p) { s->p = NULL; @@ -218,6 +218,8 @@ pair1_pipe_stop(void *arg) } } nni_mtx_unlock(&s->mtx); + nni_aio_stop(&p->aio_send); + nni_aio_stop(&p->aio_recv); } static void