diff options
| author | Garrett D'Amore <garrett@damore.org> | 2016-12-29 23:49:05 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2016-12-29 23:49:05 -0800 |
| commit | 0f5ed9c09bcbe0c0dabdf48ea14e85d418b3d8b6 (patch) | |
| tree | b2ea7f56ae0dc6d32219e695725f55d78b9e0b34 /src/core/endpt.c | |
| parent | 5d90b485fdb39cac7d1aac2ab8958ecd585ac69b (diff) | |
| download | nng-0f5ed9c09bcbe0c0dabdf48ea14e85d418b3d8b6.tar.gz nng-0f5ed9c09bcbe0c0dabdf48ea14e85d418b3d8b6.tar.bz2 nng-0f5ed9c09bcbe0c0dabdf48ea14e85d418b3d8b6.zip | |
Factor out repeated protocol code into common.
Diffstat (limited to 'src/core/endpt.c')
| -rw-r--r-- | src/core/endpt.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/core/endpt.c b/src/core/endpt.c index bb3ba268..901831ef 100644 --- a/src/core/endpt.c +++ b/src/core/endpt.c @@ -130,12 +130,11 @@ nni_endpt_connect(nni_endpt *ep, nni_pipe **pp) static int nni_dial_once(nni_endpt *ep) { - nni_socket *sock = ep->ep_sock; nni_pipe *pipe; int rv; if (((rv = nni_endpt_connect(ep, &pipe)) == 0) && - ((rv = nni_socket_add_pipe(sock, pipe)) == 0)) { + ((rv = nni_pipe_start(pipe)) == 0)) { return (0); } @@ -281,7 +280,6 @@ static void nni_listener(void *arg) { nni_endpt *ep = arg; - nni_socket *sock = ep->ep_sock; nni_pipe *pipe; int rv; @@ -332,7 +330,7 @@ nni_listener(void *arg) pipe = NULL; if (((rv = nni_endpt_accept(ep, &pipe)) == 0) && - ((rv = nni_socket_add_pipe(sock, pipe)) == 0)) { + ((rv = nni_pipe_start(pipe)) == 0)) { continue; } if (rv == NNG_ECLOSED) { |