From 72440b0d815b1b79941f3f58a47ec4df1ba1e0fc Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Fri, 23 Dec 2016 01:50:31 -0800 Subject: Some tests around recvmsg (no senders yet). Fixes for some edge cases. --- src/nng.c | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) (limited to 'src/nng.c') diff --git a/src/nng.c b/src/nng.c index cb340184..b05667c4 100644 --- a/src/nng.c +++ b/src/nng.c @@ -48,6 +48,22 @@ nng_socket_protocol(nng_socket *s) return (nni_socket_proto(s)); } +int +nng_recvmsg(nng_socket *s, nng_msg **msgp, int flags) +{ + int rv; + nni_duration expire; + if ((rv = nni_init()) != 0) { + return (rv); + } + if (flags == NNG_FLAG_NONBLOCK) { + expire = 0; + } else { + // XXX: revise this timeout from socket option!! + expire = 1000000; + } + return (nni_socket_recvmsg(s, msgp, expire)); +} // Misc. const char * -- cgit v1.2.3-70-g09d2