From 6091cf7e1c030417e1fd29c66160e71bcbe4f984 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Sun, 19 Mar 2017 22:08:17 -0700 Subject: More interface hiding. (pipe tran data setting). --- src/transport/inproc/inproc.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/transport/inproc') diff --git a/src/transport/inproc/inproc.c b/src/transport/inproc/inproc.c index 4e329d10..de9b5e91 100644 --- a/src/transport/inproc/inproc.c +++ b/src/transport/inproc/inproc.c @@ -262,7 +262,7 @@ nni_inproc_ep_close(void *arg) static int -nni_inproc_ep_connect(void *arg, void **pipep) +nni_inproc_ep_connect(void *arg, nni_pipe *npipe) { nni_inproc_ep *ep = arg; @@ -303,7 +303,7 @@ nni_inproc_ep_connect(void *arg, void **pipep) nni_list_remove(&server->clients, ep); } } - *pipep = ep->cpipe; + nni_pipe_set_tran_data(npipe, ep->cpipe); ep->cpipe = NULL; nni_mtx_unlock(&nni_inproc.mx); return (0); @@ -342,7 +342,7 @@ nni_inproc_ep_bind(void *arg) static int -nni_inproc_ep_accept(void *arg, void **pipep) +nni_inproc_ep_accept(void *arg, nni_pipe *npipe) { nni_inproc_ep *ep = arg; nni_inproc_ep *client; @@ -393,7 +393,7 @@ nni_inproc_ep_accept(void *arg, void **pipep) pair->pipe[0].peer = ep->proto; pair->refcnt = 2; client->cpipe = &pair->pipe[0]; - *pipep = &pair->pipe[1]; + nni_pipe_set_tran_data(npipe, &pair->pipe[1]); nni_cv_wake(&client->cv); nni_mtx_unlock(&nni_inproc.mx); -- cgit v1.2.3-70-g09d2