* FIX [quic] Fix the stuck on quic protocol layer sending msg that ne…

…ed acks. Signed-off-by: wanghaemq <wangwei@emqx.io>
nanomq · Mar 6, 2024 · c0c5f6d · c0c5f6d
1 parent ae1daa3
commit c0c5f6d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/supplemental/mqtt/mqtt_msg.c b/src/supplemental/mqtt/mqtt_msg.c
@@ -919,7 +919,7 @@ mqtt_close_unack_msg_cb(void *key, void *val)
 	aio = nni_mqtt_msg_get_aio(msg);
 	if (aio) {
 		// could be incompatible with nng_close(quic_socket)
-		nni_aio_abort(aio, NNG_ECLOSED);
+		nni_aio_finish_error(aio, NNG_ECLOSED);
 	}
 #ifdef NNG_HAVE_MQTT_BROKER
 	conn_param *cparam = NULL;