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

Merge remote-tracking branch 'origin/3.0' into enh/opt-transport

This commit is contained in:
yihaoDeng 2024-10-11 17:32:11 +08:00
parent 2ca458fa30
commit 731f9b3fb7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3796,11 +3796,11 @@ static int32_t delConnFromHeapCache(SHashObj* pConnHeapCache, SCliConn* pConn) {
static int32_t balanceConnHeapCache(SHashObj* pConnHeapCache, SCliConn* pConn) { static int32_t balanceConnHeapCache(SHashObj* pConnHeapCache, SCliConn* pConn) {
if (pConn->heap != NULL && pConn->inHeap != 0) { if (pConn->heap != NULL && pConn->inHeap != 0) {
SHeap* heap = pConn->heap; SHeap* heap = pConn->heap;
tTrace("conn %p'heap have too many conn %d, should do balance", pConn, heap->heap->nelts); tTrace("conn %p'heap may should do balance, numOfConn:%d", pConn, heap->heap->nelts);
int64_t now = taosGetTimestampMs(); int64_t now = taosGetTimestampMs();
if (((now - heap->lastUpdateTs) / 1000) > 30) { if (((now - heap->lastUpdateTs) / 1000) > 30) {
heap->lastUpdateTs = now; heap->lastUpdateTs = now;
tTrace("conn %p'heap have too many conn %d, do balance", pConn, heap->heap->nelts); tTrace("conn %p'heap do balance, numOfConn:%d", pConn, heap->heap->nelts);
return transHeapBalance(pConn->heap, pConn); return transHeapBalance(pConn->heap, pConn);
} }
} }