From e8b2b0d900020fde03b5dd8d1ce97b4bd03799d1 Mon Sep 17 00:00:00 2001 From: wanghaemq Date: Tue, 17 Dec 2024 01:10:36 -0500 Subject: [PATCH] * FIX [mqtt_tcp] Fix the warnings in compiling. Signed-off-by: wanghaemq --- src/mqtt/transport/quic/mqtt_quic.c | 4 +--- src/mqtt/transport/tcp/mqtt_tcp.c | 4 ++-- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/src/mqtt/transport/quic/mqtt_quic.c b/src/mqtt/transport/quic/mqtt_quic.c index 1ddfb0e0d..b40b053ce 100644 --- a/src/mqtt/transport/quic/mqtt_quic.c +++ b/src/mqtt/transport/quic/mqtt_quic.c @@ -568,7 +568,6 @@ mqtt_quictran_share_qos_send_cb(void *arg, nni_aio *qsaio, quic_substream *strea mqtt_quictran_pipe *p = arg; nni_mtx *mtx; nni_msg *msg; - uint8_t type; size_t n; int rv; @@ -604,7 +603,6 @@ mqtt_quictran_share_qos_send_cb(void *arg, nni_aio *qsaio, quic_substream *strea return; } if (msg != NULL) { - type = nni_msg_cmd_type(msg); nni_msg_free(msg); } else { log_warn("NULL msg detected in send_cb"); @@ -1221,7 +1219,7 @@ mqtt_quictran_pipe_send_start(mqtt_quictran_pipe *p) if (qos > 0) p->sndmax --; if (qos > p->qosmax) { - p->qosmax == 1? (*header &= 0XF9) & (*header |= 0X02): NNI_ARG_UNUSED(*header); + p->qosmax == 1 ? ((*header &= 0XF9), (*header |= 0X02)) : NNI_ARG_UNUSED(*header); p->qosmax == 0? *header &= 0XF9: NNI_ARG_UNUSED(*header); } } diff --git a/src/mqtt/transport/tcp/mqtt_tcp.c b/src/mqtt/transport/tcp/mqtt_tcp.c index c724e1d9d..fda4c77aa 100644 --- a/src/mqtt/transport/tcp/mqtt_tcp.c +++ b/src/mqtt/transport/tcp/mqtt_tcp.c @@ -1593,9 +1593,9 @@ static void mqtt_tcptran_ep_connect(void *arg, nni_aio *aio) { mqtt_tcptran_ep *ep = arg; - int rv; + int rv = 0; - if (nni_aio_begin(aio) != 0) { + if ((rv = nni_aio_begin(aio)) != 0) { log_error("ep connect rv %d", rv); return; }