* FIX [proto/quic] Fix the double free of msg in recv_aio.

Signed-off-by: wanghaemq <wangwei@emqx.io>
nanomq · May 11, 2024 · 17f620e · 17f620e
1 parent c3b043d
commit 17f620e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/mqtt/protocol/mqtt/mqtt_quic_client.c b/src/mqtt/protocol/mqtt/mqtt_quic_client.c
@@ -704,10 +704,10 @@ mqtt_quic_recv_cb(void *arg)
 	    nni_atomic_get_bool(&p->closed)) {
 		// pipe is already closed somewhere
 		// free msg and dont return data when pipe is closed.
-		msg = nni_aio_get_msg(&p->recv_aio);
-		if (msg) {
-			nni_msg_free(msg);
-		}
+		//msg = nni_aio_get_msg(&p->recv_aio);
+		//if (msg) {
+		//	nni_msg_free(msg);
+		//}
 		nni_mtx_unlock(&p->lk);
 		return;
 	}

diff --git a/src/mqtt/protocol/mqtt/mqttv5_quic_client.c b/src/mqtt/protocol/mqtt/mqttv5_quic_client.c
@@ -705,10 +705,10 @@ mqtt_quic_recv_cb(void *arg)
 	    nni_atomic_get_bool(&p->closed)) {
 		// pipe is already closed somewhere
 		// free msg and dont return data when pipe is closed.
-		msg = nni_aio_get_msg(&p->recv_aio);
-		if (msg) {
-			nni_msg_free(msg);
-		}
+		//msg = nni_aio_get_msg(&p->recv_aio);
+		//if (msg) {
+		//	nni_msg_free(msg);
+		//}
 		nni_mtx_unlock(&p->lk);
 		return;
 	}