| /rocksdb-6.9/util/ |
| D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| D | rate_limiter.cc | 19 size_t RateLimiter::RequestToken(size_t bytes, size_t alignment, in RequestToken()
21 RateLimiter::OpType op_type) { in RequestToken()
48 int32_t fairness, RateLimiter::Mode mode, in GenericRateLimiter()
50 : RateLimiter(mode), in GenericRateLimiter()
327 RateLimiter* NewGenericRateLimiter( in NewGenericRateLimiter()
330 RateLimiter::Mode mode /* = RateLimiter::Mode::kWritesOnly */, in NewGenericRateLimiter()
|
| D | rate_limiter.h | 24 class GenericRateLimiter : public RateLimiter {
27 int32_t fairness, RateLimiter::Mode mode, Env* env,
38 using RateLimiter::Request;
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| D | EnvOptionsTest.java | 135 final RateLimiter rateLimiter1 = new RateLimiter(1000, 100 * 1000, 1)) { in rateLimiter()
139 try(final RateLimiter rateLimiter2 = new RateLimiter(1000)) { in rateLimiter()
|
| D | BackupableDBOptionsTest.java | 142 try(final RateLimiter backupRateLimiter = in backupRateLimiter()
143 new RateLimiter(999)) { in backupRateLimiter()
173 try(final RateLimiter restoreRateLimiter = in restoreRateLimiter()
174 new RateLimiter(911)) { in restoreRateLimiter()
|
| D | DBOptionsTest.java | 783 final RateLimiter rateLimiter = new RateLimiter(1000, 100 * 1000, 1)) { in rateLimiter()
787 new RateLimiter(1000)); in rateLimiter()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | rate_limiter.h | 17 class RateLimiter {
32 explicit RateLimiter(Mode mode = Mode::kWritesOnly) : mode_(mode) {} in mode_()
34 virtual ~RateLimiter() {} in ~RateLimiter()
79 RateLimiter::OpType op_type);
95 if ((mode_ == RateLimiter::Mode::kWritesOnly && in IsRateLimited()
96 op_type == RateLimiter::OpType::kRead) || in IsRateLimited()
97 (mode_ == RateLimiter::Mode::kReadsOnly && in IsRateLimited()
98 op_type == RateLimiter::OpType::kWrite)) { in IsRateLimited()
133 extern RateLimiter* NewGenericRateLimiter(
136 RateLimiter::Mode mode = RateLimiter::Mode::kWritesOnly,
|
| D | options.h | 47 class RateLimiter; variable
410 std::shared_ptr<RateLimiter> rate_limiter = nullptr;
|
| /rocksdb-6.9/java/rocksjni/ |
| D | ratelimiterjni.cc | 24 auto* sptr_rate_limiter = new std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>( in Java_org_rocksdb_RateLimiter_newRateLimiterHandle()
42 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_RateLimiter_disposeInternal()
56 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>(handle) in Java_org_rocksdb_RateLimiter_setBytesPerSecond()
69 return reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_RateLimiter_getBytesPerSecond()
82 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>(handle) in Java_org_rocksdb_RateLimiter_request()
95 return reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_RateLimiter_getSingleBurstBytes()
109 return reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_RateLimiter_getTotalBytesThrough()
123 return reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_RateLimiter_getTotalRequests()
|
| D | backupablejni.cc | 229 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_BackupableDBOptions_setBackupRateLimiter()
271 reinterpret_cast<std::shared_ptr<ROCKSDB_NAMESPACE::RateLimiter>*>( in Java_org_rocksdb_BackupableDBOptions_setRestoreRateLimiter()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | RateLimiter.java | 14 public class RateLimiter extends RocksObject { class
30 public RateLimiter(final long rateBytesPerSecond) { in RateLimiter() method in RateLimiter
50 public RateLimiter(final long rateBytesPerSecond, in RateLimiter() method in RateLimiter
79 public RateLimiter(final long rateBytesPerSecond, in RateLimiter() method in RateLimiter
110 public RateLimiter(final long rateBytesPerSecond, in RateLimiter() method in RateLimiter
145 public RateLimiter(final long rateBytesPerSecond, in RateLimiter() method in RateLimiter
|
| D | BackupableDBOptions.java | 23 private RateLimiter backupRateLimiter = null;
24 private RateLimiter restoreRateLimiter = null;
264 public BackupableDBOptions setBackupRateLimiter(final RateLimiter backupRateLimiter) { in setBackupRateLimiter()
279 public RateLimiter backupRateLimiter() { in backupRateLimiter()
322 public BackupableDBOptions setRestoreRateLimiter(final RateLimiter restoreRateLimiter) { in setRestoreRateLimiter()
337 public RateLimiter restoreRateLimiter() { in restoreRateLimiter()
|
| D | EnvOptions.java | 310 public EnvOptions setRateLimiter(final RateLimiter rateLimiter) { in setRateLimiter()
321 public RateLimiter rateLimiter() { in rateLimiter()
365 private RateLimiter rateLimiter;
|
| D | DBOptionsInterface.java | 158 T setRateLimiter(RateLimiter rateLimiter); in setRateLimiter()
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.cc | 52 Env::IOPriority::IO_LOW, stats_, RateLimiter::OpType::kRead); in Read()
99 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()
104 RateLimiter::OpType::kRead); in Read()
105 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()
|
| D | random_access_file_reader.h | 59 RateLimiter* rate_limiter_;
67 RateLimiter* rate_limiter = nullptr,
|
| D | writable_file_writer.cc | 303 RateLimiter::OpType::kWrite); in WriteBuffered()
390 stats_, RateLimiter::OpType::kWrite); in WriteDirect()
|
| D | writable_file_writer.h | 72 RateLimiter* rate_limiter_;
|
| /rocksdb-6.9/db/ |
| D | write_controller.h | 85 RateLimiter* low_pri_rate_limiter() { return low_pri_rate_limiter_.get(); } in low_pri_rate_limiter()
105 std::unique_ptr<RateLimiter> low_pri_rate_limiter_;
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | backupable_db.h | 78 std::shared_ptr<RateLimiter> backup_rate_limiter{nullptr};
88 std::shared_ptr<RateLimiter> restore_rate_limiter{nullptr};
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 317 bool sync, RateLimiter* rate_limiter,
344 RateLimiter* rate_limiter;
385 RateLimiter* _rate_limiter, uint64_t _size_limit, in CopyOrCreateWorkItem()
491 const EnvOptions& src_env_options, RateLimiter* rate_limiter,
831 RateLimiter* rate_limiter = options_.backup_rate_limiter.get(); in CreateNewBackupWithMetadata()
1189 RateLimiter* rate_limiter = options_.restore_rate_limiter.get(); in RestoreDBFromBackup()
1298 RateLimiter* rate_limiter, uint64_t* size, uint32_t* checksum_value, in CopyOrCreateFile()
1368 RateLimiter::OpType::kWrite); in CopyOrCreateFile()
1392 RateLimiter* rate_limiter, uint64_t size_bytes, uint64_t size_limit, in AddBackupFileWorkItem()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 2221 std::shared_ptr<RateLimiter> write_rate_limiter;
2222 std::shared_ptr<RateLimiter> read_rate_limiter;
3339 10 /* fairness */, RateLimiter::Mode::kReadsOnly)); in RunBenchmark()
5180 RateLimiter::OpType::kRead); in MultiReadRandom()
5449 RateLimiter::Mode::kReadsOnly)); in MixGraph()
5508 RateLimiter::Mode::kReadsOnly)); in MixGraph()
5537 RateLimiter::OpType::kRead); in MixGraph()
5561 RateLimiter::OpType::kWrite); in MixGraph()
5813 std::unique_ptr<RateLimiter> write_rate_limiter; in BGWriter()
6158 RateLimiter::OpType::kWrite); in UpdateRandom()
[all …]
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | RocksDBSample.java | 35 final RateLimiter rateLimiter = new RateLimiter(10000000,10000, 10)) { in main()
|
| /rocksdb-6.9/options/ |
| D | db_options.h | 27 std::shared_ptr<RateLimiter> rate_limiter;
|