aboutsummaryrefslogtreecommitdiff
path: root/src/sp
diff options
context:
space:
mode:
Diffstat (limited to 'src/sp')
-rw-r--r--src/sp/protocol/bus0/bus.c2
-rw-r--r--src/sp/protocol/pair0/pair.c2
-rw-r--r--src/sp/protocol/pair1/pair.c2
-rw-r--r--src/sp/protocol/pipeline0/pull.c2
-rw-r--r--src/sp/protocol/pipeline0/push.c2
-rw-r--r--src/sp/protocol/pubsub0/sub.c2
-rw-r--r--src/sp/protocol/reqrep0/rep.c4
-rw-r--r--src/sp/protocol/reqrep0/req.c7
-rw-r--r--src/sp/protocol/survey0/respond.c4
-rw-r--r--src/sp/protocol/survey0/survey.c2
-rw-r--r--src/sp/transport/inproc/inproc.c4
-rw-r--r--src/sp/transport/ipc/ipc.c6
-rw-r--r--src/sp/transport/socket/sockfd.c6
-rw-r--r--src/sp/transport/tcp/tcp.c8
-rw-r--r--src/sp/transport/tls/tls.c6
-rw-r--r--src/sp/transport/udp/udp.c4
-rw-r--r--src/sp/transport/ws/websocket.c8
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;
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 15:50:23 +0000