From a5306b7133049fe8b22eb9c68dad2cf0a007a952 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 19 Sep 2024 09:49:46 +0800 Subject: [PATCH] fix invalid read/write --- source/libs/transport/src/transCli.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 026b7b2c91..17d8c819b8 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -181,9 +181,8 @@ typedef struct { // conn pool // add expire timeout and capacity limit -static void* createConnPool(int size); -static void* destroyConnPool(SCliThrd* thread); -// static SCliConn* getConnFromPool(SCliThrd* thread, char* key, bool* exceed); +static void* createConnPool(int size); +static void* destroyConnPool(SCliThrd* thread); static void addConnToPool(void* pool, SCliConn* conn); static void doCloseIdleConn(void* param); static int32_t cliCreateConn2(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn); @@ -816,6 +815,7 @@ static void addConnToPool(void* pool, SCliConn* conn) { } conn->status = ConnInPool; + QUEUE_INIT(&conn->q); QUEUE_PUSH(&conn->list->conns, &conn->q); conn->list->size += 1; tDebug("conn %p added to pool, pool size: %d, dst: %s", conn, conn->list->size, conn->dstAddr);