Transport listen: use nng_err

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