From 07078e1cf761cb6e56e46bde3ade6f792368d7dd Mon Sep 17 00:00:00 2001
From: Garrett D'Amore <garrett@damore.org>
Date: Fri, 21 Jul 2017 02:09:55 -0700
Subject: fixes #28 Occasional orphaned pipe or endpoint?

---
 src/transport/ipc/ipc.c | 2 ++
 src/transport/tcp/tcp.c | 2 ++
 2 files changed, 4 insertions(+)

(limited to 'src')

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
-- 
cgit v1.2.3-70-g09d2