diff options
| -rw-r--r-- | src/protocol/survey/respond.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c index 8e36cbb0..3b8c5bd8 100644 --- a/src/protocol/survey/respond.c +++ b/src/protocol/survey/respond.c @@ -302,7 +302,7 @@ nni_resp_recv_cb(void *arg) { nni_resp_pipe *ppipe = arg; nni_resp_sock *psock = ppipe->psock; - nni_msgq *urq = nni_sock_recvq(psock->nsock); + nni_msgq *urq; nni_msg *msg; uint8_t idbuf[4]; int hops; @@ -312,6 +312,8 @@ nni_resp_recv_cb(void *arg) goto error; } + urq = nni_sock_recvq(psock->nsock); + NNI_PUT32(idbuf, ppipe->id); msg = ppipe->aio_recv.a_msg; |