From 907a1eb392ca4b29c62b9cc3d2df1ad337695abf Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Tue, 24 Jan 2017 14:28:59 -0800 Subject: Add nni_ep_hold, nni_ep_hold_close, nni_ep_rele, nng_endpoint_close. --- src/nng.c | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) (limited to 'src/nng.c') diff --git a/src/nng.c b/src/nng.c index e21a84e6..a534b1bc 100644 --- a/src/nng.c +++ b/src/nng.c @@ -231,7 +231,7 @@ nng_dial(nng_socket sid, const char *addr, nng_endpoint *epp, int flags) } if ((rv = nni_sock_dial(sock, addr, &ep, flags)) == 0) { if (epp != NULL) { - *epp = ep->ep_id; + *epp = nni_ep_id(ep); } } nni_sock_rele(sock); @@ -251,7 +251,7 @@ nng_listen(nng_socket sid, const char *addr, nng_endpoint *epp, int flags) } if ((rv = nni_sock_listen(sock, addr, &ep, flags)) == 0) { if (epp != NULL) { - *epp = ep->ep_id; + *epp = nni_ep_id(ep); } } nni_sock_rele(sock); @@ -262,8 +262,14 @@ nng_listen(nng_socket sid, const char *addr, nng_endpoint *epp, int flags) int nng_endpoint_close(nng_endpoint eid) { - // XXX: FIXME: lookup endpoint by id, and then close it. - return (NNG_ENOTSUP); + int rv; + nni_ep *ep; + + if ((rv = nni_ep_hold_close(&ep, eid)) != 0) { + return (rv); + } + nni_ep_close(ep); + return (0); } -- cgit v1.2.3-70-g09d2