diff options
| author | Garrett D'Amore <garrett@damore.org> | 2016-12-14 20:44:51 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2016-12-14 20:44:51 -0800 |
| commit | 9e3f9d4d7a953d41210b9d3757fb003573b90308 (patch) | |
| tree | c2e634c4eab4f836eedfa12e30e2eecd9c1a0009 /src/core/pipe.c | |
| parent | 3583d5e407476b8836228c0abc52c400d74aba61 (diff) | |
| download | nng-9e3f9d4d7a953d41210b9d3757fb003573b90308.tar.gz nng-9e3f9d4d7a953d41210b9d3757fb003573b90308.tar.bz2 nng-9e3f9d4d7a953d41210b9d3757fb003573b90308.zip | |
nni_socket_add_pipe and nni_socket_remove_pipe implementation.
Diffstat (limited to 'src/core/pipe.c')
| -rw-r--r-- | src/core/pipe.c | 17 |
1 files changed, 0 insertions, 17 deletions
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 |