Fix another variant of flusher sync-waiting stall

epoch-deletions
Vitaliy Filippov 2023-04-24 00:44:10 +03:00
parent 5052174918
commit b74ccb613c
1 changed files with 1 additions and 1 deletions

View File

@ -932,7 +932,7 @@ bool journal_flusher_co::fsync_batch(bool fsync_meta, int wait_base)
resume_1:
if (!cur_sync->state)
{
if (flusher->syncing_flushers >= flusher->cur_flusher_count || !flusher->flush_queue.size())
if (flusher->syncing_flushers >= flusher->active_flushers || !flusher->flush_queue.size())
{
// Sync batch is ready. Do it.
await_sqe(0);