From 092e2c46826ebd7360d0fca58c18594e310c9f1e Mon Sep 17 00:00:00 2001 From: x152152 <604047286@qq.com> Date: Fri, 21 Nov 2025 20:17:25 +0800 Subject: [PATCH] Fix: Use thread-safe MQTTAsync_Socket_noPendingWrites in MQTTAsync pending writes handling Signed-off-by: x152152 <604047286@qq.com> --- src/MQTTAsyncUtils.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/MQTTAsyncUtils.c b/src/MQTTAsyncUtils.c index db06f8b1..1a2a2597 100644 --- a/src/MQTTAsyncUtils.c +++ b/src/MQTTAsyncUtils.c @@ -1027,7 +1027,7 @@ static void MQTTProtocol_checkPendingWrites(void) ListElement* le = state.pending_writes.first; while (le) { - if (Socket_noPendingWrites(((pending_write*)(le->content))->socket)) + if (MQTTAsync_Socket_noPendingWrites(((pending_write*)(le->content))->socket)) { MQTTProtocol_removePublication(((pending_write*)(le->content))->p); state.pending_writes.current = le; @@ -2462,7 +2462,7 @@ static void MQTTAsync_closeOnly(Clients* client, enum MQTTReasonCodes reasonCode if (client->net.socket > 0) { MQTTProtocol_checkPendingWrites(); - if (client->connected && Socket_noPendingWrites(client->net.socket)) + if (client->connected && MQTTAsync_Socket_noPendingWrites(client->net.socket)) MQTTPacket_send_disconnect(client, reasonCode, props); MQTTAsync_lock_mutex(socket_mutex); WebSocket_close(&client->net, WebSocket_CLOSE_NORMAL, NULL);