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

refactor errno code

This commit is contained in:
yihaoDeng 2024-08-10 18:55:03 +08:00
parent 1a2e233d09
commit 6a7cee7687
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1161,7 +1161,7 @@ void cliSendBatch(SCliConn* pConn) {
if (wb == NULL) { if (wb == NULL) {
code = TSDB_CODE_OUT_OF_MEMORY; code = TSDB_CODE_OUT_OF_MEMORY;
tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code)); tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code));
goto _except; goto _exception;
} }
int i = 0; int i = 0;
@ -1177,7 +1177,7 @@ void cliSendBatch(SCliConn* pConn) {
if (pMsg->pCont == NULL) { if (pMsg->pCont == NULL) {
code = TSDB_CODE_OUT_OF_BUFFER; code = TSDB_CODE_OUT_OF_BUFFER;
tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code)); tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code));
goto _except; goto _exception;
} }
pMsg->contLen = 0; pMsg->contLen = 0;
} }
@ -1215,7 +1215,7 @@ void cliSendBatch(SCliConn* pConn) {
if (req == NULL) { if (req == NULL) {
code = TSDB_CODE_OUT_OF_MEMORY; code = TSDB_CODE_OUT_OF_MEMORY;
tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code)); tError("%s conn %p failed to send batch msg since:%s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(code));
goto _except; goto _exception;
} }
req->data = pConn; req->data = pConn;
tDebug("%s conn %p start to send batch msg, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(pConn), pConn, tDebug("%s conn %p start to send batch msg, batch size:%d, msgLen:%d", CONN_GET_INST_LABEL(pConn), pConn,
@ -1224,13 +1224,13 @@ void cliSendBatch(SCliConn* pConn) {
code = uv_write(req, (uv_stream_t*)pConn->stream, wb, wLen, cliSendBatchCb); code = uv_write(req, (uv_stream_t*)pConn->stream, wb, wLen, cliSendBatchCb);
if (code != 0) { if (code != 0) {
tDebug("%s conn %p failed to to send batch msg since %s", CONN_GET_INST_LABEL(pConn), pConn, uv_err_name(code)); tDebug("%s conn %p failed to to send batch msg since %s", CONN_GET_INST_LABEL(pConn), pConn, uv_err_name(code));
goto _except; goto _exception;
} }
taosMemoryFree(wb); taosMemoryFree(wb);
return; return;
_except: _exception:
cliDestroyBatch(pBatch); cliDestroyBatch(pBatch);
taosMemoryFree(wb); taosMemoryFree(wb);
pConn->pBatch = NULL; pConn->pBatch = NULL;