* FIX [broker_tcp] prevent cache msg from a closed pipe

JaylinYu · JaylinYu · commit dadcadebef28 · 2025-12-25T09:30:01.000+08:00
Signed-off-by: Jaylin &lt;jaylin@emqx.io&gt;
diff --git a/src/sp/transport/mqtt/broker_tcp.c b/src/sp/transport/mqtt/broker_tcp.c
@@ -1549,7 +1549,7 @@ tcptran_pipe_send(void *arg, nni_aio *aio)
 	}
 	nni_mtx_lock(&p->mtx);
 	nni_msg *msg = nni_aio_get_msg(aio);
-	if (msg == NULL || p->tcp_cparam == NULL) {
+	if (msg == NULL || p->tcp_cparam == NULL || p->closed == true) {
 		log_error("sending NULL msg or pipe is invalid!");
 		nni_mtx_unlock(&p->mtx);
 		if(msg) {

Original file line number	Diff line number	Diff line change
`@@ -1549,7 +1549,7 @@ tcptran_pipe_send(void arg, nni_aio aio)`
`1549`	`1549`	`}`
`1550`	`1550`	`nni_mtx_lock(&p->mtx);`
`1551`	`1551`	`nni_msg *msg = nni_aio_get_msg(aio);`
`1552`		`- if (msg == NULL \|\| p->tcp_cparam == NULL) {`
	`1552`	`+ if (msg == NULL \|\| p->tcp_cparam == NULL \|\| p->closed == true) {`
`1553`	`1553`	`log_error("sending NULL msg or pipe is invalid!");`
`1554`	`1554`	`nni_mtx_unlock(&p->mtx);`
`1555`	`1555`	`if(msg) {`