diff --git a/db/batchlog_manager.cc b/db/batchlog_manager.cc index ce9c8f38a2..796262bba1 100644 --- a/db/batchlog_manager.cc +++ b/db/batchlog_manager.cc @@ -115,10 +115,12 @@ future<> db::batchlog_manager::start() { } future<> db::batchlog_manager::drain() { - blogger.info("Asked to drain"); - if (!_stop.abort_requested()) { - _stop.request_abort(); + if (_stop.abort_requested()) { + co_return; } + + blogger.info("Asked to drain"); + _stop.request_abort(); if (this_shard_id() == 0) { // Abort do_batch_log_replay if waiting on the semaphore. _sem.broken();