More interface hiding. (pipe tran data setting).

3 files changed, 12 insertions, 12 deletions

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);
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c
index 4673a6dc..11965d17 100644
--- a/src/transport/ipc/ipc.c
+++ b/src/transport/ipc/ipc.c
@@ -260,7 +260,7 @@ nni_ipc_negotiate(nni_ipc_pipe *pipe)
 
 
 static int
-nni_ipc_ep_connect(void *arg, void **pipep)
+nni_ipc_ep_connect(void *arg, nni_pipe *npipe)
 {
 	nni_ipc_ep *ep = arg;
 	nni_ipc_pipe *pipe;
@@ -295,7 +295,7 @@ nni_ipc_ep_connect(void *arg, void **pipep)
 		NNI_FREE_STRUCT(pipe);
 		return (rv);
 	}
-	*pipep = pipe;
+	nni_pipe_set_tran_data(npipe, pipe);
 	return (0);
 }
 
@@ -321,7 +321,7 @@ nni_ipc_ep_bind(void *arg)
 
 
 static int
-nni_ipc_ep_accept(void *arg, void **pipep)
+nni_ipc_ep_accept(void *arg, nni_pipe *npipe)
 {
 	nni_ipc_ep *ep = arg;
 	nni_ipc_pipe *pipe;
@@ -349,7 +349,7 @@ nni_ipc_ep_accept(void *arg, void **pipep)
 		NNI_FREE_STRUCT(pipe);
 		return (rv);
 	}
-	*pipep = pipe;
+	nni_pipe_set_tran_data(npipe, pipe);
 	return (0);
 }
 
diff --git a/src/transport/tcp/tcp.c b/src/transport/tcp/tcp.c
index ad2d398a..e198a927 100644
--- a/src/transport/tcp/tcp.c
+++ b/src/transport/tcp/tcp.c
@@ -303,7 +303,7 @@ nni_tcp_negotiate(nni_tcp_pipe *pipe)
 
 
 static int
-nni_tcp_ep_connect(void *arg, void **pipep)
+nni_tcp_ep_connect(void *arg, nni_pipe *npipe)
 {
 	nni_tcp_ep *ep = arg;
 	nni_tcp_pipe *pipe;
@@ -377,7 +377,7 @@ nni_tcp_ep_connect(void *arg, void **pipep)
 		NNI_FREE_STRUCT(pipe);
 		return (rv);
 	}
-	*pipep = pipe;
+	nni_pipe_set_tran_data(npipe, pipe);
 	return (0);
 }
 
@@ -414,7 +414,7 @@ nni_tcp_ep_bind(void *arg)
 
 
 static int
-nni_tcp_ep_accept(void *arg, void **pipep)
+nni_tcp_ep_accept(void *arg, nni_pipe *npipe)
 {
 	nni_tcp_ep *ep = arg;
 	nni_tcp_pipe *pipe;
@@ -442,7 +442,7 @@ nni_tcp_ep_accept(void *arg, void **pipep)
 		NNI_FREE_STRUCT(pipe);
 		return (rv);
 	}
-	*pipep = pipe;
+	nni_pipe_set_tran_data(npipe, pipe);
 	return (0);
 }