Searched refs:throttle_ (Results 1 – 4 of 4) sorted by relevance
39 GcsThrottleTest() : throttle_(&time_) { in GcsThrottleTest()41 throttle_.SetConfig(config_); in GcsThrottleTest()46 GcsThrottle throttle_; member in tensorflow::__anon3928650c0111::GcsThrottleTest50 EXPECT_EQ(0, throttle_.available_tokens()); in TEST_F()52 EXPECT_EQ(100000, throttle_.available_tokens()); in TEST_F()54 EXPECT_EQ(300000, throttle_.available_tokens()); in TEST_F()58 EXPECT_EQ(0, throttle_.available_tokens()); in TEST_F()60 EXPECT_TRUE(throttle_.AdmitRequest()); in TEST_F()61 EXPECT_EQ(99900, throttle_.available_tokens()); in TEST_F()63 EXPECT_TRUE(throttle_.AdmitRequest()); in TEST_F()[all …]
798 throttle_.SetConfig(config); in GcsFileSystem()876 stats_->Configure(this, &throttle_, file_block_cache_.get()); in ResetFileBlockCache()928 throttle_.RecordResponse(bytes_read); in LoadBufferFromGCS()1646 stats_->Configure(this, &throttle_, file_block_cache_.get()); in SetStats()1682 if (!throttle_.AdmitRequest()) { in CreateHttpRequest()
318 GcsThrottle throttle_; variable
3236 CHECK(throttle_ == nullptr); in Configure()3240 throttle_ = throttle; in Configure()3259 GcsThrottle* throttle_ = nullptr; member in tensorflow::__anon8fbfa37a0111::TestGcsStats