* MDF [mqtt_websocket] lock send_cb

JaylinYu · JaylinYu · commit 89ac265ec2be · 2025-12-24T17:47:06.000+08:00
Signed-off-by: Jaylin &lt;jaylin@emqx.io&gt;
diff --git a/src/sp/transport/mqttws/nmq_websocket.c b/src/sp/transport/mqttws/nmq_websocket.c
@@ -82,7 +82,7 @@ wstran_pipe_send_cb(void *arg)
 
 	taio = p->txaio;
 	uaio = p->user_txaio;
-	// nni_mtx_lock(&p->mtx);
+	nni_mtx_lock(&p->mtx);
 	rv   = nni_aio_result(taio);
 	if (nni_aio_result(taio) != 0) {
 		log_warn(" send aio error %s", nng_strerror(rv));
@@ -93,7 +93,7 @@ wstran_pipe_send_cb(void *arg)
 	if (uaio != NULL) {
 		if (p->closed){
 			nni_aio_finish_error(uaio, p->err_code);
-			// nni_mtx_unlock(&p->mtx);
+			nni_mtx_unlock(&p->mtx);
 			return;
 		}
 		if (rv != 0) {
@@ -102,7 +102,7 @@ wstran_pipe_send_cb(void *arg)
 			nni_aio_finish(uaio, 0, 0);
 		}
 	}
-	// nni_mtx_unlock(&p->mtx);
+	nni_mtx_unlock(&p->mtx);
 }
 
 static void

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ wstran_pipe_send_cb(void *arg)`
`82`	`82`
`83`	`83`	`taio = p->txaio;`
`84`	`84`	`uaio = p->user_txaio;`
`85`		`- // nni_mtx_lock(&p->mtx);`
	`85`	`+ nni_mtx_lock(&p->mtx);`
`86`	`86`	`rv = nni_aio_result(taio);`
`87`	`87`	`if (nni_aio_result(taio) != 0) {`
`88`	`88`	`log_warn(" send aio error %s", nng_strerror(rv));`
`@@ -93,7 +93,7 @@ wstran_pipe_send_cb(void *arg)`
`93`	`93`	`if (uaio != NULL) {`
`94`	`94`	`if (p->closed){`
`95`	`95`	`nni_aio_finish_error(uaio, p->err_code);`
`96`		`- // nni_mtx_unlock(&p->mtx);`
	`96`	`+ nni_mtx_unlock(&p->mtx);`
`97`	`97`	`return;`
`98`	`98`	`}`
`99`	`99`	`if (rv != 0) {`
`@@ -102,7 +102,7 @@ wstran_pipe_send_cb(void *arg)`
`102`	`102`	`nni_aio_finish(uaio, 0, 0);`
`103`	`103`	`}`
`104`	`104`	`}`
`105`		`- // nni_mtx_unlock(&p->mtx);`
	`105`	`+ nni_mtx_unlock(&p->mtx);`
`106`	`106`	`}`
`107`	`107`
`108`	`108`	`static void`