Home
last modified time | relevance | path

Searched refs:write_controller_ (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc911 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
912 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1405 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1421 while (write_controller_.NeedsDelay()) { in DelayWrite()
1439 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1464 if (write_controller_.IsStopped()) { in DelayWrite()
1483 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1497 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
Ddb_impl.h708 const WriteController& write_controller() { return write_controller_; } in write_controller()
952 WriteController& TEST_write_controler() { return write_controller_; } in TEST_write_controler()
1880 WriteController write_controller_; variable
Ddb_impl_secondary.cc613 &impl->write_controller_)); in OpenAsSecondary()
Ddb_impl.cc180 write_controller_(mutable_db_options_.delayed_write_rate), in DBImpl()
247 &write_controller_, &block_cache_tracer_)); in DBImpl()
1074 write_controller_.set_max_delayed_write_rate( in SetDBOptions()
Ddb_impl_compaction_flush.cc2036 write_controller_.NeedSpeedupCompaction()); in GetBGJobLimits()
/rocksdb-6.9/db/
Dwal_manager_test.cc55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
Dcolumn_family.h683 WriteController* write_controller() { return write_controller_; } in write_controller()
714 WriteController* write_controller_; variable
Dflush_job_test.cc58 &write_controller_,
122 WriteController write_controller_; member in ROCKSDB_NAMESPACE::FlushJobTest
Dcolumn_family.cc853 auto write_controller = column_family_set_->write_controller_; in RecalculateWriteStallConditions()
1414 write_controller_(_write_controller), in ColumnFamilySet()
Dversion_set_test.cc652 &write_controller_, in VersionSetTestBase()
656 &write_buffer_manager_, &write_controller_); in VersionSetTestBase()
776 WriteController write_controller_; member in ROCKSDB_NAMESPACE::VersionSetTestBase
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc83 &write_controller_, in CompactionJobTest()
253 &write_controller_, in NewDB()
374 WriteController write_controller_; member in ROCKSDB_NAMESPACE::CompactionJobTest