* FIX [nmq_mqtt] fix potential memleak of local conn_param

nanomq · May 6, 2023 · 7f31d19 · 7f31d19
1 parent 1cde5b5
commit 7f31d19
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/sp/protocol/mqtt/nmq_mqtt.c b/src/sp/protocol/mqtt/nmq_mqtt.c
@@ -99,6 +99,7 @@ nmq_close_unack_msg_cb(void *key, void *val)
 	nni_msg_free(msg);
 }
 
+// Flush lmq and conn_param
 void
 nano_nni_lmq_flush(nni_lmq *lmq, bool cp)
 {
@@ -851,7 +852,7 @@ nano_pipe_close(void *arg)
 				if (nni_lmq_resize(&s->waitlmq,
 				        nni_lmq_cap(&s->waitlmq) * 2) != 0) {
 					log_error("wait lmq resize failed.");
-					conn_param_clone(p->conn_param);
+					conn_param_free(p->conn_param);
 					nni_msg_free(msg);
 				}
 			}