From 17faedcee8dbbf10b8bba56fcaad2dbab76ba625 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 10 Oct 2024 15:24:00 +0800 Subject: [PATCH] add time out --- source/libs/transport/src/transCli.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 0e11efaf45..9c8c8fb277 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -837,7 +837,7 @@ static int32_t cliGetConnFromPool(SCliThrd* pThrd, const char* key, SCliConn** p return TSDB_CODE_RPC_NETWORK_BUSY; } - queue* h = QUEUE_TAIL(&plist->conns); + queue* h = QUEUE_HEAD(&plist->conns); plist->size -= 1; QUEUE_REMOVE(h); @@ -894,7 +894,7 @@ static void addConnToPool(void* pool, SCliConn* conn) { conn->heapMissHit = 0; - if (conn->list->size >= 2) { + if (conn->list->size >= 5) { STaskArg* arg = taosMemoryCalloc(1, sizeof(STaskArg)); if (arg == NULL) return; arg->param1 = conn;