diff options
| author | Garrett D'Amore <garrett@damore.org> | 2016-12-22 20:52:45 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2016-12-22 20:52:45 -0800 |
| commit | ee45cbf4498a3c1d1868469bdb0c767d66c278e4 (patch) | |
| tree | b9116256f12a54c90f92bf5cf215f3d4c8152126 /src/protocol/pair | |
| parent | 718de1828cc5b5256511c5b723360d499ae21c8f (diff) | |
| download | nng-ee45cbf4498a3c1d1868469bdb0c767d66c278e4.tar.gz nng-ee45cbf4498a3c1d1868469bdb0c767d66c278e4.tar.bz2 nng-ee45cbf4498a3c1d1868469bdb0c767d66c278e4.zip | |
Endpoint dialer implemented.
Diffstat (limited to 'src/protocol/pair')
| -rw-r--r-- | src/protocol/pair/pair.c | 24 |
1 files changed, 0 insertions, 24 deletions
diff --git a/src/protocol/pair/pair.c b/src/protocol/pair/pair.c index cabd3f06..692f4b0e 100644 --- a/src/protocol/pair/pair.c +++ b/src/protocol/pair/pair.c @@ -76,29 +76,6 @@ nni_pair_destroy(void *arg) } -static void -nni_pair_shutdown(void *arg) -{ - nni_pair_sock *pair = arg; - nni_pipe_t pipe; - - // This just causes the protocol to close its various pipes. - // The draining logic, if any, will have been performed in the - // upper layer socket. - // - // Closing the pipes is intended to cause the receiver on them - // to notice the failure, and ultimately call back into the socket - // to unregister them. The socket can use this to wait for a clean - // shutdown of all pipe workers. - nni_mutex_enter(&pair->mx); - pipe = pair->pipe; - pair->pipe = NULL; - nni_mutex_exit(&pair->mx); - - nni_pipe_close(pipe); -} - - static int nni_pair_add_pipe(void *arg, nni_pipe *pipe) { @@ -252,7 +229,6 @@ struct nni_protocol nni_pair_protocol = { .proto_name = "pair", .proto_create = nni_pair_create, .proto_destroy = nni_pair_destroy, - .proto_shutdown = nni_pair_shutdown, .proto_add_pipe = nni_pair_add_pipe, .proto_rem_pipe = nni_pair_rem_pipe, .proto_setopt = nni_pair_setopt, |