diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/core/pipe.c | 4 | ||||
| -rw-r--r-- | src/core/transport.h | 4 | ||||
| -rw-r--r-- | src/transport/inproc/inproc.c | 8 | ||||
| -rw-r--r-- | src/transport/ipc/ipc.c | 8 | ||||
| -rw-r--r-- | src/transport/tcp/tcp.c | 8 |
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, |