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 09:12:41 +08:00
parent c4cf02148a
commit d072e3f7df
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1971,9 +1971,8 @@ static int32_t createBatchList(SCliBatchList** ppBatchList, char* key, char* ip,
*ppBatchList = pBatchList; *ppBatchList = pBatchList;
return 0; return 0;
} }
static int32_t destroyBatchList(SCliBatchList* pList) { static void destroyBatchList(SCliBatchList* pList) {
if (pList == NULL) { if (pList == NULL) {
return 0;
} }
while (!QUEUE_IS_EMPTY(&pList->wq)) { while (!QUEUE_IS_EMPTY(&pList->wq)) {
queue* h = QUEUE_HEAD(&pList->wq); queue* h = QUEUE_HEAD(&pList->wq);
@ -1985,7 +1984,6 @@ static int32_t destroyBatchList(SCliBatchList* pList) {
taosMemoryFree(pList->ip); taosMemoryFree(pList->ip);
taosMemoryFree(pList->dst); taosMemoryFree(pList->dst);
taosMemoryFree(pList); taosMemoryFree(pList);
return 0;
} }
static int32_t createBatch(SCliBatch** ppBatch, SCliBatchList* pList, SCliMsg* pMsg) { static int32_t createBatch(SCliBatch** ppBatch, SCliBatchList* pList, SCliMsg* pMsg) {
SCliBatch* pBatch = taosMemoryCalloc(1, sizeof(SCliBatch)); SCliBatch* pBatch = taosMemoryCalloc(1, sizeof(SCliBatch));