From 9e3f9d4d7a953d41210b9d3757fb003573b90308 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Wed, 14 Dec 2016 20:44:51 -0800 Subject: nni_socket_add_pipe and nni_socket_remove_pipe implementation. --- src/core/pipe.c | 17 ----------------- 1 file changed, 17 deletions(-) (limited to 'src/core/pipe.c') diff --git a/src/core/pipe.c b/src/core/pipe.c index a08aab8a..1895b74b 100644 --- a/src/core/pipe.c +++ b/src/core/pipe.c @@ -29,14 +29,6 @@ * performed in the context of the protocol. */ -struct nng_pipe { - uint32_t p_id; - struct nni_pipe_ops p_ops; - void *p_tran; - nni_list_node_t p_node; - nni_socket_t p_sock; -}; - /* nni_pipe_id returns the 32-bit pipe id, which can be used in backtraces. */ uint32_t nni_pipe_id(nni_pipe_t p) @@ -64,10 +56,7 @@ nni_pipe_recv(nni_pipe_t p, nng_msg_t *msgp) void nni_pipe_close(nni_pipe_t p) { - /* XXX: we need to unregister from the parent socket. */ - /* XXX: also unregister from the protocol. */ p->p_ops.p_close(p->p_tran); - // XXX: nni_sock_remove_pipe(sock, p); } uint16_t @@ -82,9 +71,3 @@ nni_pipe_destroy(nni_pipe_t p) p->p_ops.p_destroy(p->p_tran); nni_free(p, sizeof (*p)); } - -void -nni_pipe_list_init(nni_list_t *list) -{ - NNI_LIST_INIT(list, struct nng_pipe, p_node); -} \ No newline at end of file -- cgit v1.2.3-70-g09d2