aboutsummaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
Diffstat (limited to 'src/core')
-rw-r--r--src/core/pipe.c28
-rw-r--r--src/core/pipe.h11
-rw-r--r--src/core/platform.h4
3 files changed, 1 insertions, 42 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index 4b37cfa9..bc77cd2d 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -23,20 +23,6 @@ nni_pipe_id(nni_pipe *p)
int
-nni_pipe_send(nni_pipe *p, nng_msg *msg)
-{
- return (p->p_tran_ops.pipe_send(p->p_tran_data, msg));
-}
-
-
-int
-nni_pipe_recv(nni_pipe *p, nng_msg **msgp)
-{
- return (p->p_tran_ops.pipe_recv(p->p_tran_data, msgp));
-}
-
-
-int
nni_pipe_aio_recv(nni_pipe *p, nni_aio *aio)
{
return (p->p_tran_ops.p_aio_recv(p->p_tran_data, aio));
@@ -233,20 +219,6 @@ nni_pipe_get_proto_data(nni_pipe *p)
void
-nni_pipe_set_tran_data(nni_pipe *p, void *data)
-{
- p->p_tran_data = data;
-}
-
-
-void *
-nni_pipe_get_tran_data(nni_pipe *p)
-{
- return (p->p_tran_data);
-}
-
-
-void
nni_pipe_sock_list_init(nni_list *list)
{
NNI_LIST_INIT(list, nni_pipe, p_sock_node);
diff --git a/src/core/pipe.h b/src/core/pipe.h
index 71f3821a..912c70bd 100644
--- a/src/core/pipe.h
+++ b/src/core/pipe.h
@@ -37,8 +37,6 @@ extern int nni_pipe_aio_recv(nni_pipe *, nni_aio *);
extern int nni_pipe_aio_send(nni_pipe *, nni_aio *);
// Pipe operations that protocols use.
-extern int nni_pipe_recv(nni_pipe *, nng_msg **);
-extern int nni_pipe_send(nni_pipe *, nng_msg *);
extern uint32_t nni_pipe_id(nni_pipe *);
extern void nni_pipe_close(nni_pipe *);
extern void nni_pipe_incref(nni_pipe *);
@@ -64,15 +62,6 @@ extern void nni_pipe_set_proto_data(nni_pipe *, void *);
// nni_pipe_set_proto_data function. No locking is performed.
extern void *nni_pipe_get_proto_data(nni_pipe *);
-// nni_pipe_set_tran_data sets the transport private data. No locking is
-// performed, and this routine should only be called once per pipe at
-// initialization.
-extern void nni_pipe_set_tran_data(nni_pipe *, void *);
-
-// nni_pipe_get_tran_data gets the transport private data set with the
-// nni_pipe_set_tran_data function. No locking is performed.
-extern void *nni_pipe_get_tran_data(nni_pipe *);
-
// nni_pipe_sock_list_init initializes a list of pipes, to be used by
// a per-socket list.
extern void nni_pipe_sock_list_init(nni_list *);
diff --git a/src/core/platform.h b/src/core/platform.h
index 1644973c..e6eac8e3 100644
--- a/src/core/platform.h
+++ b/src/core/platform.h
@@ -208,13 +208,11 @@ extern int nni_plat_tcp_connect(nni_plat_tcpsock *, const nni_sockaddr *,
// of iovs will never be larger than 4. The platform may modify the iovs,
// or the iov list.
extern int nni_plat_tcp_aio_send(nni_plat_tcpsock *, nni_aio *);
-extern int nni_plat_tcp_send(nni_plat_tcpsock *, nni_iov *, int);
-// nni_plat_tcp_recv recvs data into the buffers provided by the
+// nni_plat_tcp_aio_recv recvs data into the buffers provided by the
// iovs. The implementation does not return until the iovs are completely
// full, or an error condition occurs.
extern int nni_plat_tcp_aio_recv(nni_plat_tcpsock *, nni_aio *);
-extern int nni_plat_tcp_recv(nni_plat_tcpsock *, nni_iov *, int);
// nni_plat_ipc_init initializes the socket, for example it can
// set underlying file descriptors to -1, etc.