diff options
Diffstat (limited to 'src/platform')
| -rw-r--r-- | src/platform/posix/posix_ipclisten.c | 8 | ||||
| -rw-r--r-- | src/platform/posix/posix_tcplisten.c | 6 | ||||
| -rw-r--r-- | src/platform/windows/win_ipclisten.c | 10 | ||||
| -rw-r--r-- | src/platform/windows/win_tcplisten.c | 6 |
4 files changed, 15 insertions, 15 deletions
diff --git a/src/platform/posix/posix_ipclisten.c b/src/platform/posix/posix_ipclisten.c index ea540918..c651b9ab 100644 --- a/src/platform/posix/posix_ipclisten.c +++ b/src/platform/posix/posix_ipclisten.c @@ -358,13 +358,13 @@ ipc_listener_chmod(ipc_listener *l, const char *path) return (0); } -int +nng_err ipc_listener_listen(void *arg) { ipc_listener *l = arg; socklen_t len; struct sockaddr_storage ss; - int rv; + nng_err rv; int fd; char *path; @@ -420,7 +420,7 @@ ipc_listener_listen(void *arg) (listen(fd, 128) != 0)) { rv = nni_plat_errno(errno); } - if (rv != 0) { + if (rv != NNG_OK) { nni_mtx_unlock(&l->mtx); (void) close(fd); if (path != NULL) { @@ -457,7 +457,7 @@ ipc_listener_listen(void *arg) l->path = path; nni_mtx_unlock(&l->mtx); - return (0); + return (NNG_OK); } static void diff --git a/src/platform/posix/posix_tcplisten.c b/src/platform/posix/posix_tcplisten.c index 73374dc5..29255df2 100644 --- a/src/platform/posix/posix_tcplisten.c +++ b/src/platform/posix/posix_tcplisten.c @@ -176,13 +176,13 @@ tcp_listener_cancel(nni_aio *aio, void *arg, nng_err rv) nni_mtx_unlock(&l->mtx); } -static int +static nng_err tcp_listener_listen(void *arg) { tcp_listener *l = arg; socklen_t len; struct sockaddr_storage ss; - int rv; + nng_err rv; int fd; if (((len = nni_posix_nn2sockaddr(&ss, &l->sa)) == 0) || @@ -244,7 +244,7 @@ tcp_listener_listen(void *arg) l->started = true; nni_mtx_unlock(&l->mtx); - return (0); + return (NNG_OK); } static void diff --git a/src/platform/windows/win_ipclisten.c b/src/platform/windows/win_ipclisten.c index 56ec5cc3..e8670afe 100644 --- a/src/platform/windows/win_ipclisten.c +++ b/src/platform/windows/win_ipclisten.c @@ -191,11 +191,11 @@ ipc_listener_get( return (nni_getopt(ipc_listener_options, name, l, buf, szp, t)); } -static int +static nng_err ipc_listener_listen(void *arg) { ipc_listener *l = arg; - int rv; + nng_err rv; HANDLE f; char *path; @@ -209,7 +209,7 @@ ipc_listener_listen(void *arg) return (NNG_ECLOSED); } rv = nni_asprintf(&path, IPC_PIPE_PREFIX "%s", l->sa.s_ipc.sa_path); - if (rv != 0) { + if (rv != NNG_OK) { nni_mtx_unlock(&l->mtx); return (rv); } @@ -230,7 +230,7 @@ ipc_listener_listen(void *arg) nni_strfree(path); return (rv); } - if ((rv = nni_win_io_register(f)) != 0) { + if ((rv = nni_win_io_register(f)) != NNG_OK) { CloseHandle(f); nni_mtx_unlock(&l->mtx); nni_strfree(path); @@ -241,7 +241,7 @@ ipc_listener_listen(void *arg) l->path = path; l->started = true; nni_mtx_unlock(&l->mtx); - return (0); + return (NNG_OK); } static void diff --git a/src/platform/windows/win_tcplisten.c b/src/platform/windows/win_tcplisten.c index aa4a18e9..b92470ca 100644 --- a/src/platform/windows/win_tcplisten.c +++ b/src/platform/windows/win_tcplisten.c @@ -130,10 +130,10 @@ tcp_listener_free(void *arg) NNI_FREE_STRUCT(l); } -static int +static nng_err tcp_listener_listen(void *arg) { - int rv; + nng_err rv; BOOL yes; DWORD no; int len; @@ -192,7 +192,7 @@ tcp_listener_listen(void *arg) } l->started = true; nni_mtx_unlock(&l->mtx); - return (0); + return (NNG_OK); } static void |