From 9b77e2dfe84a0ce14bfa4ad1a8aa1088ad62d3ea Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 24 Feb 2023 22:44:03 +0800 Subject: [PATCH] fix: limit session num --- source/libs/transport/src/transCli.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index d002366a12..0e8b87938c 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -1096,6 +1096,8 @@ static void cliHandleBatchReq(SCliBatch* pBatch, SCliThrd* pThrd) { nList->numOfConn++; QUEUE_INIT(&nList->msgQ); taosHashPut(pThrd->connLimitCache, conn->ip, strlen(conn->ip), &nList, sizeof(void*)); + } else { + (*list)->numOfConn++; } uv_timer_start(conn->timer, cliConnTimeout, TRANS_CONN_TIMEOUT, 0); return; @@ -1400,7 +1402,6 @@ static void doFreeTimeoutMsg(void* param) { STrans* pTransInst = pThrd->pTransInst; QUEUE_REMOVE(&pMsg->q); - STraceId* trace = &pMsg->msg.info.traceId; tGTrace("%s msg %s cannot get available conn after timeout", pTransInst->label, TMSG_INFO(pMsg->msg.msgType)); doNotifyApp(pMsg, pThrd); @@ -1531,6 +1532,8 @@ void cliHandleReq(SCliMsg* pMsg, SCliThrd* pThrd) { nList->numOfConn++; QUEUE_INIT(&nList->msgQ); taosHashPut(pThrd->connLimitCache, conn->ip, strlen(conn->ip), &nList, sizeof(void*)); + } else { + (*list)->numOfConn++; } uv_timer_start(conn->timer, cliConnTimeout, TRANS_CONN_TIMEOUT, 0);