diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-07-21 02:09:55 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-07-21 02:09:55 -0700 |
| commit | 07078e1cf761cb6e56e46bde3ade6f792368d7dd (patch) | |
| tree | 128045a356cb1674561ea5d48d66c4a3ee4f043d | |
| parent | 191c43b57d81754b3572562a1a73d889c4d979e8 (diff) | |
| download | nng-07078e1cf761cb6e56e46bde3ade6f792368d7dd.tar.gz nng-07078e1cf761cb6e56e46bde3ade6f792368d7dd.tar.bz2 nng-07078e1cf761cb6e56e46bde3ade6f792368d7dd.zip | |
fixes #28 Occasional orphaned pipe or endpoint?
| -rw-r--r-- | src/transport/ipc/ipc.c | 2 | ||||
| -rw-r--r-- | src/transport/tcp/tcp.c | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c index b2b9c438..96dae6de 100644 --- a/src/transport/ipc/ipc.c +++ b/src/transport/ipc/ipc.c @@ -511,6 +511,8 @@ nni_ipc_ep_close(void *arg) ep->closed = 1; nni_plat_ipc_ep_close(ep->iep); nni_mtx_unlock(&ep->mtx); + + nni_aio_stop(&ep->aio); } static int diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c index 1bd42cec..28677f54 100644 --- a/src/transport/tcp/tcp.c +++ b/src/transport/tcp/tcp.c @@ -576,6 +576,8 @@ nni_tcp_ep_close(void *arg) ep->closed = 1; nni_plat_tcp_ep_close(ep->tep); nni_mtx_unlock(&ep->mtx); + + nni_aio_stop(&ep->aio); } static int |