diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-07 22:23:37 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-07 22:23:37 -0800 |
| commit | cb01bb934be4432252c80d139682bfea23c3efa8 (patch) | |
| tree | 273205f182abe0cabec5ca5017ed1605748fd7de | |
| parent | 0f8fc066cca5567ba5c3e068766270bcc5daee21 (diff) | |
| download | nng-cb01bb934be4432252c80d139682bfea23c3efa8.tar.gz nng-cb01bb934be4432252c80d139682bfea23c3efa8.tar.bz2 nng-cb01bb934be4432252c80d139682bfea23c3efa8.zip | |
Clean up sender/recver threads.
| -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); |