We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2bb49eb commit 29e91cbCopy full SHA for 29e91cb
db/db_impl/db_impl.cc
@@ -550,7 +550,9 @@ void DBImpl::CancelAllBackgroundWork(bool wait) {
550
if (!shutting_down_.load(std::memory_order_acquire) &&
551
has_unpersisted_data_.load(std::memory_order_relaxed) &&
552
!mutable_db_options_.avoid_flush_during_shutdown) {
553
- s = DBImpl::FlushAllColumnFamilies(FlushOptions(), FlushReason::kShutDown);
+ auto flush_options = FlushOptions();
554
+ flush_options.allow_write_stall = true;
555
+ s = DBImpl::FlushAllColumnFamilies(flush_options, FlushReason::kShutDown);
556
s.PermitUncheckedError(); //**TODO: What to do on error?
557
}
558
0 commit comments