From 0113eb8781f9195d2ede3883f85141ba9d429adc Mon Sep 17 00:00:00 2001 From: wayne Date: Fri, 29 Dec 2023 16:38:27 +0800 Subject: [PATCH] * MDF [log] optimize format Signed-off-by: wayne --- src/mqtt/transport/tcp/mqtt_tcp.c | 21 +++++++++++++++------ 1 file changed, 15 insertions(+), 6 deletions(-) diff --git a/src/mqtt/transport/tcp/mqtt_tcp.c b/src/mqtt/transport/tcp/mqtt_tcp.c index 29da4ecc..d1d9eea6 100644 --- a/src/mqtt/transport/tcp/mqtt_tcp.c +++ b/src/mqtt/transport/tcp/mqtt_tcp.c @@ -916,17 +916,26 @@ mqtt_tcptran_pipe_send_start(mqtt_tcptran_pipe *p) niov++; } - int msg_body_len = 30 < nni_msg_len(msg) ? 30 : nni_msg_len(msg); + int msg_body_len = 30 < nni_msg_len(msg) ? 30 : nni_msg_len(msg); - char *data = iov[0].iov_buf; - for (int i = 0; i < nni_msg_header_len(msg);++i) { - log_debug("msg header %d: %x", i, data[i]); + char *strheader = nng_alloc(nni_msg_header_len(msg) * 3 + 1); + char *strbody = nng_alloc(msg_body_len * 3 + 1); + char *data; + + data = nni_msg_header(msg); + for (int i = 0; i < nni_msg_header_len(msg); ++i) { + sprintf(strheader + i * 3, "%02X ", data[i]); } + log_debug("msg header: %s", strheader); - data = iov[1].iov_buf; + data = nni_msg_body(msg); for (int i = 0; i < msg_body_len; ++i) { - log_debug("msg body %d: %x", i, data[i]); + sprintf(strbody + i * 3, "%02X ", data[i]); } + log_debug("msg body: %s", strbody); + + nng_free(strheader, nni_msg_header_len(msg) * 3 + 1); + nng_free(strbody, msg_body_len * 3 + 1); nni_aio_set_iov(txaio, niov, iov); nng_stream_send(p->conn, txaio);