* FIX [mqtt_client/SDK] fix missing "msg" that was deleted

Signed-off-by: jaylin <[email protected]>
emqx · Jan 8, 2024 · 7746164 · 7746164
1 parent 2527e4f
commit 7746164
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/mqtt/protocol/mqtt/mqtt_client.c b/src/mqtt/protocol/mqtt/mqtt_client.c
@@ -491,7 +491,7 @@ mqtt_timer_cb(void *arg)
 	mqtt_pipe_t *p = arg;
 	mqtt_sock_t *s = p->mqtt_sock;
 	// disable retransmission
-	// nni_msg *  msg = NULL;
+	nni_msg *  msg = NULL;
 	// nni_aio *  aio;
 	// uint16_t   pid = p->rid;
 

diff --git a/src/mqtt/protocol/mqtt/mqttv5_client.c b/src/mqtt/protocol/mqtt/mqttv5_client.c
@@ -480,7 +480,7 @@ mqtt_timer_cb(void *arg)
 {
 	mqtt_pipe_t *p = arg;
 	mqtt_sock_t *s = p->mqtt_sock;
-	// nni_msg *  msg;
+	nni_msg *  msg;
 	// nni_aio *  aio;
 	// uint16_t   pid = p->rid;