aboutsummaryrefslogtreecommitdiff
path: root/src/core/pipe.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/pipe.c')
-rw-r--r--src/core/pipe.c4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index cdbeb6a7..94524da4 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -117,7 +117,9 @@ nni_pipe_destroy(nni_pipe *p)
if (nni_list_node_active(&p->p_ep_node)) {
nni_ep_pipe_remove(p->p_ep, p);
}
- nni_sock_pipe_remove(p->p_sock, p);
+ if (nni_list_node_active(&p->p_sock_node)) {
+ nni_sock_pipe_remove(p->p_sock, p);
+ }
if (p->p_tran_data != NULL) {
p->p_tran_ops.p_fini(p->p_tran_data);