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 | |
| 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')
| -rw-r--r-- | src/core/socket.c | 4 | ||||
| -rw-r--r-- | src/core/socket.h | 1 |
2 files changed, 3 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; } diff --git a/src/core/socket.h b/src/core/socket.h index 1376c454..4fa59355 100644 --- a/src/core/socket.h +++ b/src/core/socket.h @@ -45,5 +45,6 @@ extern void nni_socket_rem_pipe(nni_socket *, nni_pipe *); extern uint16_t nni_socket_proto(nni_socket *); extern int nni_socket_setopt(nni_socket *, int, const void *, size_t); extern int nni_socket_getopt(nni_socket *, int, void *, size_t *); +extern int nni_socket_recvmsg(nni_socket *, nni_msg **, int); #endif // CORE_SOCKET_H |