This commit is contained in:
Liang Ding
2022-11-22 10:38:13 +08:00
parent 31be236557
commit 8652c4cef7
2 changed files with 7 additions and 1 deletions

View File

@@ -81,6 +81,10 @@ func isWritingDatabase() bool {
return false
}
func IsEmptyQueue() bool {
return 1 > len(operationQueue) && !util.IsMutexLocked(&txLock)
}
func flushTreeQueue() {
ops := mergeUpsertTrees()
if 1 > len(ops) {