aboutsummaryrefslogtreecommitdiff
path: root/src/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'src/protocol')
-rw-r--r--src/protocol/survey/survey.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c
index 3870a9ef..d8ab065c 100644
--- a/src/protocol/survey/survey.c
+++ b/src/protocol/survey/survey.c
@@ -205,7 +205,7 @@ nni_surv_pipe_receiver(void *arg)
}
}
nni_msgq_signal(uwq, &ppipe->sigclose);
- nni_msgq_set_error(ppipe->sendq, NNG_ECLOSED);
+ nni_msgq_signal(ppipe->sendq, &ppipe->sigclose);
nni_pipe_close(npipe);
}