diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-02 14:37:42 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-02 14:37:42 -0800 |
| commit | ec2b1275153487fda661942d9b98aab2567b612e (patch) | |
| tree | 4e1457b1bbf57341ea569013892550a988457e09 /src/protocol/reqrep | |
| parent | b6374f9d9b07c929522066f27ed9a7a05c6bb23b (diff) | |
| download | nng-ec2b1275153487fda661942d9b98aab2567b612e.tar.gz nng-ec2b1275153487fda661942d9b98aab2567b612e.tar.bz2 nng-ec2b1275153487fda661942d9b98aab2567b612e.zip | |
Begin testing REQ/REP.
Diffstat (limited to 'src/protocol/reqrep')
| -rw-r--r-- | src/protocol/reqrep/rep.c | 3 | ||||
| -rw-r--r-- | src/protocol/reqrep/req.c | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c index 8d51ee0a..60346390 100644 --- a/src/protocol/reqrep/rep.c +++ b/src/protocol/reqrep/rep.c @@ -312,6 +312,7 @@ again: } } nni_msgq_signal(uwq, &rp->sigclose); + nni_msgq_signal(rp->sendq, &rp->sigclose); nni_pipe_close(pipe); } @@ -452,7 +453,7 @@ static nni_proto_pipe nni_rep_proto_pipe = { .pipe_recv = nni_rep_pipe_recv, }; -nni_proto nni_rep_protocol = { +nni_proto nni_rep_proto = { .proto_self = NNG_PROTO_REP, .proto_peer = NNG_PROTO_REQ, .proto_name = "rep", diff --git a/src/protocol/reqrep/req.c b/src/protocol/reqrep/req.c index c26d66e8..b8401107 100644 --- a/src/protocol/reqrep/req.c +++ b/src/protocol/reqrep/req.c @@ -118,6 +118,7 @@ nni_req_pipe_init(void **rpp, nni_pipe *pipe, void *rsock) rp->pipe = pipe; rp->sigclose = 0; rp->req = rsock; + *rpp = rp; return (0); } @@ -414,7 +415,7 @@ static nni_proto_pipe nni_req_proto_pipe = { .pipe_recv = nni_req_pipe_recv, }; -nni_proto nni_req_protocol = { +nni_proto nni_req_proto = { .proto_self = NNG_PROTO_REQ, .proto_peer = NNG_PROTO_REP, .proto_name = "req", |