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

refactor transport

This commit is contained in:
yihaoDeng 2024-10-16 10:35:17 +08:00
parent 6fdf9f8a9f
commit d6f1ab52fa
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -480,6 +480,7 @@ int32_t cliGetReqBySeq(SCliConn* conn, int64_t seq, int32_t msgType, SCliReq** p
int8_t cliMayRecycleConn(SCliConn* conn) { int8_t cliMayRecycleConn(SCliConn* conn) {
int32_t code = 0; int32_t code = 0;
SCliThrd* pThrd = conn->hostThrd; SCliThrd* pThrd = conn->hostThrd;
STrans* pInst = pThrd->pInst;
if (transQueueSize(&conn->reqsToSend) == 0 && transQueueSize(&conn->reqsSentOut) == 0 && if (transQueueSize(&conn->reqsToSend) == 0 && transQueueSize(&conn->reqsSentOut) == 0 &&
taosHashGetSize(conn->pQTable) == 0) { taosHashGetSize(conn->pQTable) == 0) {
cliResetConnTimer(conn); cliResetConnTimer(conn);
@ -496,6 +497,10 @@ int8_t cliMayRecycleConn(SCliConn* conn) {
} }
addConnToPool(pThrd->pool, conn); addConnToPool(pThrd->pool, conn);
return 1; return 1;
} else if ((transQueueSize(&conn->reqsToSend) == 0) &&
((pInst->shareConnLimit >= 2) && (transQueueSize(&conn->reqsSentOut) > 0) &&
transQueueSize(&conn->reqsSentOut) <= pInst->shareConnLimit / 2)) {
TAOS_UNUSED(transHeapBalance(conn->heap, conn));
} }
return 0; return 0;
} }