aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-02 16:02:37 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-02 16:02:37 -0700
commitac1cdf1a4a2bff6d2ad469735d6825881f5045d9 (patch)
treef7da80b51ad15a33786dbf85d6733b7a300956d6
parent9f5fa865f252f6d71f2d92181b17c038e2c28a8a (diff)
downloadnng-ac1cdf1a4a2bff6d2ad469735d6825881f5045d9.tar.gz
nng-ac1cdf1a4a2bff6d2ad469735d6825881f5045d9.tar.bz2
nng-ac1cdf1a4a2bff6d2ad469735d6825881f5045d9.zip
More aio name cleanups.
-rw-r--r--src/core/pipe.c4
-rw-r--r--src/core/transport.h4
-rw-r--r--src/transport/inproc/inproc.c8
-rw-r--r--src/transport/ipc/ipc.c8
-rw-r--r--src/transport/tcp/tcp.c8
5 files changed, 16 insertions, 16 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index 32ad2370..7f568457 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -92,14 +92,14 @@ nni_pipe_id(nni_pipe *p)
void
nni_pipe_recv(nni_pipe *p, nni_aio *aio)
{
- p->p_tran_ops.p_aio_recv(p->p_tran_data, aio);
+ p->p_tran_ops.p_recv(p->p_tran_data, aio);
}
void
nni_pipe_send(nni_pipe *p, nni_aio *aio)
{
- p->p_tran_ops.p_aio_send(p->p_tran_data, aio);
+ p->p_tran_ops.p_send(p->p_tran_data, aio);
}
diff --git a/src/core/transport.h b/src/core/transport.h
index 0ec7310a..383526cb 100644
--- a/src/core/transport.h
+++ b/src/core/transport.h
@@ -93,12 +93,12 @@ struct nni_tran_pipe {
// message, and the caller may not use it again. The transport will
// have the responsibility to free the message (nng_msg_free()) when
// it is finished with it.
- int (*p_aio_send)(void *, nni_aio *);
+ int (*p_send)(void *, nni_aio *);
// p_recv schedules a message receive. This will be performed even for
// cases where no data is expected, to allow detection of a remote
// disconnect.
- int (*p_aio_recv)(void *, nni_aio *);
+ int (*p_recv)(void *, nni_aio *);
// p_close closes the pipe. Further recv or send operations should
// return back NNG_ECLOSED.
diff --git a/src/transport/inproc/inproc.c b/src/transport/inproc/inproc.c
index 0ff87548..dc0baef0 100644
--- a/src/transport/inproc/inproc.c
+++ b/src/transport/inproc/inproc.c
@@ -153,7 +153,7 @@ nni_inproc_pipe_fini(void *arg)
static int
-nni_inproc_pipe_aio_send(void *arg, nni_aio *aio)
+nni_inproc_pipe_send(void *arg, nni_aio *aio)
{
nni_inproc_pipe *pipe = arg;
nni_msg *msg = aio->a_msg;
@@ -175,7 +175,7 @@ nni_inproc_pipe_aio_send(void *arg, nni_aio *aio)
static int
-nni_inproc_pipe_aio_recv(void *arg, nni_aio *aio)
+nni_inproc_pipe_recv(void *arg, nni_aio *aio)
{
nni_inproc_pipe *pipe = arg;
@@ -447,8 +447,8 @@ nni_inproc_ep_accept(void *arg, void **pipep)
static nni_tran_pipe nni_inproc_pipe_ops = {
.p_fini = nni_inproc_pipe_fini,
- .p_aio_send = nni_inproc_pipe_aio_send,
- .p_aio_recv = nni_inproc_pipe_aio_recv,
+ .p_send = nni_inproc_pipe_send,
+ .p_recv = nni_inproc_pipe_recv,
.p_close = nni_inproc_pipe_close,
.p_peer = nni_inproc_pipe_peer,
.p_getopt = nni_inproc_pipe_getopt,
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c
index 8cb24b28..760be794 100644
--- a/src/transport/ipc/ipc.c
+++ b/src/transport/ipc/ipc.c
@@ -252,7 +252,7 @@ nni_ipc_cancel_tx(nni_aio *aio)
static int
-nni_ipc_pipe_aio_send(void *arg, nni_aio *aio)
+nni_ipc_pipe_send(void *arg, nni_aio *aio)
{
nni_ipc_pipe *pipe = arg;
nni_msg *msg = aio->a_msg;
@@ -300,7 +300,7 @@ nni_ipc_cancel_rx(nni_aio *aio)
static int
-nni_ipc_pipe_aio_recv(void *arg, nni_aio *aio)
+nni_ipc_pipe_recv(void *arg, nni_aio *aio)
{
nni_ipc_pipe *pipe = arg;
@@ -525,8 +525,8 @@ nni_ipc_ep_accept(void *arg, void **pipep)
static nni_tran_pipe nni_ipc_pipe_ops = {
.p_fini = nni_ipc_pipe_fini,
- .p_aio_send = nni_ipc_pipe_aio_send,
- .p_aio_recv = nni_ipc_pipe_aio_recv,
+ .p_send = nni_ipc_pipe_send,
+ .p_recv = nni_ipc_pipe_recv,
.p_close = nni_ipc_pipe_close,
.p_peer = nni_ipc_pipe_peer,
.p_getopt = nni_ipc_pipe_getopt,
diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c
index d366a496..92653991 100644
--- a/src/transport/tcp/tcp.c
+++ b/src/transport/tcp/tcp.c
@@ -239,7 +239,7 @@ nni_tcp_cancel_tx(nni_aio *aio)
static int
-nni_tcp_pipe_aio_send(void *arg, nni_aio *aio)
+nni_tcp_pipe_send(void *arg, nni_aio *aio)
{
nni_tcp_pipe *pipe = arg;
nni_msg *msg = aio->a_msg;
@@ -287,7 +287,7 @@ nni_tcp_cancel_rx(nni_aio *aio)
static int
-nni_tcp_pipe_aio_recv(void *arg, nni_aio *aio)
+nni_tcp_pipe_recv(void *arg, nni_aio *aio)
{
nni_tcp_pipe *pipe = arg;
@@ -616,8 +616,8 @@ nni_tcp_ep_accept(void *arg, void **pipep)
static nni_tran_pipe nni_tcp_pipe_ops = {
.p_fini = nni_tcp_pipe_fini,
- .p_aio_send = nni_tcp_pipe_aio_send,
- .p_aio_recv = nni_tcp_pipe_aio_recv,
+ .p_send = nni_tcp_pipe_send,
+ .p_recv = nni_tcp_pipe_recv,
.p_close = nni_tcp_pipe_close,
.p_peer = nni_tcp_pipe_peer,
.p_getopt = nni_tcp_pipe_getopt,