From b447c620e5d8b0175b0af7130e7a1d36c64537bb Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Mon, 16 Sep 2024 18:35:45 +0800 Subject: [PATCH] Merge branch '3.0' into enh/opt-transport --- source/libs/transport/src/transCli.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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; }