From 81a4ef73f1121d8b74e166ab42d455b6fe2a1ceb Mon Sep 17 00:00:00 2001 From: Yihao Deng Date: Thu, 16 May 2024 16:26:49 +0800 Subject: [PATCH] refactor transport --- source/libs/transport/src/transCli.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 419c037a5d..023cb16b8b 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -1803,13 +1803,13 @@ static void cliBatchDealReq(queue* wq, SCliThrd* pThrd) { SCliMsg* pMsg = QUEUE_DATA(h, SCliMsg, q); - if (pMsg->type == Quit) { - pThrd->stopMsg = pMsg; + if (pMsg->type == Normal && REQUEST_NO_RESP(&pMsg->msg)) { + cliBuildBatch(pMsg, h, pThrd); continue; } - if (pMsg->type == Normal && REQUEST_NO_RESP(&pMsg->msg)) { - cliBuildBatch(pMsg, h, pThrd); + if (pMsg->type == Quit) { + pThrd->stopMsg = pMsg; continue; } (*cliAsyncHandle[pMsg->type])(pMsg, pThrd);