* MDF [mqtt_quic] count tx msg in prior_send as well

Signed-off-by: Jaylin <jaylin@emqx.io>

Author: JaylinYu

src/mqtt/protocol/mqtt/mqtt_quic_client.c

@@ -1027,11 +1027,20 @@ static void mqtt_quic_sock_init(void *arg, nni_sock *sock)
 		.si_atomic = true,
 	};
 	nni_stat_init(&s->msg_bytes_cached, &msg_bytes_cached);
+	static const nni_stat_info msg_sqlite_cached = {
+		.si_name   = "mqtt_msg_sqlite_cached",
+		.si_desc   = "count all cached msg in sqlite",
+		.si_type   = NNG_STAT_COUNTER,
+		.si_unit   = NNG_UNIT_BYTES,
+		.si_atomic = true,
+	};
+	nni_stat_init(&s->msg_sqlite_cached, &msg_sqlite_cached);
 	nni_sock_add_stat(s->nsock, &s->mqtt_reconnect);
 	nni_sock_add_stat(s->nsock, &s->msg_resend);
 	nni_sock_add_stat(s->nsock, &s->msg_send_drop);
 	nni_sock_add_stat(s->nsock, &s->msg_recv_drop);
 	nni_sock_add_stat(s->nsock, &s->msg_bytes_cached);
+	nni_sock_add_stat(s->nsock, &s->msg_sqlite_cached);
 #endif
 }
 

src/mqtt/transport/quic/mqtt_quic.c

@@ -1162,6 +1162,10 @@ mqtt_quictran_pipe_send_prior(mqtt_quictran_pipe *p, nni_aio *aio)
 	// *flag |= p->substreams[nni_random()%2].id;
 	// nni_aio_set_prov_data(aio, flag);
 	nng_stream_send(p->conn, aio);
+#ifdef NNG_ENABLE_STATS
+	// assume it is already sent, since we cannot access user cb.
+	nni_sock_bump_tx(p->ep->nsock, nni_msg_len(msg));
+#endif
 }
 
 static void