| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 883 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
884 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1377 uint64_t delay = write_controller_.GetDelay(env_, num_bytes); in DelayWrite()
1393 while (write_controller_.NeedsDelay()) { in DelayWrite()
1411 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1436 if (write_controller_.IsStopped()) { in DelayWrite()
1455 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1469 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in rocksdb::WalManagerTest
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 55 &write_controller_, in Init()
110 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 56 &write_buffer_manager_, &write_controller_, in Init()
114 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| H A D | column_family.h | 702 WriteController* write_controller() { return write_controller_; } in write_controller()
733 WriteController* write_controller_; variable
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/db/ |
| H A D | wal_manager_test.cc | 55 &write_buffer_manager_, &write_controller_, in Init()
114 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/rocksdb/rocksdb-6.26.1/db/ |
| H A D | wal_manager_test.cc | 55 &write_buffer_manager_, &write_controller_, in Init()
114 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 56 &write_buffer_manager_, &write_controller_, in Init()
114 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | wal_manager_test.cc | 56 &write_buffer_manager_, &write_controller_, in Init()
114 WriteController write_controller_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 955 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
956 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1481 write_controller_.GetDelay(immutable_db_options_.clock, num_bytes); in DelayWrite()
1499 while (write_controller_.NeedsDelay()) { in DelayWrite()
1517 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1542 if (write_controller_.IsStopped()) { in DelayWrite()
1584 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1598 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 955 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
956 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1481 write_controller_.GetDelay(immutable_db_options_.clock, num_bytes); in DelayWrite()
1499 while (write_controller_.NeedsDelay()) { in DelayWrite()
1517 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1542 if (write_controller_.IsStopped()) { in DelayWrite()
1584 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1598 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/db/db_impl/ |
| H A D | db_impl_write.cc | 957 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
958 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1499 write_controller_.GetDelay(immutable_db_options_.clock, num_bytes); in DelayWrite()
1517 while (write_controller_.NeedsDelay()) { in DelayWrite()
1535 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1560 if (write_controller_.IsStopped()) { in DelayWrite()
1602 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1616 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/rocksdb/rocksdb-6.26.1/db/db_impl/ |
| H A D | db_impl_write.cc | 957 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
958 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1499 write_controller_.GetDelay(immutable_db_options_.clock, num_bytes); in DelayWrite()
1517 while (write_controller_.NeedsDelay()) { in DelayWrite()
1535 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1560 if (write_controller_.IsStopped()) { in DelayWrite()
1602 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1616 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 955 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
956 write_controller_.NeedsDelay()))) { in PreprocessWrite()
1481 write_controller_.GetDelay(immutable_db_options_.clock, num_bytes); in DelayWrite()
1499 while (write_controller_.NeedsDelay()) { in DelayWrite()
1517 while (error_handler_.GetBGError().ok() && write_controller_.IsStopped()) { in DelayWrite()
1542 if (write_controller_.IsStopped()) { in DelayWrite()
1584 if (write_controller_.NeedSpeedupCompaction()) { in ThrottleLowPriWritesIfNeeded()
1598 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
|