diff options
Diffstat (limited to 'src/protocol/survey0/survey.c')
| -rw-r--r-- | src/protocol/survey0/survey.c | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/protocol/survey0/survey.c b/src/protocol/survey0/survey.c index dcf92e07..999b8a56 100644 --- a/src/protocol/survey0/survey.c +++ b/src/protocol/survey0/survey.c @@ -384,12 +384,7 @@ surv0_pipe_recv_cb(void *arg) return; } id = nni_msg_trim_u32(msg); - if (nni_msg_header_append_u32(msg, id) != 0) { - // Should be NNG_ENOMEM - discard and try again. - nni_msg_free(msg); - nni_pipe_recv(p->npipe, p->aio_recv); - return; - } + nni_msg_header_must_append_u32(msg ,id); nni_mtx_lock(&sock->mtx); |