From c70c6df8675e81b5a56a17492a93924de29f1fbb Mon Sep 17 00:00:00 2001 From: peili Date: Thu, 27 Feb 2025 21:48:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9C=A8RT-Thread=E4=B8=AD=EF=BC=8Crt=5Fmq=5Fr?= =?UTF-8?q?ecv=E7=9A=84=E8=BF=94=E5=9B=9E=E5=80=BC=E6=98=AF=E6=94=B6?= =?UTF-8?q?=E5=88=B0=E6=B6=88=E6=81=AF=E7=9A=84=E9=95=BF=E5=BA=A6=EF=BC=8C?= =?UTF-8?q?=E4=BF=AE=E6=94=B9umqtt.c=E4=B8=AD=E5=AF=B9=E5=85=B6=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E5=80=BC=E7=9A=84=E9=94=99=E8=AF=AF=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/umqtt.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/umqtt.c b/src/umqtt.c index 238fdb4..a61a7c3 100644 --- a/src/umqtt.c +++ b/src/umqtt.c @@ -1393,7 +1393,7 @@ int umqtt_start(struct umqtt_client *client) set_uplink_recon_tick(client, UPLINK_LAST_TICK); rt_memset(&msg_ack, 0, sizeof(msg_ack)); - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(client->mqtt_info.send_timeout * 1000))) { @@ -1512,7 +1512,7 @@ int umqtt_publish(struct umqtt_client *client, enum umqtt_qos qos, const char *t _ret = UMQTT_OK; if (qos == UMQTT_QOS1) { - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(timeout))) { @@ -1547,7 +1547,7 @@ int umqtt_publish(struct umqtt_client *client, enum umqtt_qos qos, const char *t } else if (qos == UMQTT_QOS2) { - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(timeout))) { @@ -1603,7 +1603,7 @@ int umqtt_publish(struct umqtt_client *client, enum umqtt_qos qos, const char *t } _ret = UMQTT_OK; - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(timeout))) { @@ -1718,7 +1718,7 @@ int umqtt_subscribe(struct umqtt_client *client, const char *topic, enum umqtt_q set_uplink_recon_tick(client, UPLINK_LAST_TICK); rt_memset(&msg_ack, 0, sizeof(msg_ack)); - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(client->mqtt_info.send_timeout * 1000))) { @@ -1817,7 +1817,7 @@ int umqtt_unsubscribe(struct umqtt_client *client, const char *topic) set_uplink_recon_tick(client, UPLINK_LAST_TICK); rt_memset(&msg_ack, 0, sizeof(msg_ack)); - if (RT_EOK == rt_mq_recv(client->msg_queue, + if (sizeof(struct umqtt_msg_ack) == rt_mq_recv(client->msg_queue, &msg_ack, sizeof(struct umqtt_msg_ack), rt_tick_from_millisecond(client->mqtt_info.send_timeout * 1000))) {