aboutsummaryrefslogtreecommitdiff
path: root/src/transport
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-06-28 23:07:28 -0700
committerGarrett D'Amore <garrett@damore.org>2017-06-28 23:07:28 -0700
commitfe3c9705072ac8cafecdf2ea6bca4c26f9464824 (patch)
tree07aaea70cbf8bb6af369d5efede475ed03ffdd63 /src/transport
parent10d748fa6444324878a77cc5749c93b75819ced2 (diff)
downloadnng-fe3c9705072ac8cafecdf2ea6bca4c26f9464824.tar.gz
nng-fe3c9705072ac8cafecdf2ea6bca4c26f9464824.tar.bz2
nng-fe3c9705072ac8cafecdf2ea6bca4c26f9464824.zip
Refactor stop again, closing numerous races (thanks valgrind!)
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/ipc/ipc.c2
-rw-r--r--src/transport/tcp/tcp.c2
2 files changed, 0 insertions, 4 deletions
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c
index 7ffea62d..ada7a87c 100644
--- a/src/transport/ipc/ipc.c
+++ b/src/transport/ipc/ipc.c
@@ -409,7 +409,6 @@ nni_ipc_ep_connect(void *arg, void *pipearg)
}
if ((rv = nni_ipc_negotiate(pipe)) != 0) {
- nni_plat_ipc_shutdown(pipe->isp);
return (rv);
}
return (0);
@@ -450,7 +449,6 @@ nni_ipc_ep_accept(void *arg, void *pipearg)
return (rv);
}
if ((rv = nni_ipc_negotiate(pipe)) != 0) {
- nni_plat_ipc_shutdown(pipe->isp);
return (rv);
}
return (0);
diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c
index 7e712cc8..1c1eabbf 100644
--- a/src/transport/tcp/tcp.c
+++ b/src/transport/tcp/tcp.c
@@ -494,7 +494,6 @@ nni_tcp_ep_connect(void *arg, void *pipearg)
}
if ((rv = nni_tcp_negotiate(pipe)) != 0) {
- nni_plat_tcp_shutdown(pipe->tsp);
return (rv);
}
return (0);
@@ -546,7 +545,6 @@ nni_tcp_ep_accept(void *arg, void *pipearg)
return (rv);
}
if ((rv = nni_tcp_negotiate(pipe)) != 0) {
- nni_plat_tcp_shutdown(pipe->tsp);
return (rv);
}
return (0);