From bc41a5ee3cbabad5effc56d62449589fb0533cbb Mon Sep 17 00:00:00 2001 From: Yihao Deng Date: Thu, 16 May 2024 14:14:09 +0800 Subject: [PATCH] refactor transport --- source/libs/transport/src/transSvr.c | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index c0b2eba90a..04f6ac8c95 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -680,18 +680,19 @@ static FORCE_INLINE void destroySmsg(SSvrMsg* smsg) { taosMemoryFree(smsg); } static FORCE_INLINE void destroySmsgWrapper(void* smsg, void* param) { destroySmsg((SSvrMsg*)smsg); } -static void destroyAllConn(SWorkThrd* pThrd) { - tTrace("thread %p destroy all conn ", pThrd); - while (!QUEUE_IS_EMPTY(&pThrd->conn)) { - queue* h = QUEUE_HEAD(&pThrd->conn); - QUEUE_REMOVE(h); - QUEUE_INIT(h); - SSvrConn* c = QUEUE_DATA(h, SSvrConn, queue); - while (T_REF_VAL_GET(c) >= 2) { - transUnrefSrvHandle(c); +static void destroyAllConn(SWorkThrd* pThrd) { + tTrace("thread %p destroy all conn ", pThrd); + while (!QUEUE_IS_EMPTY(&pThrd->conn)) { + queue* h = QUEUE_HEAD(&pThrd->conn); + QUEUE_REMOVE(h); + QUEUE_INIT(h); + + SSvrConn* c = QUEUE_DATA(h, SSvrConn, queue); + while (T_REF_VAL_GET(c) >= 2) { + transUnrefSrvHandle(c); } - transUnrefSrvHandle(c); + transUnrefSrvHandle(c); } } void uvWorkerAsyncCb(uv_async_t* handle) {