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

handle quit error

This commit is contained in:
yihaoDeng 2024-10-30 16:30:46 +08:00
parent 70c9d9847f
commit a191e9993a
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1311,11 +1311,9 @@ static void cliBatchSendCb(uv_write_t* req, int status) {
STrans* pInst = pThrd->pInst; STrans* pInst = pThrd->pInst;
while (!QUEUE_IS_EMPTY(&wrapper->node)) { while (!QUEUE_IS_EMPTY(&wrapper->node)) {
queue* h = QUEUE_HEAD(&wrapper->node); queue* h = QUEUE_HEAD(&wrapper->node);
QUEUE_REMOVE(h);
SCliReq* pReq = QUEUE_DATA(h, SCliReq, sendQ); SCliReq* pReq = QUEUE_DATA(h, SCliReq, sendQ);
pReq->inSendQ = 0; removeReqFromSendQ(pReq);
} }
freeWReqToWQ(&conn->wq, wrapper); freeWReqToWQ(&conn->wq, wrapper);