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) {