From cb01bb934be4432252c80d139682bfea23c3efa8 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Sat, 7 Jan 2017 22:23:37 -0800 Subject: Clean up sender/recver threads. --- src/core/socket.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/core/socket.c') diff --git a/src/core/socket.c b/src/core/socket.c index e9f61e97..6b4054e9 100644 --- a/src/core/socket.c +++ b/src/core/socket.c @@ -197,7 +197,6 @@ nni_sock_open(nni_sock **sockp, uint16_t pnum) return (rv); } - if ((rv = nni_thr_init(&sock->s_reaper, nni_reaper, sock)) != 0) { nni_cv_fini(&sock->s_cv); nni_mtx_fini(&sock->s_mx); @@ -376,6 +375,8 @@ nni_sock_close(nni_sock *sock) // And we need to clean up *our* state. nni_thr_fini(&sock->s_reaper); + nni_thr_fini(&sock->s_sender); + nni_thr_fini(&sock->s_recver); nni_msgq_fini(sock->s_urq); nni_msgq_fini(sock->s_uwq); nni_cv_fini(&sock->s_cv); -- cgit v1.2.3-70-g09d2