fix review
This commit is contained in:
parent
1e569acc33
commit
09a8a81316
|
@ -53,7 +53,6 @@ bool stmtDequeue(STscStmt* pStmt, SStmtQNode** param) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (pStmt->queue.stopQueue) {
|
if (pStmt->queue.stopQueue) {
|
||||||
(void)taosThreadMutexUnlock(&pStmt->queue.mutex);
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
SStmtQNode* orig = pStmt->queue.head;
|
SStmtQNode* orig = pStmt->queue.head;
|
||||||
|
|
|
@ -53,7 +53,6 @@ static bool stmtDequeue(STscStmt2* pStmt, SStmtQNode** param) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (pStmt->queue.stopQueue) {
|
if (pStmt->queue.stopQueue) {
|
||||||
(void)taosThreadMutexUnlock(&pStmt->queue.mutex);
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
SStmtQNode* orig = pStmt->queue.head;
|
SStmtQNode* orig = pStmt->queue.head;
|
||||||
|
|
Loading…
Reference in New Issue