diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/protocol/survey/survey.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/protocol/survey/survey.c b/src/protocol/survey/survey.c index c7ce1c16..087211a2 100644 --- a/src/protocol/survey/survey.c +++ b/src/protocol/survey/survey.c @@ -114,10 +114,11 @@ nni_surv_pipe_init(void **pp, nni_pipe *npipe, void *psock) static void nni_surv_pipe_fini(void *arg) { - nni_surv_pipe *sp = arg; + nni_surv_pipe *ppipe = arg; - if (sp != NULL) { - NNI_FREE_STRUCT(sp); + if (ppipe != NULL) { + nni_msgq_fini(ppipe->sendq); + NNI_FREE_STRUCT(ppipe); } } |