diff options
| author | Garrett D'Amore <garrett@damore.org> | 2025-04-27 22:02:04 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2025-04-27 22:02:04 -0700 |
| commit | 03f812ccb2876aacd10e589f996b5ec9e0133d5b (patch) | |
| tree | 8393333b23528c3641a39ed81e44188ddfbe507a /src/platform/posix | |
| parent | c5b07415cc3a6a7960cb3ca2a2aaf70b1cbe3469 (diff) | |
| download | nng-03f812ccb2876aacd10e589f996b5ec9e0133d5b.tar.gz nng-03f812ccb2876aacd10e589f996b5ec9e0133d5b.tar.bz2 nng-03f812ccb2876aacd10e589f996b5ec9e0133d5b.zip | |
More nng_err -- this time for dialer and listener allocations.
Diffstat (limited to 'src/platform/posix')
| -rw-r--r-- | src/platform/posix/posix_ipcdial.c | 2 | ||||
| -rw-r--r-- | src/platform/posix/posix_ipclisten.c | 4 | ||||
| -rw-r--r-- | src/platform/posix/posix_sockfd.c | 4 | ||||
| -rw-r--r-- | src/platform/posix/posix_tcplisten.c | 10 |
4 files changed, 10 insertions, 10 deletions
diff --git a/src/platform/posix/posix_ipcdial.c b/src/platform/posix/posix_ipcdial.c index d299f947..f9e87b72 100644 --- a/src/platform/posix/posix_ipcdial.c +++ b/src/platform/posix/posix_ipcdial.c @@ -304,7 +304,7 @@ ipc_dialer_set( return (nni_setopt(ipc_dialer_options, nm, d, buf, sz, t)); } -int +nng_err nni_ipc_dialer_alloc(nng_stream_dialer **dp, const nng_url *url) { ipc_dialer *d; diff --git a/src/platform/posix/posix_ipclisten.c b/src/platform/posix/posix_ipclisten.c index 98432f71..ea540918 100644 --- a/src/platform/posix/posix_ipclisten.c +++ b/src/platform/posix/posix_ipclisten.c @@ -505,7 +505,7 @@ ipc_listener_accept(void *arg, nni_aio *aio) nni_mtx_unlock(&l->mtx); } -int +nng_err nni_ipc_listener_alloc(nng_stream_listener **lp, const nng_url *url) { ipc_listener *l; @@ -560,5 +560,5 @@ nni_ipc_listener_alloc(nng_stream_listener **lp, const nng_url *url) l->sl.sl_set = ipc_listener_set; *lp = (void *) l; - return (0); + return (NNG_OK); } diff --git a/src/platform/posix/posix_sockfd.c b/src/platform/posix/posix_sockfd.c index bc411252..a76ef85f 100644 --- a/src/platform/posix/posix_sockfd.c +++ b/src/platform/posix/posix_sockfd.c @@ -448,7 +448,7 @@ sfd_set(void *arg, const char *name, const void *buf, size_t sz, nni_type t) return (nni_setopt(sfd_options, name, c, buf, sz, t)); } -int +nng_err nni_sfd_conn_alloc(nni_sfd_conn **cp, int fd) { nni_sfd_conn *c; @@ -473,7 +473,7 @@ nni_sfd_conn_alloc(nni_sfd_conn **cp, int fd) c->stream.s_set = sfd_set; *cp = c; - return (0); + return (NNG_OK); } void diff --git a/src/platform/posix/posix_tcplisten.c b/src/platform/posix/posix_tcplisten.c index 13ecb33e..73374dc5 100644 --- a/src/platform/posix/posix_tcplisten.c +++ b/src/platform/posix/posix_tcplisten.c @@ -506,7 +506,7 @@ tcp_listener_set( return (nni_setopt(tcp_listener_options, name, arg, buf, sz, t)); } -static int +static nng_err tcp_listener_alloc_addr(nng_stream_listener **lp, const nng_sockaddr *sa) { tcp_listener *l; @@ -532,16 +532,16 @@ tcp_listener_alloc_addr(nng_stream_listener **lp, const nng_sockaddr *sa) l->ops.sl_set = tcp_listener_set; *lp = (void *) l; - return (0); + return (NNG_OK); } -int +nng_err nni_tcp_listener_alloc(nng_stream_listener **lp, const nng_url *url) { - int rv; + nng_err rv; nng_sockaddr sa; - if ((rv = nni_url_to_address(&sa, url)) != 0) { + if ((rv = nni_url_to_address(&sa, url)) != NNG_OK) { return (rv); } |
