xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

change sleep loop times

This commit is contained in:
pengrongkun94@qq.com 2025-02-25 10:45:16 +08:00
parent cbd9504e8f
commit 1e569acc33
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/client/src/clientStmt.c
View File

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

2
source/client/src/clientStmt2.c
View File

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