* FIX [mqtt_client] pick correct aio to send in pipe_start

Signed-off-by: jaylin <jaylin@emqx.io>
nanomq · Nov 14, 2024 · 7071d72 · 7071d72
1 parent bc09d05
commit 7071d72
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/mqtt/protocol/mqtt/mqtt_client.c b/src/mqtt/protocol/mqtt/mqtt_client.c
@@ -559,7 +559,7 @@ mqtt_pipe_start(void *arg)
 	if ((aio = nni_list_first(&s->cached_aio)) != NULL) {
 		nni_list_remove(&s->cached_aio, aio);
 		nni_pipe_recv(p->pipe, &p->recv_aio);
-		mqtt_send_msg(c->saio, NULL, s);
+		mqtt_send_msg(aio, NULL, s);
 		nni_sleep_aio(s->retry, &p->time_aio);
 		return (0);
 	}