diff --git a/flusher.cc b/flusher.cc index c7f7aeed9..213d791d1 100644 --- a/flusher.cc +++ b/flusher.cc @@ -144,15 +144,11 @@ bool Flusher::step(Dispatcher &d, TaskId tid) { case running: { int n = doFlush(); - if (n > 0) { - if (_state == running) { - d.snooze(tid, n); - return true; - } else { - return false; - } - } else { + if (_state == running) { + d.snooze(tid, std::max(n, 1)); return true; + } else { + return false; } } case stopping: