From 1e569acc3356116c24301a0bcefbd83a26928273 Mon Sep 17 00:00:00 2001 From: "pengrongkun94@qq.com" Date: Tue, 25 Feb 2025 10:45:16 +0800 Subject: [PATCH] change sleep loop times --- source/client/src/clientStmt.c | 2 +- source/client/src/clientStmt2.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/client/src/clientStmt.c b/source/client/src/clientStmt.c index 279078b759..b16d1e8aac 100644 --- a/source/client/src/clientStmt.c +++ b/source/client/src/clientStmt.c @@ -41,7 +41,7 @@ static FORCE_INLINE int32_t stmtAllocQNodeFromBuf(STableBufInfo* pTblBuf, void** bool stmtDequeue(STscStmt* pStmt, SStmtQNode** param) { int i = 0; while (0 == atomic_load_64((int64_t*)&pStmt->queue.qRemainNum)) { - if (i < 5000) { + if (i < 10) { taosUsleep(1); i++; } else { diff --git a/source/client/src/clientStmt2.c b/source/client/src/clientStmt2.c index 2d5029ca4d..bc8b03ffd4 100644 --- a/source/client/src/clientStmt2.c +++ b/source/client/src/clientStmt2.c @@ -41,7 +41,7 @@ static FORCE_INLINE int32_t stmtAllocQNodeFromBuf(STableBufInfo* pTblBuf, void** static bool stmtDequeue(STscStmt2* pStmt, SStmtQNode** param) { int i = 0; while (0 == atomic_load_64((int64_t*)&pStmt->queue.qRemainNum)) { - if (i < 5000) { + if (i < 10) { taosUsleep(1); i++; } else {