Searched refs:limiter (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/util/ |
| D | rate_limiter_test.cc | 28 GenericRateLimiter limiter(port::kMaxInt64, 1000, 10, in TEST_F() local
31 ASSERT_GT(limiter.GetSingleBurstBytes(), 1000000000ll); in TEST_F()
41 GenericRateLimiter limiter( in TEST_F() local
47 ASSERT_EQ(0, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
49 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F() member
101 arg.limiter->SetBytesPerSecond(target); in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F() member
151 std::shared_ptr<RateLimiter> limiter = in TEST_F() local
160 Arg arg(target, Env::IO_HIGH, limiter); in TEST_F()
[all …]
|
| D | concurrent_task_limiter_impl.h | 55 explicit TaskLimiterToken(ConcurrentTaskLimiterImpl* limiter) in TaskLimiterToken() argument
56 : limiter_(limiter) {} in TaskLimiterToken()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-12-18-17-auto-tuned-rate-limiter.markdown | 10 …limiter has been hard to configure since users need to pick a value that is low enough to prevent …
12 To address this, in RocksDB 5.9 we released a dynamic rate limiter that adjusts itself over time ac…
16 …asure demand for background I/O as the ratio of intervals where the rate limiter is drained. There…
20 Data is ingested at 10MB/s and the rate limiter was created with 1000MB/s as its upper bound. The d…
22 
24 
26 … p90 - p100 for background write rate are significantly lower with auto-tuned rate limiter enabled.
28 
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | rules.ini | 118 suggestions=bytes-per-sync-non0:wal-bytes-per-sync-non0:set-rate-limiter
151 [Suggestion "set-rate-limiter"]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 65 auto limiter = static_cast<ConcurrentTaskLimiterImpl*>( in RequestCompactionToken() local
67 if (limiter == nullptr) { in RequestCompactionToken()
70 *token = limiter->GetToken(force); in RequestCompactionToken()
75 limiter->GetName().c_str(), cfd->GetName().c_str(), in RequestCompactionToken()
76 force ? "true" : "false", limiter->GetOutstandingTask()); in RequestCompactionToken()
|
| /rocksdb-6.9/db/ |
| D | c.cc | 2742 void rocksdb_options_set_ratelimiter(rocksdb_options_t *opt, rocksdb_ratelimiter_t *limiter) { in rocksdb_options_set_ratelimiter() argument
2743 if (limiter) { in rocksdb_options_set_ratelimiter()
2744 opt->rep.rate_limiter = limiter->rep; in rocksdb_options_set_ratelimiter()
2764 void rocksdb_ratelimiter_destroy(rocksdb_ratelimiter_t *limiter) { in rocksdb_ratelimiter_destroy() argument
2765 delete limiter; in rocksdb_ratelimiter_destroy()
|
| D | db_compaction_test.cc | 4516 std::shared_ptr<ConcurrentTaskLimiter> limiter; in TEST_F() member
4525 ls.limiter.reset(NewConcurrentTaskLimiter(ls.name, ls.limit_tasks)); in TEST_F()
4564 cf_opt.compaction_thread_limiter = ls.limiter; in TEST_F()
4672 ASSERT_EQ(0, ls.limiter->GetOutstandingTask()); in TEST_F()
|
| /rocksdb-6.9/ |
| D | WINDOWS_PORT.md | 68 …t within the posix_env which includes memory mapped files, random access, rate-limiter support etc.
|
| /rocksdb-6.9/include/rocksdb/ |
| D | c.h | 1046 rocksdb_options_t* opt, rocksdb_ratelimiter_t* limiter);
|