diff options
| author | Garrett D'Amore <garrett@damore.org> | 2016-12-23 01:50:31 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2016-12-23 01:50:31 -0800 |
| commit | 72440b0d815b1b79941f3f58a47ec4df1ba1e0fc (patch) | |
| tree | 6494c69b89f36ab75976fc7acaec68a4d4f0d1bf /src/core/socket.c | |
| parent | 07478f02caaebf74c11b366d048ba696a8678fec (diff) | |
| download | nng-72440b0d815b1b79941f3f58a47ec4df1ba1e0fc.tar.gz nng-72440b0d815b1b79941f3f58a47ec4df1ba1e0fc.tar.bz2 nng-72440b0d815b1b79941f3f58a47ec4df1ba1e0fc.zip | |
Some tests around recvmsg (no senders yet). Fixes for some edge cases.
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 99573a2f..e3298886 100644 --- a/src/core/socket.c +++ b/src/core/socket.c @@ -57,8 +57,8 @@ nni_socket_create(nni_socket **sockp, uint16_t proto) NNI_LIST_INIT(&sock->s_pipes, nni_pipe, p_sock_node); NNI_LIST_INIT(&sock->s_eps, nni_endpt, ep_sock_node); - if (((rv = nni_msgqueue_create(&sock->s_uwq, 1)) != 0) || - ((rv = nni_msgqueue_create(&sock->s_urq, 1)) != 0)) { + if (((rv = nni_msgqueue_create(&sock->s_uwq, 0)) != 0) || + ((rv = nni_msgqueue_create(&sock->s_urq, 0)) != 0)) { goto fail; } |