Lines Matching refs:limiter

28   GenericRateLimiter limiter(port::kMaxInt64, 1000, 10,  in TEST_F()  local
31 ASSERT_GT(limiter.GetSingleBurstBytes(), 1000000000ll); in TEST_F()
35 std::unique_ptr<RateLimiter> limiter(NewGenericRateLimiter(100, 100, 10)); in TEST_F() local
41 GenericRateLimiter limiter( in TEST_F() local
44 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()
47 ASSERT_EQ(0, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
49 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
52 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()
55 ASSERT_EQ(2000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
57 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
67 : limiter(NewGenericRateLimiter(_target_rate, 100 * 1000, 10)), in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F() member
84 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, in TEST_F()
88 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, Env::IO_LOW, in TEST_F()
101 arg.limiter->SetBytesPerSecond(target); in TEST_F()
111 (arg.limiter->GetTotalBytesThrough() - old_total_bytes_through) * in TEST_F()
113 old_total_bytes_through = arg.limiter->GetTotalBytesThrough(); in TEST_F()
135 : request_size(_request_size), pri(_pri), limiter(_limiter) {} in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F() member
143 arg->limiter->Request(arg->request_size, arg->pri, nullptr /* stats */, in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F() local
160 Arg arg(target, Env::IO_HIGH, limiter); in TEST_F()
168 arg.limiter->SetBytesPerSecond(new_limit); in TEST_F()