* FIX [trans/quic] packmax should be applied to both mqttv311 and mqtv5.

Signed-off-by: wanghaemq <wangwei@emqx.io>
nanomq · May 15, 2024 · 4723ee9 · 4723ee9
1 parent 0caaf48
commit 4723ee9
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/mqtt/transport/tcp/mqtt_tcp.c b/src/mqtt/transport/tcp/mqtt_tcp.c
@@ -781,12 +781,13 @@ mqtt_tcptran_pipe_send_start(mqtt_tcptran_pipe *p)
 				p->qosmax == 0 ? *header &= 0XF9 : NNI_ARG_UNUSED(*header);
 			}
 		}
-		// check max packet size
-		if (nni_msg_header_len(msg) + nni_msg_len(msg) > p->packmax) {
-			txaio = p->txaio;
-			nni_aio_finish_error(txaio, UNSPECIFIED_ERROR);
-			return;
-		}
+	}
+
+	// check max packet size
+	if (nni_msg_header_len(msg) + nni_msg_len(msg) > p->packmax) {
+		txaio = p->txaio;
+		nni_aio_finish_error(txaio, UNSPECIFIED_ERROR);
+		return;
 	}
 
 	txaio = p->txaio;