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

Merge branch '3.0' into enh/opt-transport

This commit is contained in:
yihaoDeng 2024-09-16 18:45:18 +08:00
parent 721d997c38
commit d6e7189201
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

@ -3211,15 +3211,15 @@ static FORCE_INLINE bool filterToDebug(void* e, void* arg) {
return false; return false;
} }
static FORCE_INLINE int32_t logConnMissHit(SCliConn* pConn) { static FORCE_INLINE int32_t logConnMissHit(SCliConn* pConn) {
queue set; // queue set;
QUEUE_INIT(&set); // QUEUE_INIT(&set);
pConn->heapMissHit++; pConn->heapMissHit++;
tDebug("conn %p has %d reqs, %d sentout and %d status in process, total limit:%d, switch to other conn", pConn, 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), transQueueSize(&pConn->reqsToSend), transQueueSize(&pConn->reqsSentOut), taosHashGetSize(pConn->pQTable),
BUFFER_LIMIT); BUFFER_LIMIT);
if (transQueueSize(&pConn->reqsSentOut) >= BUFFER_LIMIT) { // if (transQueueSize(&pConn->reqsSentOut) >= BUFFER_LIMIT) {
transQueueRemoveByFilter(&pConn->reqsSentOut, filterToDebug, NULL, &set, 1); // transQueueRemoveByFilter(&pConn->reqsSentOut, filterToDebug, NULL, &set, 1);
} // }
return 0; return 0;
} }
static SCliConn* getConnFromHeapCache(SHashObj* pConnHeapCache, char* key) { static SCliConn* getConnFromHeapCache(SHashObj* pConnHeapCache, char* key) {