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

fix limit

This commit is contained in:
yihaoDeng 2024-10-23 17:29:28 +08:00
parent 4b37a1092d
commit ebaef4a537
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -27,7 +27,7 @@ typedef struct {
typedef struct SConnList { typedef struct SConnList {
queue conns; queue conns;
int32_t size; int32_t size;
int32_t totaSize; int32_t totalSize;
} SConnList; } SConnList;
typedef struct { typedef struct {
@ -855,10 +855,10 @@ static int32_t cliGetConnFromPool(SCliThrd* pThrd, const char* key, SCliConn** p
} }
if (QUEUE_IS_EMPTY(&plist->conns)) { if (QUEUE_IS_EMPTY(&plist->conns)) {
if (plist->totaSize >= pInst->connLimitNum) { if (plist->totalSize >= pInst->connLimitNum) {
return TSDB_CODE_RPC_MAX_SESSIONS; return TSDB_CODE_RPC_MAX_SESSIONS;
} }
plist->totaSize += 1; plist->totalSize += 1;
return TSDB_CODE_RPC_NETWORK_BUSY; return TSDB_CODE_RPC_NETWORK_BUSY;
} }
@ -1249,7 +1249,7 @@ static void cliHandleException(SCliConn* conn) {
cliDestroyAllQidFromThrd(conn); cliDestroyAllQidFromThrd(conn);
QUEUE_REMOVE(&conn->q); QUEUE_REMOVE(&conn->q);
if (conn->list) { if (conn->list) {
conn->list->totaSize -= 1; conn->list->totalSize -= 1;
conn->list = NULL; conn->list = NULL;
} }
@ -3739,7 +3739,7 @@ static FORCE_INLINE int8_t shouldSWitchToOtherConn(SCliConn* pConn, char* key) {
tTrace("conn %p get list %p from pool for key:%s", pConn, pConn->list, key); tTrace("conn %p get list %p from pool for key:%s", pConn, pConn->list, key);
} }
} }
if (pConn->list && pConn->list->totaSize >= pInst->connLimitNum / 4) { if (pConn->list && pConn->list->totalSize >= pInst->connLimitNum / 4) {
tWarn("%s conn %p try to remove timeout msg since too many conn created", transLabel(pInst), pConn); tWarn("%s conn %p try to remove timeout msg since too many conn created", transLabel(pInst), pConn);
if (cliConnRemoveTimeoutMsg(pConn)) { if (cliConnRemoveTimeoutMsg(pConn)) {