From ec2b1275153487fda661942d9b98aab2567b612e Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Mon, 2 Jan 2017 14:37:42 -0800 Subject: Begin testing REQ/REP. --- src/protocol/reqrep/rep.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/protocol/reqrep/rep.c') 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", -- cgit v1.2.3-70-g09d2