From 63479c2938cbc80c1aac9367cb95564f6e7540e1 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Mon, 14 Aug 2017 15:27:38 -0700 Subject: fixes #63 NNG_FLAG_SYNCH should be the default Also enables creating endpoints that are idle (first part of endpoint options API) and shutting down endpoints. --- src/nng.c | 60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 file changed, 55 insertions(+), 5 deletions(-) (limited to 'src/nng.c') diff --git a/src/nng.c b/src/nng.c index 421ce74a..21543dbc 100644 --- a/src/nng.c +++ b/src/nng.c @@ -277,19 +277,69 @@ nng_listen(nng_socket sid, const char *addr, nng_listener *lp, int flags) return (rv); } +int +nng_listener_create(nng_listener *lp, nng_socket sid, const char *addr) +{ + nni_sock *s; + nni_ep * ep; + int rv; + + if ((rv = nni_sock_find(&s, sid)) != 0) { + return (rv); + } + if ((rv = nni_ep_create_listener(&ep, s, addr)) != 0) { + nni_sock_rele(s); + return (rv); + } + *lp = nni_ep_id(ep); + nni_ep_rele(ep); + nni_sock_rele(s); + return (0); +} + +int +nng_dialer_create(nng_dialer *dp, nng_socket sid, const char *addr) +{ + nni_sock *s; + nni_ep * ep; + int rv; + + if ((rv = nni_sock_find(&s, sid)) != 0) { + return (rv); + } + if ((rv = nni_ep_create_dialer(&ep, s, addr)) != 0) { + nni_sock_rele(s); + return (rv); + } + *dp = nni_ep_id(ep); + nni_ep_rele(ep); + nni_sock_rele(s); + return (0); +} + +static int +nng_ep_close(uint32_t id) +{ + nni_ep *ep; + int rv; + + if ((rv = nni_ep_find(&ep, id)) != 0) { + return (rv); + } + nni_ep_close(ep); + return (0); +} + int nng_dialer_close(nng_dialer d) { - // return (nni_ep_close()); - NNI_ARG_UNUSED(d); - return (NNG_ENOTSUP); + return (nng_ep_close((uint32_t) d)); } int nng_listener_close(nng_listener l) { - NNI_ARG_UNUSED(l); - return (NNG_ENOTSUP); + return (nng_ep_close((uint32_t) l)); } int -- cgit v1.2.3-70-g09d2