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:23:03 +08:00
parent d072e3f7df
commit 1a2e233d09
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1973,6 +1973,7 @@ static int32_t createBatchList(SCliBatchList** ppBatchList, char* key, char* ip,
} }
static void destroyBatchList(SCliBatchList* pList) { static void destroyBatchList(SCliBatchList* pList) {
if (pList == NULL) { if (pList == NULL) {
return;
} }
while (!QUEUE_IS_EMPTY(&pList->wq)) { while (!QUEUE_IS_EMPTY(&pList->wq)) {
queue* h = QUEUE_HEAD(&pList->wq); queue* h = QUEUE_HEAD(&pList->wq);
@ -2056,7 +2057,10 @@ static void cliBatchDealReq(queue* wq, SCliThrd* pThrd) {
if (QUEUE_IS_EMPTY(&(*ppBatchList)->wq)) { if (QUEUE_IS_EMPTY(&(*ppBatchList)->wq)) {
SCliBatch* pBatch = NULL; SCliBatch* pBatch = NULL;
code = createBatch(&pBatch, *ppBatchList, pMsg); code = createBatch(&pBatch, *ppBatchList, pMsg);
if (code != 0) cliDestroyBatch(pBatch); if (code != 0) {
destroyCmsg(pMsg);
cliDestroyBatch(pBatch);
}
} else { } else {
queue* hdr = QUEUE_TAIL(&((*ppBatchList)->wq)); queue* hdr = QUEUE_TAIL(&((*ppBatchList)->wq));
SCliBatch* pBatch = QUEUE_DATA(hdr, SCliBatch, listq); SCliBatch* pBatch = QUEUE_DATA(hdr, SCliBatch, listq);
@ -2067,7 +2071,10 @@ static void cliBatchDealReq(queue* wq, SCliThrd* pThrd) {
} else { } else {
SCliBatch* tBatch = NULL; SCliBatch* tBatch = NULL;
code = createBatch(&tBatch, *ppBatchList, pMsg); code = createBatch(&tBatch, *ppBatchList, pMsg);
if (code != 0) cliDestroyBatch(pBatch); if (code != 0) {
destroyCmsg(pMsg);
cliDestroyBatch(pBatch);
}
} }
} }
} }