From dc51ba1c3132d8ba0260102a94a414c1160e53cb Mon Sep 17 00:00:00 2001 From: hxy7yx <1595670487@qq.com> Date: Tue, 19 Aug 2025 19:41:58 -0700 Subject: [PATCH] fix(mqtt):handle errors when no subACK code is received --- src/connection/mqtt_client.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/connection/mqtt_client.c b/src/connection/mqtt_client.c index 9ff8ce241..0958389d2 100644 --- a/src/connection/mqtt_client.c +++ b/src/connection/mqtt_client.c @@ -407,6 +407,11 @@ static void task_handle_sub(task_t *task, neu_mqtt_client_t *client) } rc = nng_mqtt_msg_get_suback_return_codes(msg, &n); + if (NULL == rc) { + log(error, "failed to get SUBACK return codes"); + rv = -1; + goto end; + } log(debug, "recv SUBACK return_code:%d", *rc); rv = 0x80 == *rc ? -1 : 0; task->sub->ack = true;