refactor transport

This commit is contained in:
yihaoDeng 2024-10-16 11:41:59 +08:00
parent 0afec9a5f4
commit 29b07a350c
1 changed files with 1 additions and 3 deletions

View File

@ -506,9 +506,7 @@ int8_t cliMayRecycleConn(SCliConn* conn) {
(taosHashGetSize(conn->pQTable) != 0)) {
tDebug("%s conn %p do balance directly", CONN_GET_INST_LABEL(conn), conn);
TAOS_UNUSED(transHeapBalance(conn->heap, conn));
} else if ((transQueueSize(&conn->reqsToSend) == 0) &&
((pInst->shareConnLimit >= 4) && ((transQueueSize(&conn->reqsSentOut) > 0) &&
transQueueSize(&conn->reqsSentOut) < pInst->shareConnLimit / 2))) {
} else {
SCliConn* topConn = NULL;
if (conn->heap != NULL) {
code = transHeapGet(conn->heap, &topConn);