Searched refs:NewGenericRateLimiter (Results 1 – 16 of 16) sorted by relevance
35 std::unique_ptr<RateLimiter> limiter(NewGenericRateLimiter(100, 100, 10)); in TEST_F()67 : limiter(NewGenericRateLimiter(_target_rate, 100 * 1000, 10)), in TEST_F()
327 RateLimiter* NewGenericRateLimiter( in NewGenericRateLimiter() function
25 ROCKSDB_NAMESPACE::NewGenericRateLimiter( in Java_org_rocksdb_RateLimiter_newRateLimiterHandle()
133 extern RateLimiter* NewGenericRateLimiter(
33 NewGenericRateLimiter(low_pri_rate_bytes_per_sec)) {
606 options.rate_limiter.reset(NewGenericRateLimiter(31 * 1024 * 1024)); in TEST_F()
87 using ROCKSDB_NAMESPACE::NewGenericRateLimiter;2759 NewGenericRateLimiter(rate_bytes_per_sec, in rocksdb_ratelimiter_create()
3705 NewGenericRateLimiter(static_cast<int64_t>(0.7 * raw_rate))); in TEST_F()3731 NewGenericRateLimiter(static_cast<int64_t>(raw_rate / 2))); in TEST_F()
2870 options.rate_limiter.reset(NewGenericRateLimiter( in TEST_F()
12 …/O. It can be enabled simply by passing `auto_tuned=true` in the `NewGenericRateLimiter()` call. I…
3334 NewGenericRateLimiter(FLAGS_benchmark_write_rate_limit)); in RunBenchmark()3337 shared.read_rate_limiter.reset(NewGenericRateLimiter( in RunBenchmark()4054 options.rate_limiter.reset(NewGenericRateLimiter( in InitializeOptionsGeneral()4513 NewGenericRateLimiter(write_rate)); in DoWrite()5447 thread->shared->read_rate_limiter.reset(NewGenericRateLimiter( in MixGraph()5451 NewGenericRateLimiter(static_cast<int64_t>(write_rate))); in MixGraph()5504 NewGenericRateLimiter(static_cast<int64_t>(write_rate))); in MixGraph()5505 thread->shared->read_rate_limiter.reset(NewGenericRateLimiter( in MixGraph()5816 NewGenericRateLimiter(FLAGS_benchmark_write_rate_limit)); in BGWriter()6773 NewGenericRateLimiter(FLAGS_benchmark_write_rate_limit)); in TimeSeriesWrite()
1394 std::shared_ptr<RateLimiter> backupThrottler(NewGenericRateLimiter(1)); in TEST_F()1395 std::shared_ptr<RateLimiter> restoreThrottler(NewGenericRateLimiter(1)); in TEST_F()
552 NewGenericRateLimiter(options_.backup_rate_limit)); in BackupEngineImpl()557 NewGenericRateLimiter(options_.restore_rate_limit)); in BackupEngineImpl()
1845 options_.rate_limiter.reset(NewGenericRateLimiter( in Open()
1197 NewGenericRateLimiter(static_cast<int64_t>(ParseUint64(value)))); in ParseDBOption()
567 …an be enabled by passing `true` to the `auto_tuned` parameter in `NewGenericRateLimiter()`. The va…