diff options
Diffstat (limited to 'src/core/socket.c')
| -rw-r--r-- | src/core/socket.c | 3 |
1 files changed, 2 insertions, 1 deletions
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); |