AIO: Use nng_err for cancellation callback instead of int.

This is part of our work to improve type safety/awareness, and also
improve debugger support, for NNG error codes.  There are still quite
a few more but this should help.

17 files changed, 36 insertions, 35 deletions

diff --git a/src/sp/protocol/bus0/bus.c b/src/sp/protocol/bus0/bus.c
index 99c3a9bf..13abfd6b 100644
--- a/src/sp/protocol/bus0/bus.c
+++ b/src/sp/protocol/bus0/bus.c
@@ -318,7 +318,7 @@ bus0_sock_send(void *arg, nni_aio *aio)
 }
 
 static void
-bus0_recv_cancel(nng_aio *aio, void *arg, int rv)
+bus0_recv_cancel(nng_aio *aio, void *arg, nng_err rv)
 {
 	bus0_sock *s = arg;
 	nni_mtx_lock(&s->mtx);
diff --git a/src/sp/protocol/pair0/pair.c b/src/sp/protocol/pair0/pair.c
index e577738b..5dc7f67a 100644
--- a/src/sp/protocol/pair0/pair.c
+++ b/src/sp/protocol/pair0/pair.c
@@ -137,7 +137,7 @@ pair0_pipe_init(void *arg, nni_pipe *pipe, void *pair)
 }
 
 static void
-pair0_cancel(nni_aio *aio, void *arg, int rv)
+pair0_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	pair0_sock *s = arg;
 
diff --git a/src/sp/protocol/pair1/pair.c b/src/sp/protocol/pair1/pair.c
index 65ee66ad..35e87b7b 100644
--- a/src/sp/protocol/pair1/pair.c
+++ b/src/sp/protocol/pair1/pair.c
@@ -248,7 +248,7 @@ pair1_pipe_init(void *arg, nni_pipe *pipe, void *pair)
 }
 
 static void
-pair1_cancel(nni_aio *aio, void *arg, int rv)
+pair1_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	pair1_sock *s = arg;
 
diff --git a/src/sp/protocol/pipeline0/pull.c b/src/sp/protocol/pipeline0/pull.c
index 64438304..d808180a 100644
--- a/src/sp/protocol/pipeline0/pull.c
+++ b/src/sp/protocol/pipeline0/pull.c
@@ -205,7 +205,7 @@ pull0_sock_send(void *arg, nni_aio *aio)
 }
 
 static void
-pull0_cancel(nni_aio *aio, void *arg, int rv)
+pull0_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	pull0_sock *s = arg;
 	nni_mtx_lock(&s->m);
diff --git a/src/sp/protocol/pipeline0/push.c b/src/sp/protocol/pipeline0/push.c
index 4cf14a6e..4260f333 100644
--- a/src/sp/protocol/pipeline0/push.c
+++ b/src/sp/protocol/pipeline0/push.c
@@ -249,7 +249,7 @@ push0_send_cb(void *arg)
 }
 
 static void
-push0_cancel(nni_aio *aio, void *arg, int rv)
+push0_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	push0_sock *s = arg;
 
diff --git a/src/sp/protocol/pubsub0/sub.c b/src/sp/protocol/pubsub0/sub.c
index 97324571..6744e909 100644
--- a/src/sp/protocol/pubsub0/sub.c
+++ b/src/sp/protocol/pubsub0/sub.c
@@ -76,7 +76,7 @@ struct sub0_pipe {
 };
 
 static void
-sub0_ctx_cancel(nng_aio *aio, void *arg, int rv)
+sub0_ctx_cancel(nng_aio *aio, void *arg, nng_err rv)
 {
 	sub0_ctx  *ctx  = arg;
 	sub0_sock *sock = ctx->sock;
diff --git a/src/sp/protocol/reqrep0/rep.c b/src/sp/protocol/reqrep0/rep.c
index 4a30e967..e84440a7 100644
--- a/src/sp/protocol/reqrep0/rep.c
+++ b/src/sp/protocol/reqrep0/rep.c
@@ -111,7 +111,7 @@ rep0_ctx_init(void *carg, void *sarg)
 }
 
 static void
-rep0_ctx_cancel_send(nni_aio *aio, void *arg, int rv)
+rep0_ctx_cancel_send(nni_aio *aio, void *arg, nng_err rv)
 {
 	rep0_ctx  *ctx = arg;
 	rep0_sock *s   = ctx->sock;
@@ -400,7 +400,7 @@ rep0_pipe_send_cb(void *arg)
 }
 
 static void
-rep0_cancel_recv(nni_aio *aio, void *arg, int rv)
+rep0_cancel_recv(nni_aio *aio, void *arg, nng_err rv)
 {
 	rep0_ctx  *ctx = arg;
 	rep0_sock *s   = ctx->sock;
diff --git a/src/sp/protocol/reqrep0/req.c b/src/sp/protocol/reqrep0/req.c
index 6ddf958a..52f97d3a 100644
--- a/src/sp/protocol/reqrep0/req.c
+++ b/src/sp/protocol/reqrep0/req.c
@@ -536,7 +536,8 @@ req0_run_send_queue(req0_sock *s, nni_aio_completions *sent_list)
 		// At this point, we will never give this message back to
 		// the user, so we don't have to worry about making it
 		// unique.  We can freely clone it.
-		// But only do so if we need to hang onto it (for potential retries)
+		// But only do so if we need to hang onto it (for potential
+		// retries)
 		if (ctx->retry > 0) {
 			nni_msg_clone(ctx->req_msg);
 		}
@@ -573,7 +574,7 @@ req0_ctx_reset(req0_ctx *ctx)
 }
 
 static void
-req0_ctx_cancel_recv(nni_aio *aio, void *arg, int rv)
+req0_ctx_cancel_recv(nni_aio *aio, void *arg, nng_err rv)
 {
 	req0_ctx  *ctx = arg;
 	req0_sock *s   = ctx->sock;
@@ -661,7 +662,7 @@ req0_ctx_recv(void *arg, nni_aio *aio)
 }
 
 static void
-req0_ctx_cancel_send(nni_aio *aio, void *arg, int rv)
+req0_ctx_cancel_send(nni_aio *aio, void *arg, nng_err rv)
 {
 	req0_ctx  *ctx = arg;
 	req0_sock *s   = ctx->sock;
diff --git a/src/sp/protocol/survey0/respond.c b/src/sp/protocol/survey0/respond.c
index a7cdf132..ace2962a 100644
--- a/src/sp/protocol/survey0/respond.c
+++ b/src/sp/protocol/survey0/respond.c
@@ -117,7 +117,7 @@ resp0_ctx_init(void *carg, void *sarg)
 }
 
 static void
-resp0_ctx_cancel_send(nni_aio *aio, void *arg, int rv)
+resp0_ctx_cancel_send(nni_aio *aio, void *arg, nng_err rv)
 {
 	resp0_ctx  *ctx = arg;
 	resp0_sock *s   = ctx->sock;
@@ -398,7 +398,7 @@ resp0_pipe_send_cb(void *arg)
 }
 
 static void
-resp0_cancel_recv(nni_aio *aio, void *arg, int rv)
+resp0_cancel_recv(nni_aio *aio, void *arg, nng_err rv)
 {
 	resp0_ctx  *ctx = arg;
 	resp0_sock *s   = ctx->sock;
diff --git a/src/sp/protocol/survey0/survey.c b/src/sp/protocol/survey0/survey.c
index 6cf73e66..c64f0bb0 100644
--- a/src/sp/protocol/survey0/survey.c
+++ b/src/sp/protocol/survey0/survey.c
@@ -133,7 +133,7 @@ surv0_ctx_init(void *c, void *s)
 }
 
 static void
-surv0_ctx_cancel(nni_aio *aio, void *arg, int rv)
+surv0_ctx_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	surv0_ctx  *ctx  = arg;
 	surv0_sock *sock = ctx->sock;
diff --git a/src/sp/transport/inproc/inproc.c b/src/sp/transport/inproc/inproc.c
index 672c4d33..1c7b88e6 100644
--- a/src/sp/transport/inproc/inproc.c
+++ b/src/sp/transport/inproc/inproc.c
@@ -176,7 +176,7 @@ inproc_queue_run(inproc_queue *queue)
 }
 
 static void
-inproc_queue_cancel(nni_aio *aio, void *arg, int rv)
+inproc_queue_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	inproc_queue *queue = arg;
 
@@ -433,7 +433,7 @@ inproc_accept_clients(inproc_ep *srv)
 }
 
 static void
-inproc_ep_cancel(nni_aio *aio, void *arg, int rv)
+inproc_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	inproc_ep *ep = arg;
 
diff --git a/src/sp/transport/ipc/ipc.c b/src/sp/transport/ipc/ipc.c
index 5fea1632..82ec3f7e 100644
--- a/src/sp/transport/ipc/ipc.c
+++ b/src/sp/transport/ipc/ipc.c
@@ -413,7 +413,7 @@ error:
 }
 
 static void
-ipc_pipe_send_cancel(nni_aio *aio, void *arg, int rv)
+ipc_pipe_send_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ipc_pipe *p = arg;
 
@@ -500,7 +500,7 @@ ipc_pipe_send(void *arg, nni_aio *aio)
 }
 
 static void
-ipc_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+ipc_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ipc_pipe *p = arg;
 
@@ -835,7 +835,7 @@ ipc_ep_init_listener(void *arg, nng_url *url, nni_listener *listener)
 }
 
 static void
-ipc_ep_cancel(nni_aio *aio, void *arg, int rv)
+ipc_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ipc_ep *ep = arg;
 	nni_mtx_lock(&ep->mtx);
diff --git a/src/sp/transport/socket/sockfd.c b/src/sp/transport/socket/sockfd.c
index 9eea18f6..5138afaa 100644
--- a/src/sp/transport/socket/sockfd.c
+++ b/src/sp/transport/socket/sockfd.c
@@ -382,7 +382,7 @@ recv_error:
 }
 
 static void
-sfd_tran_pipe_send_cancel(nni_aio *aio, void *arg, int rv)
+sfd_tran_pipe_send_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	sfd_tran_pipe *p = arg;
 
@@ -470,7 +470,7 @@ sfd_tran_pipe_send(void *arg, nni_aio *aio)
 }
 
 static void
-sfd_tran_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+sfd_tran_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	sfd_tran_pipe *p = arg;
 
@@ -728,7 +728,7 @@ sfd_tran_listener_init(void *arg, nng_url *url, nni_listener *nlistener)
 }
 
 static void
-sfd_tran_ep_cancel(nni_aio *aio, void *arg, int rv)
+sfd_tran_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	sfd_tran_ep *ep = arg;
 	nni_mtx_lock(&ep->mtx);
diff --git a/src/sp/transport/tcp/tcp.c b/src/sp/transport/tcp/tcp.c
index c59ec5aa..3bc124ee 100644
--- a/src/sp/transport/tcp/tcp.c
+++ b/src/sp/transport/tcp/tcp.c
@@ -1,5 +1,5 @@
 //
-// Copyright 2024 Staysail Systems, Inc. <info@staysail.tech>
+// Copyright 2025 Staysail Systems, Inc. <info@staysail.tech>
 // Copyright 2018 Capitar IT Group BV <info@capitar.com>
 // Copyright 2019 Devolutions <info@devolutions.net>
 //
@@ -402,7 +402,7 @@ recv_error:
 }
 
 static void
-tcptran_pipe_send_cancel(nni_aio *aio, void *arg, int rv)
+tcptran_pipe_send_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tcptran_pipe *p = arg;
 
@@ -491,7 +491,7 @@ tcptran_pipe_send(void *arg, nni_aio *aio)
 }
 
 static void
-tcptran_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+tcptran_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tcptran_pipe *p = arg;
 
@@ -846,7 +846,7 @@ tcptran_listener_init(void *arg, nng_url *url, nni_listener *nlistener)
 }
 
 static void
-tcptran_ep_cancel(nni_aio *aio, void *arg, int rv)
+tcptran_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tcptran_ep *ep = arg;
 	nni_mtx_lock(&ep->mtx);
diff --git a/src/sp/transport/tls/tls.c b/src/sp/transport/tls/tls.c
index ed4fad05..643146f7 100644
--- a/src/sp/transport/tls/tls.c
+++ b/src/sp/transport/tls/tls.c
@@ -395,7 +395,7 @@ recv_error:
 }
 
 static void
-tlstran_pipe_send_cancel(nni_aio *aio, void *arg, int rv)
+tlstran_pipe_send_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tlstran_pipe *p = arg;
 
@@ -476,7 +476,7 @@ tlstran_pipe_send(void *arg, nni_aio *aio)
 }
 
 static void
-tlstran_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+tlstran_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tlstran_pipe *p = arg;
 
@@ -815,7 +815,7 @@ tlstran_ep_init_listener(void *arg, nng_url *url, nni_listener *nlistener)
 }
 
 static void
-tlstran_ep_cancel(nni_aio *aio, void *arg, int rv)
+tlstran_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	tlstran_ep *ep = arg;
 	nni_mtx_lock(&ep->mtx);
diff --git a/src/sp/transport/udp/udp.c b/src/sp/transport/udp/udp.c
index b068be03..2e85fd0f 100644
--- a/src/sp/transport/udp/udp.c
+++ b/src/sp/transport/udp/udp.c
@@ -999,7 +999,7 @@ udp_pipe_send(void *arg, nni_aio *aio)
 }
 
 static void
-udp_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+udp_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	udp_pipe *p  = arg;
 	udp_ep   *ep = p->ep;
@@ -1430,7 +1430,7 @@ udp_listener_init(void *arg, nng_url *url, nni_listener *nlistener)
 }
 
 static void
-udp_ep_cancel(nni_aio *aio, void *arg, int rv)
+udp_ep_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	udp_ep *ep = arg;
 	nni_mtx_lock(&ep->mtx);
diff --git a/src/sp/transport/ws/websocket.c b/src/sp/transport/ws/websocket.c
index 23256edc..f93b1f49 100644
--- a/src/sp/transport/ws/websocket.c
+++ b/src/sp/transport/ws/websocket.c
@@ -106,7 +106,7 @@ wstran_pipe_recv_cb(void *arg)
 }
 
 static void
-wstran_pipe_recv_cancel(nni_aio *aio, void *arg, int rv)
+wstran_pipe_recv_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ws_pipe *p = arg;
 	nni_mtx_lock(&p->mtx);
@@ -137,7 +137,7 @@ wstran_pipe_recv(void *arg, nni_aio *aio)
 }
 
 static void
-wstran_pipe_send_cancel(nni_aio *aio, void *arg, int rv)
+wstran_pipe_send_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ws_pipe *p = arg;
 	nni_mtx_lock(&p->mtx);
@@ -241,7 +241,7 @@ wstran_listener_bind(void *arg, nng_url *url)
 }
 
 static void
-wstran_listener_cancel(nni_aio *aio, void *arg, int rv)
+wstran_listener_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ws_listener *l = arg;
 
@@ -277,7 +277,7 @@ wstran_listener_accept(void *arg, nni_aio *aio)
 }
 
 static void
-wstran_dialer_cancel(nni_aio *aio, void *arg, int rv)
+wstran_dialer_cancel(nni_aio *aio, void *arg, nng_err rv)
 {
 	ws_dialer *d = arg;