diff options
Diffstat (limited to 'src/transport')
| -rw-r--r-- | src/transport/ipc/ipc.c | 5 | ||||
| -rw-r--r-- | src/transport/tcp/tcp.c | 5 |
2 files changed, 10 insertions, 0 deletions
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c index 65266ccc..b2b9c438 100644 --- a/src/transport/ipc/ipc.c +++ b/src/transport/ipc/ipc.c @@ -86,6 +86,10 @@ nni_ipc_pipe_fini(void *arg) { nni_ipc_pipe *pipe = arg; + nni_aio_stop(&pipe->rxaio); + nni_aio_stop(&pipe->txaio); + nni_aio_stop(&pipe->negaio); + nni_aio_fini(&pipe->rxaio); nni_aio_fini(&pipe->txaio); nni_aio_fini(&pipe->negaio); @@ -462,6 +466,7 @@ nni_ipc_ep_fini(void *arg) { nni_ipc_ep *ep = arg; + nni_aio_stop(&ep->aio); nni_plat_ipc_ep_fini(ep->iep); nni_aio_fini(&ep->aio); nni_mtx_fini(&ep->mtx); diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c index 13d5716a..1bd42cec 100644 --- a/src/transport/tcp/tcp.c +++ b/src/transport/tcp/tcp.c @@ -86,6 +86,10 @@ nni_tcp_pipe_fini(void *arg) { nni_tcp_pipe *pipe = arg; + nni_aio_stop(&pipe->rxaio); + nni_aio_stop(&pipe->txaio); + nni_aio_stop(&pipe->negaio); + nni_aio_fini(&pipe->rxaio); nni_aio_fini(&pipe->txaio); nni_aio_fini(&pipe->negaio); @@ -530,6 +534,7 @@ nni_tcp_ep_fini(void *arg) { nni_tcp_ep *ep = arg; + nni_aio_stop(&ep->aio); if (ep->tep != NULL) { nni_plat_tcp_ep_fini(ep->tep); } |