Transport listen: use nng_err

2 files changed, 7 insertions, 7 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