* FIX [mqtt_client] fix thread sanitizer complain

nanomq · Apr 30, 2023 · 6852a62 · 6852a62
1 parent 4516526
commit 6852a62
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/mqtt/protocol/mqtt/mqtt_client.c b/src/mqtt/protocol/mqtt/mqtt_client.c
@@ -1001,16 +1001,17 @@ mqtt_ctx_send(void *arg, nni_aio *aio)
 static void
 mqtt_ctx_recv(void *arg, nni_aio *aio)
 {
-	mqtt_ctx_t * ctx = arg;
+	mqtt_ctx_t  *ctx = arg;
 	mqtt_sock_t *s   = ctx->mqtt_sock;
-	mqtt_pipe_t *p   = s->mqtt_pipe;
+	mqtt_pipe_t *p;
 	nni_msg     *msg = NULL;
 
 	if (nni_aio_begin(aio) != 0) {
 		return;
 	}
 
 	nni_mtx_lock(&s->mtx);
+	p = s->mqtt_pipe;
 	if (p == NULL) {
 		goto wait;
 	}