From 557964482f2b9d4246a2943fb1bedc6074d01e0d Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Tue, 3 Oct 2017 12:57:04 -0700 Subject: fixes #99 Still seeing segfaults in pair1 (rarely) --- src/protocol/pair/pair_v0.c | 8 ++++---- src/protocol/pair/pair_v1.c | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) (limited to 'src/protocol') diff --git a/src/protocol/pair/pair_v0.c b/src/protocol/pair/pair_v0.c index 9cabe3c7..a87af593 100644 --- a/src/protocol/pair/pair_v0.c +++ b/src/protocol/pair/pair_v0.c @@ -139,10 +139,10 @@ pair0_pipe_stop(void *arg) pair0_pipe *p = arg; pair0_sock *s = p->psock; - nni_aio_cancel(p->aio_send, NNG_ECANCELED); - nni_aio_cancel(p->aio_recv, NNG_ECANCELED); - nni_aio_cancel(p->aio_putq, NNG_ECANCELED); - nni_aio_cancel(p->aio_getq, NNG_ECANCELED); + nni_aio_stop(p->aio_send); + nni_aio_stop(p->aio_recv); + nni_aio_stop(p->aio_putq); + nni_aio_stop(p->aio_getq); nni_mtx_lock(&s->mtx); if (s->ppipe == p) { diff --git a/src/protocol/pair/pair_v1.c b/src/protocol/pair/pair_v1.c index 0b9e0643..a27203b2 100644 --- a/src/protocol/pair/pair_v1.c +++ b/src/protocol/pair/pair_v1.c @@ -191,10 +191,10 @@ pair1_pipe_stop(void *arg) nni_mtx_unlock(&s->mtx); nni_msgq_close(p->sendq); - nni_aio_cancel(p->aio_send, NNG_ECANCELED); - nni_aio_cancel(p->aio_recv, NNG_ECANCELED); - nni_aio_cancel(p->aio_putq, NNG_ECANCELED); - nni_aio_cancel(p->aio_getq, NNG_ECANCELED); + nni_aio_stop(p->aio_send); + nni_aio_stop(p->aio_recv); + nni_aio_stop(p->aio_putq); + nni_aio_stop(p->aio_getq); } static void -- cgit v1.2.3-70-g09d2