From d6e7189201f65a7d83bcdbd41db5cfebe3055969 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Mon, 16 Sep 2024 18:45:18 +0800 Subject: [PATCH] Merge branch '3.0' into enh/opt-transport --- source/libs/transport/src/transCli.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 440b6a867c..5513ea692b 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -3211,15 +3211,15 @@ static FORCE_INLINE bool filterToDebug(void* e, void* arg) { return false; } static FORCE_INLINE int32_t logConnMissHit(SCliConn* pConn) { - queue set; - QUEUE_INIT(&set); + // queue set; + // QUEUE_INIT(&set); pConn->heapMissHit++; tDebug("conn %p has %d reqs, %d sentout and %d status in process, total limit:%d, switch to other conn", pConn, transQueueSize(&pConn->reqsToSend), transQueueSize(&pConn->reqsSentOut), taosHashGetSize(pConn->pQTable), BUFFER_LIMIT); - if (transQueueSize(&pConn->reqsSentOut) >= BUFFER_LIMIT) { - transQueueRemoveByFilter(&pConn->reqsSentOut, filterToDebug, NULL, &set, 1); - } + // if (transQueueSize(&pConn->reqsSentOut) >= BUFFER_LIMIT) { + // transQueueRemoveByFilter(&pConn->reqsSentOut, filterToDebug, NULL, &set, 1); + // } return 0; } static SCliConn* getConnFromHeapCache(SHashObj* pConnHeapCache, char* key) {