aboutsummaryrefslogtreecommitdiff
path: root/src/core/endpt.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-13 22:19:20 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-13 22:19:20 -0700
commitf7463b4bd9b549a152b28aff959113b9ab56959a (patch)
tree6f7e58b85a1c7a7ce1082d5a04068ee7272fda16 /src/core/endpt.c
parentd3de15eb854b88844071685f13cb70064d1fda49 (diff)
downloadnng-f7463b4bd9b549a152b28aff959113b9ab56959a.tar.gz
nng-f7463b4bd9b549a152b28aff959113b9ab56959a.tar.bz2
nng-f7463b4bd9b549a152b28aff959113b9ab56959a.zip
Use the same pipe teardown in all circumstances.
Diffstat (limited to 'src/core/endpt.c')
-rw-r--r--src/core/endpt.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/endpt.c b/src/core/endpt.c
index d8f94d9b..7784de73 100644
--- a/src/core/endpt.c
+++ b/src/core/endpt.c
@@ -254,7 +254,7 @@ nni_ep_connect_sync(nni_ep *ep)
}
rv = nni_ep_connect_aio(ep, &pipe->p_tran_data);
if (rv != 0) {
- nni_pipe_remove(pipe);
+ nni_pipe_stop(pipe);
return (rv);
}
nni_pipe_start(pipe);
@@ -435,7 +435,7 @@ nni_ep_accept_sync(nni_ep *ep)
}
rv = nni_ep_accept_aio(ep, &pipe->p_tran_data);
if (rv != 0) {
- nni_pipe_remove(pipe);
+ nni_pipe_stop(pipe);
return (rv);
}
nni_pipe_start(pipe);