Stop flushing when less than min_flusher_count operations are available (unless a trim is forced)

2021-04-03 00:53:28 +03:00
parent e1355cbc74
commit 52097c4856
1 changed files with 2 additions and 1 deletions
@@ -238,7 +238,8 @@ bool journal_flusher_co::loop()
    else if (wait_state == 21)
        goto resume_21;
 resume_0:
-    if (!flusher->flush_queue.size() || !flusher->dequeuing)
+    if (flusher->flush_queue.size() < flusher->min_flusher_count && !flusher->trim_wanted ||
+        !flusher->flush_queue.size() || !flusher->dequeuing)
    {
 stop_flusher:
        if (flusher->trim_wanted > 0 && flusher->journal_trim_counter > 0)