aboutsummaryrefslogtreecommitdiff
path: root/src/core/pipe.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-03-19 16:24:50 -0700
committerGarrett D'Amore <garrett@damore.org>2017-03-19 16:24:50 -0700
commit6fa1e01e750ea09292b21318c3fba33df40eaac0 (patch)
treecca31c599168fdffdfb148d0abf1148f4ef8964e /src/core/pipe.c
parentb8a133a9d6c5d8439c1f8ed3153d6a750aae3646 (diff)
downloadnng-6fa1e01e750ea09292b21318c3fba33df40eaac0.tar.gz
nng-6fa1e01e750ea09292b21318c3fba33df40eaac0.tar.bz2
nng-6fa1e01e750ea09292b21318c3fba33df40eaac0.zip
More API cleanups to separate interfaces. (nni_pipe_create).
Diffstat (limited to 'src/core/pipe.c')
-rw-r--r--src/core/pipe.c6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index dd3b2984..8eb6c376 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -121,11 +121,9 @@ nni_pipe_peer(nni_pipe *p)
int
-nni_pipe_create(nni_pipe **pp, nni_ep *ep)
+nni_pipe_create(nni_pipe **pp, nni_ep *ep, nni_sock *sock, nni_tran *tran)
{
nni_pipe *p;
- nni_sock *sock = ep->ep_sock;
- const nni_proto_pipe_ops *ops = &sock->s_pipe_ops;
void *pdata;
int rv;
@@ -145,7 +143,7 @@ nni_pipe_create(nni_pipe **pp, nni_ep *ep)
// Make a copy of the transport ops. We can override entry points
// and we avoid an extra dereference on hot code paths.
- p->p_tran_ops = *ep->ep_tran->tran_pipe;
+ p->p_tran_ops = *tran->tran_pipe;
if ((rv = nni_sock_pipe_add(sock, p)) != 0) {
nni_mtx_fini(&p->p_mtx);