xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add debug info

This commit is contained in:
yihaoDeng 2023-02-16 19:29:06 +08:00
parent 23e1cb8fd5
commit 666cfd8701
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/transport/src/transCli.c
View File

@ -879,6 +879,8 @@ void cliSendBatch(SCliConn* pConn) {
uv_write_t* req = taosMemoryCalloc(1, sizeof(uv_write_t)); uv_write_t* req = taosMemoryCalloc(1, sizeof(uv_write_t));
req->data = pConn; req->data = pConn;
tDebug("%p conn %p start to send batch msg, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(pConn), pConn,
pBatch->wLen, pBatch->batchSize);
uv_write(req, (uv_stream_t*)pConn->stream, wb, wLen, cliSendBatchCb); uv_write(req, (uv_stream_t*)pConn->stream, wb, wLen, cliSendBatchCb);
taosMemoryFree(wb); taosMemoryFree(wb);
} }
@ -1074,6 +1076,9 @@ static void cliSendBatchCb(uv_write_t* req, int status) {
SCliConn* conn = req->data; SCliConn* conn = req->data;
taosMemoryFree(req); taosMemoryFree(req);
tDebug("%p conn %p send batch msg out, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(conn), conn, conn->pBatch->wLen,
conn->pBatch->batchSize);
SCliThrd* thrd = conn->hostThrd; SCliThrd* thrd = conn->hostThrd;
cliDestroyBatch(conn->pBatch); cliDestroyBatch(conn->pBatch);
conn->pBatch = NULL; conn->pBatch = NULL;