Remove the extra _aio_ part of pipe send and recv functions.

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);
 }