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

add config

This commit is contained in:
yihaoDeng 2024-10-06 17:08:18 +08:00
parent 93257ba369
commit 16c6a5400b
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1952,7 +1952,7 @@ static void cliDoReq(queue* wq, SCliThrd* pThrd) {
(*cliAsyncHandle[pReq->type])(pThrd, pReq); (*cliAsyncHandle[pReq->type])(pThrd, pReq);
count++; count++;
} }
int32_t code = 0;
while (!QUEUE_IS_EMPTY(&pThrd->batchSendSet)) { while (!QUEUE_IS_EMPTY(&pThrd->batchSendSet)) {
queue* el = QUEUE_HEAD(&pThrd->batchSendSet); queue* el = QUEUE_HEAD(&pThrd->batchSendSet);
QUEUE_REMOVE(el); QUEUE_REMOVE(el);
@ -1960,7 +1960,11 @@ static void cliDoReq(queue* wq, SCliThrd* pThrd) {
SCliConn* conn = QUEUE_DATA(el, SCliConn, batchSendq); SCliConn* conn = QUEUE_DATA(el, SCliConn, batchSendq);
conn->inThreadSendq = 0; conn->inThreadSendq = 0;
QUEUE_INIT(&conn->batchSendq); QUEUE_INIT(&conn->batchSendq);
TAOS_UNUSED(cliBatchSend(conn, 1)); code = cliBatchSend(conn, 1);
if (code != 0) {
tWarn("%s conn %p failed to send req since %s", pThrd->pInst->label, conn, tstrerror(code));
TAOS_UNUSED(transUnrefCliHandle(conn));
}
} }
QUEUE_INIT(&pThrd->batchSendSet); QUEUE_INIT(&pThrd->batchSendSet);
if (count >= 2) { if (count >= 2) {