diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-01 19:14:26 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-01 19:14:26 -0800 |
| commit | 3a421d08f87b8b34786ac47e30552fbdb2cf4371 (patch) | |
| tree | cc430dedd312cb670c8c8b7c29dcfd01e8e08d75 /src/core/socket.c | |
| parent | f26dea6463adce8d70e1a4b22d8f9a867cf672c6 (diff) | |
| download | nng-3a421d08f87b8b34786ac47e30552fbdb2cf4371.tar.gz nng-3a421d08f87b8b34786ac47e30552fbdb2cf4371.tar.bz2 nng-3a421d08f87b8b34786ac47e30552fbdb2cf4371.zip | |
Endpoint uses single thread.
Diffstat (limited to 'src/core/socket.c')
| -rw-r--r-- | src/core/socket.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/socket.c b/src/core/socket.c index 3536934a..a79b1fde 100644 --- a/src/core/socket.c +++ b/src/core/socket.c @@ -74,7 +74,7 @@ nni_reaper(void *arg) if ((sock->s_closing) && (nni_list_first(&sock->s_reaps) == NULL) && (nni_list_first(&sock->s_pipes) == NULL)) { - nni_mutex_exit(&sock->s_mx); + nni_mutex_exit(&sock->s_mx); break; } @@ -132,7 +132,7 @@ nni_socket_create(nni_socket **sockp, uint16_t proto) nni_mutex_fini(&sock->s_mx); nni_free(sock, sizeof (*sock)); return (rv); - } + } if ((rv = nni_msgqueue_create(&sock->s_urq, 0)) != 0) { nni_msgqueue_destroy(sock->s_uwq); nni_thr_fini(&sock->s_reaper); |