diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 085e609961..65389b8bd0 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -3192,11 +3192,15 @@ static int32_t getOrCreateHeap(SHashObj* pConnHeapCache, char* key, SHeap** pHea } static FORCE_INLINE int8_t shouldSWitchToOtherConn(int32_t reqNum, int32_t sentNum, int32_t stateNum) { - int32_t total = reqNum + sentNum + stateNum; + int32_t total = reqNum + sentNum; if (total >= BUFFER_LIMIT) { return 1; } + if (stateNum >= BUFFER_LIMIT * 2) { + return 1; + } + return 0; }