From 7def9662dad8a888356ae419e3cbe1f088051879 Mon Sep 17 00:00:00 2001 From: wanghaemq Date: Fri, 31 Mar 2023 12:22:36 +0800 Subject: [PATCH] * FIX [mqtt_codec] Fix the wrong length in decoding publish packet. --- src/supplemental/mqtt/mqtt_codec.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/supplemental/mqtt/mqtt_codec.c b/src/supplemental/mqtt/mqtt_codec.c index f38bf926..c9342a06 100644 --- a/src/supplemental/mqtt/mqtt_codec.c +++ b/src/supplemental/mqtt/mqtt_codec.c @@ -2220,7 +2220,7 @@ nni_mqttv5_msg_decode_publish(nni_msg *msg) a PUBLISH Packet to contain a zero length payload.*/ mqtt->payload.publish.payload.length = mqtt->fixed_header.remaining_length - - (2 /* Length bytes of Topic Name */ + + (2 /* Length bytes of Topic Name */ + 1 + prop_len + mqtt->var_header.publish.topic_name.length + packid_length); mqtt->payload.publish.payload.buf = (mqtt->payload.publish.payload.length > 0) ? buf.curpos : NULL;