aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/core/pipe.c4
-rw-r--r--src/core/pipe.h4
-rw-r--r--src/protocol/bus/bus.c4
-rw-r--r--src/protocol/pair/pair.c6
-rw-r--r--src/protocol/pipeline/pull.c4
-rw-r--r--src/protocol/pipeline/push.c6
-rw-r--r--src/protocol/pubsub/pub.c6
-rw-r--r--src/protocol/pubsub/sub.c4
-rw-r--r--src/protocol/reqrep/rep.c6
-rw-r--r--src/protocol/reqrep/req.c8
-rw-r--r--src/protocol/survey/respond.c6
-rw-r--r--src/protocol/survey/survey.c6
12 files changed, 32 insertions, 32 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index ff686d65..32ad2370 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -90,14 +90,14 @@ nni_pipe_id(nni_pipe *p)
void
-nni_pipe_aio_recv(nni_pipe *p, nni_aio *aio)
+nni_pipe_recv(nni_pipe *p, nni_aio *aio)
{
p->p_tran_ops.p_aio_recv(p->p_tran_data, aio);
}
void
-nni_pipe_aio_send(nni_pipe *p, nni_aio *aio)
+nni_pipe_send(nni_pipe *p, nni_aio *aio)
{
p->p_tran_ops.p_aio_send(p->p_tran_data, aio);
}
diff --git a/src/core/pipe.h b/src/core/pipe.h
index 7e1f8e5a..e8e6ecad 100644
--- a/src/core/pipe.h
+++ b/src/core/pipe.h
@@ -38,8 +38,8 @@ extern int nni_pipe_sys_init(void);
extern void nni_pipe_sys_fini(void);
// AIO
-extern void nni_pipe_aio_recv(nni_pipe *, nni_aio *);
-extern void nni_pipe_aio_send(nni_pipe *, nni_aio *);
+extern void nni_pipe_recv(nni_pipe *, nni_aio *);
+extern void nni_pipe_send(nni_pipe *, nni_aio *);
// Pipe operations that protocols use.
extern uint32_t nni_pipe_id(nni_pipe *);
diff --git a/src/protocol/bus/bus.c b/src/protocol/bus/bus.c
index 1c32fec6..5755d5a9 100644
--- a/src/protocol/bus/bus.c
+++ b/src/protocol/bus/bus.c
@@ -215,7 +215,7 @@ nni_bus_pipe_getq_cb(void *arg)
ppipe->aio_send.a_msg = ppipe->aio_getq.a_msg;
ppipe->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(ppipe->npipe, &ppipe->aio_send);
+ nni_pipe_send(ppipe->npipe, &ppipe->aio_send);
}
@@ -351,7 +351,7 @@ nni_bus_pipe_getq(nni_bus_pipe *ppipe)
static void
nni_bus_pipe_recv(nni_bus_pipe *ppipe)
{
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
}
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c
index 67119f80..326e0c0e 100644
--- a/src/protocol/pair/pair.c
+++ b/src/protocol/pair/pair.c
@@ -150,7 +150,7 @@ nni_pair_pipe_start(void *arg)
// Schedule a getq on the upper, and a read from the pipe.
// Each of these also sets up another hold on the pipe itself.
nni_msgq_aio_get(psock->uwq, &ppipe->aio_getq);
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
return (0);
}
@@ -203,7 +203,7 @@ nni_pair_putq_cb(void *arg)
nni_pipe_stop(ppipe->npipe);
return;
}
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
}
@@ -221,7 +221,7 @@ nni_pair_getq_cb(void *arg)
ppipe->aio_send.a_msg = ppipe->aio_getq.a_msg;
ppipe->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(ppipe->npipe, &ppipe->aio_send);
+ nni_pipe_send(ppipe->npipe, &ppipe->aio_send);
}
diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index 728682dd..fd3d1e29 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -106,7 +106,7 @@ nni_pull_pipe_start(void *arg)
nni_pull_pipe *pp = arg;
// Start the pending pull...
- nni_pipe_aio_recv(pp->pipe, &pp->recv_aio);
+ nni_pipe_recv(pp->pipe, &pp->recv_aio);
return (0);
}
@@ -158,7 +158,7 @@ nni_pull_putq_cb(void *arg)
return;
}
- nni_pipe_aio_recv(pp->pipe, &pp->recv_aio);
+ nni_pipe_recv(pp->pipe, &pp->recv_aio);
}
diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c
index 7d3be42e..e39adb7a 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -125,7 +125,7 @@ nni_push_pipe_start(void *arg)
// Schedule a receiver. This is mostly so that we can detect
// a closed transport pipe.
- nni_pipe_aio_recv(pp->pipe, &pp->aio_recv);
+ nni_pipe_recv(pp->pipe, &pp->aio_recv);
// Schedule a sender.
nni_msgq_aio_get(push->uwq, &pp->aio_getq);
@@ -159,7 +159,7 @@ nni_push_recv_cb(void *arg)
}
nni_msg_free(pp->aio_recv.a_msg);
pp->aio_recv.a_msg = NULL;
- nni_pipe_aio_recv(pp->pipe, &pp->aio_recv);
+ nni_pipe_recv(pp->pipe, &pp->aio_recv);
}
@@ -195,7 +195,7 @@ nni_push_getq_cb(void *arg)
pp->aio_send.a_msg = aio->a_msg;
aio->a_msg = NULL;
- nni_pipe_aio_send(pp->pipe, &pp->aio_send);
+ nni_pipe_send(pp->pipe, &pp->aio_send);
}
diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c
index 2767f6b6..58d80d44 100644
--- a/src/protocol/pubsub/pub.c
+++ b/src/protocol/pubsub/pub.c
@@ -164,7 +164,7 @@ nni_pub_pipe_start(void *arg)
nni_mtx_unlock(&pub->mtx);
// Start the receiver and the queue reader.
- nni_pipe_aio_recv(pp->pipe, &pp->aio_recv);
+ nni_pipe_recv(pp->pipe, &pp->aio_recv);
nni_msgq_aio_get(pp->sendq, &pp->aio_getq);
return (0);
@@ -246,7 +246,7 @@ nni_pub_pipe_recv_cb(void *arg)
nni_msg_free(pp->aio_recv.a_msg);
pp->aio_recv.a_msg = NULL;
- nni_pipe_aio_recv(pp->pipe, &pp->aio_recv);
+ nni_pipe_recv(pp->pipe, &pp->aio_recv);
}
@@ -263,7 +263,7 @@ nni_pub_pipe_getq_cb(void *arg)
pp->aio_send.a_msg = pp->aio_getq.a_msg;
pp->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(pp->pipe, &pp->aio_send);
+ nni_pipe_send(pp->pipe, &pp->aio_send);
}
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index 5733b8f2..9e8fa5a7 100644
--- a/src/protocol/pubsub/sub.c
+++ b/src/protocol/pubsub/sub.c
@@ -117,7 +117,7 @@ nni_sub_pipe_start(void *arg)
{
nni_sub_pipe *sp = arg;
- nni_pipe_aio_recv(sp->pipe, &sp->aio_recv);
+ nni_pipe_recv(sp->pipe, &sp->aio_recv);
return (0);
}
@@ -163,7 +163,7 @@ nni_sub_putq_cb(void *arg)
return;
}
- nni_pipe_aio_recv(sp->pipe, &sp->aio_recv);
+ nni_pipe_recv(sp->pipe, &sp->aio_recv);
}
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 036904b1..7d887b55 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -193,7 +193,7 @@ nni_rep_pipe_start(void *arg)
}
nni_msgq_aio_get(rp->sendq, &rp->aio_getq);
- nni_pipe_aio_recv(rp->pipe, &rp->aio_recv);
+ nni_pipe_recv(rp->pipe, &rp->aio_recv);
return (0);
}
@@ -292,7 +292,7 @@ nni_rep_pipe_getq_cb(void *arg)
rp->aio_send.a_msg = rp->aio_getq.a_msg;
rp->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(rp->pipe, &rp->aio_send);
+ nni_pipe_send(rp->pipe, &rp->aio_send);
}
@@ -389,7 +389,7 @@ nni_rep_pipe_putq_cb(void *arg)
return;
}
- nni_pipe_aio_recv(rp->pipe, &rp->aio_recv);
+ nni_pipe_recv(rp->pipe, &rp->aio_recv);
}
diff --git a/src/protocol/reqrep/req.c b/src/protocol/reqrep/req.c
index c2542e18..b951c9a0 100644
--- a/src/protocol/reqrep/req.c
+++ b/src/protocol/reqrep/req.c
@@ -205,7 +205,7 @@ nni_req_pipe_start(void *arg)
nni_msgq_aio_get(req->uwq, &rp->aio_getq);
- nni_pipe_aio_recv(rp->pipe, &rp->aio_recv);
+ nni_pipe_recv(rp->pipe, &rp->aio_recv);
return (0);
}
@@ -321,7 +321,7 @@ nni_req_getq_cb(void *arg)
rp->aio_getq.a_msg = NULL;
// Send the message, but use the raw mode aio.
- nni_pipe_aio_send(rp->pipe, &rp->aio_sendraw);
+ nni_pipe_send(rp->pipe, &rp->aio_sendraw);
}
@@ -391,7 +391,7 @@ nni_req_putq_cb(void *arg)
}
rp->aio_putq.a_msg = NULL;
- nni_pipe_aio_recv(rp->pipe, &rp->aio_recv);
+ nni_pipe_recv(rp->pipe, &rp->aio_recv);
}
@@ -498,7 +498,7 @@ nni_req_resend(nni_req_sock *req)
// Note that because we were ready rather than busy, we
// should not have any I/O oustanding and hence the aio
// object will be available for our use.
- nni_pipe_aio_send(rp->pipe, &rp->aio_sendcooked);
+ nni_pipe_send(rp->pipe, &rp->aio_sendcooked);
nni_timer_schedule(&req->timer, req->resend);
}
}
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c
index 68e4b00f..840b2582 100644
--- a/src/protocol/survey/respond.c
+++ b/src/protocol/survey/respond.c
@@ -193,7 +193,7 @@ nni_resp_pipe_start(void *arg)
return (rv);
}
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
nni_msgq_aio_get(ppipe->sendq, &ppipe->aio_getq);
return (rv);
@@ -283,7 +283,7 @@ nni_resp_getq_cb(void *arg)
ppipe->aio_send.a_msg = ppipe->aio_getq.a_msg;
ppipe->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(ppipe->npipe, &ppipe->aio_send);
+ nni_pipe_send(ppipe->npipe, &ppipe->aio_send);
}
@@ -379,7 +379,7 @@ nni_resp_putq_cb(void *arg)
nni_pipe_stop(ppipe->npipe);
}
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
}
diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c
index fa89e61a..bfbe5c1a 100644
--- a/src/protocol/survey/survey.c
+++ b/src/protocol/survey/survey.c
@@ -186,7 +186,7 @@ nni_surv_pipe_start(void *arg)
nni_mtx_unlock(&psock->mtx);
nni_msgq_aio_get(ppipe->sendq, &ppipe->aio_getq);
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
return (0);
}
@@ -224,7 +224,7 @@ nni_surv_getq_cb(void *arg)
ppipe->aio_send.a_msg = ppipe->aio_getq.a_msg;
ppipe->aio_getq.a_msg = NULL;
- nni_pipe_aio_send(ppipe->npipe, &ppipe->aio_send);
+ nni_pipe_send(ppipe->npipe, &ppipe->aio_send);
}
@@ -256,7 +256,7 @@ nni_surv_putq_cb(void *arg)
return;
}
- nni_pipe_aio_recv(ppipe->npipe, &ppipe->aio_recv);
+ nni_pipe_recv(ppipe->npipe, &ppipe->aio_recv);
}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 16:05:11 +0000