Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(120)

Unified Diff: net/base/network_throttle_manager_impl_unittest.cc

Issue 2511493002: Revert of Implement THROTTLED priority semantics. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@NetworkStreamThrottler
Patch Set: Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/base/network_throttle_manager_impl.cc ('k') | net/base/percentile_estimator.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/base/network_throttle_manager_impl_unittest.cc
diff --git a/net/base/network_throttle_manager_impl_unittest.cc b/net/base/network_throttle_manager_impl_unittest.cc
deleted file mode 100644
index bc672b2c67975b48def577fe6f5a02fda2947aa6..0000000000000000000000000000000000000000
--- a/net/base/network_throttle_manager_impl_unittest.cc
+++ /dev/null
@@ -1,568 +0,0 @@
-// Copyright 2016 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "net/base/network_throttle_manager_impl.h"
-
-#include <memory>
-
-#include "base/bind.h"
-#include "base/callback.h"
-#include "base/callback_helpers.h"
-#include "base/memory/scoped_vector.h"
-#include "base/run_loop.h"
-#include "base/test/simple_test_tick_clock.h"
-#include "base/test/test_message_loop.h"
-#include "net/base/request_priority.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace net {
-
-namespace {
-
-#include "testing/gtest/include/gtest/gtest.h"
-
-const int kInitialAgeHorizonForUncountedRequests =
- (NetworkThrottleManagerImpl::kInitialMedianInMs *
- NetworkThrottleManagerImpl::kMedianLifetimeMultiple);
-
-// Must be greater than the corresponding fudge factor in
-// network_throttle_manager_impl.cc.
-const int kAgeHorizonFudgeFactor = 20;
-
-// Test fixture for throttle manager tests.
-
-// Note that the manager owned and managed by this fixture has a clock
-// that is set to base::TimeTicks::Now() (which value is also exposed
-// via an accessor) on creation but does not change without
-// intervention by tests (to make the tests more predictable).
-//
-// HOWEVER, also note that that manager uses the base::Timer class, which
-// uses the system clock, which isn't affected by the setting of the
-// test fixture clock. So test should be written to a) avoid situations
-// in which the manager's timer will actually go off based on the system
-// clock, and b) call ConditionallyTriggerTimerForTesting() (which does
-// evaluate the manager's clock) when timer based tests are necessary.
-class NetworkThrottleManagerTest : public testing::Test,
- NetworkThrottleManager::ThrottleDelegate {
- public:
- NetworkThrottleManagerTest()
- : clock_(new base::SimpleTestTickClock),
- now_(base::TimeTicks::Now()),
- throttle_state_change_count_(0),
- last_throttle_to_change_state_(nullptr),
- throttle_manager_(new NetworkThrottleManagerImpl) {
- clock_->SetNowTicks(now_);
- throttle_manager_->SetTickClockForTesting(
- std::unique_ptr<base::TickClock>(clock_));
- }
-
- protected:
- enum ExpectedThrottleBlockState { BLOCKED, UNBLOCKED };
-
- base::TimeTicks now() { return now_; }
- NetworkThrottleManagerImpl* throttle_manager() {
- return throttle_manager_.get();
- }
-
- // Set the offset of the test clock from now_.
- void SetClockDelta(base::TimeDelta time_delta) {
- clock_->SetNowTicks(now_ + time_delta);
- }
-
- // Throttle creation
- std::unique_ptr<NetworkThrottleManager::Throttle> CreateThrottle(
- net::RequestPriority priority,
- ExpectedThrottleBlockState throttle_state) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle(
- throttle_manager_->CreateThrottle(this, priority, false));
- EXPECT_EQ(throttle_state == BLOCKED, throttle->IsBlocked());
- return throttle;
- }
- std::unique_ptr<NetworkThrottleManager::Throttle>
- CreateThrottleIgnoringLimits(net::RequestPriority priority) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle(
- throttle_manager_->CreateThrottle(this, priority, true));
- EXPECT_FALSE(throttle->IsBlocked());
- return throttle;
- }
-
- // Throttle state change information.
- int throttle_state_change_count() { return throttle_state_change_count_; }
- NetworkThrottleManager::Throttle* last_throttle_to_change_state() {
- return last_throttle_to_change_state_;
- }
-
- // Setting a callback to be invoked when a throttle's state changes.
- void SetThrottleStateChangedCallback(const base::Closure& callback) {
- throttle_state_changed_callback_ = callback;
- }
-
- private:
- // NetworkThrottleManager::Delegate
- void OnThrottleUnblocked(
- NetworkThrottleManager::Throttle* throttle) override {
- ++throttle_state_change_count_;
- last_throttle_to_change_state_ = throttle;
- if (!throttle_state_changed_callback_.is_null())
- base::ResetAndReturn(&throttle_state_changed_callback_).Run();
- }
-
- base::SimpleTestTickClock* clock_;
- base::TimeTicks now_;
- int throttle_state_change_count_;
- NetworkThrottleManager::Throttle* last_throttle_to_change_state_;
- std::unique_ptr<NetworkThrottleManagerImpl> throttle_manager_;
- base::Closure throttle_state_changed_callback_;
-
- DISALLOW_COPY_AND_ASSIGN(NetworkThrottleManagerTest);
-};
-
-// Check to confirm that all created throttles at priorities other than
-// THROTTLED start unblocked.
-TEST_F(NetworkThrottleManagerTest, AllUnthrottled) {
- for (int i = MINIMUM_PRIORITY; i <= MAXIMUM_PRIORITY; ++i) {
- if (i == THROTTLED)
- continue;
- CreateThrottle(static_cast<RequestPriority>(i), UNBLOCKED);
- }
-}
-
-// Check for basic semantics around the new THROTTLED level.
-TEST_F(NetworkThrottleManagerTest, ThrottledBlocking) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
-
- throttle1.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle3.get(), last_throttle_to_change_state());
-
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_TRUE(throttle4->IsBlocked());
- EXPECT_TRUE(throttle5->IsBlocked());
-
- throttle2.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(2, throttle_state_change_count());
- EXPECT_EQ(throttle4.get(), last_throttle_to_change_state());
-
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_FALSE(throttle4->IsBlocked());
- EXPECT_TRUE(throttle5->IsBlocked());
-}
-
-// Check that THROTTLED semantics are dependent on all outstanding requests.
-TEST_F(NetworkThrottleManagerTest, ThrottledBlockingMultiPriority) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(HIGHEST, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(LOW, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
-
- throttle1.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(0, throttle_state_change_count());
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_TRUE(throttle4->IsBlocked());
- EXPECT_TRUE(throttle5->IsBlocked());
-
- throttle2.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle4.get(), last_throttle_to_change_state());
-
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_FALSE(throttle4->IsBlocked());
- EXPECT_TRUE(throttle5->IsBlocked());
-
- throttle3.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(2, throttle_state_change_count());
- EXPECT_EQ(throttle5.get(), last_throttle_to_change_state());
-
- EXPECT_FALSE(throttle4->IsBlocked());
- EXPECT_FALSE(throttle5->IsBlocked());
-}
-
-// Check that a SetPriority() away from THROTTLED results in unblocking
-// and an upcall.
-TEST_F(NetworkThrottleManagerTest, ThrottledSetPriority) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
-
- throttle3->SetPriority(LOW);
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle3.get(), last_throttle_to_change_state());
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_TRUE(throttle4->IsBlocked());
-}
-
-void ResetThrottles(bool* function_called,
- ScopedVector<NetworkThrottleManager::Throttle> throttles) {
- *function_called = true;
- // All pointers in the vector should be deleted on exit.
-}
-
-// Check that tearing down all elements in the NTM on a SetPriority
-// upcall doesn't create any problems.
-TEST_F(NetworkThrottleManagerTest, ThrottleTeardown) {
- ScopedVector<NetworkThrottleManager::Throttle> throttles;
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle_temporary;
-
- throttles.push_back(std::unique_ptr<NetworkThrottleManager::Throttle>(
- CreateThrottle(THROTTLED, UNBLOCKED)));
- throttles.push_back(std::unique_ptr<NetworkThrottleManager::Throttle>(
- CreateThrottle(THROTTLED, UNBLOCKED)));
-
- // Note that if there is more than one throttle blocked, then the
- // number of throttle state changes is dependent on destruction order.
- // So only one blocked throttle is created.
- throttle_temporary = CreateThrottle(THROTTLED, BLOCKED);
- NetworkThrottleManager::Throttle* throttle3 = throttle_temporary.get();
- throttles.push_back(std::move(throttle_temporary));
-
- bool callback_called(false);
- SetThrottleStateChangedCallback(
- base::Bind(&ResetThrottles, &callback_called, base::Passed(&throttles)));
-
- EXPECT_EQ(0, throttle_state_change_count());
-
- throttle3->SetPriority(LOW);
-
- // If the test is functioning as expected, throttle3 now points to
- // a deleted object and can no longer be indirected through.
-
- EXPECT_TRUE(callback_called);
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle3, last_throttle_to_change_state());
-}
-
-// Note that this routine is dependent on priority setting *not* resulting in
-// destruction of any throttle and should only be used in tests where that is
-// true.
-void SetAllToPriority(
- RequestPriority priority,
- std::vector<NetworkThrottleManager::Throttle*> throttles) {
- for (size_t i = 0; i < throttles.size(); ++i)
- throttles[i]->SetPriority(priority);
-}
-
-// Check that modifying all the priorities of the allocated throttles in
-// the callback works properly.
-TEST_F(NetworkThrottleManagerTest, ThrottlePriorityReset) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
-
- std::vector<NetworkThrottleManager::Throttle*> throttles;
- throttles.push_back(throttle1.get());
- throttles.push_back(throttle2.get());
- throttles.push_back(throttle3.get());
-
- SetThrottleStateChangedCallback(
- base::Bind(&SetAllToPriority, MEDIUM, base::Passed(&throttles)));
-
- EXPECT_EQ(0, throttle_state_change_count());
- throttle3->SetPriority(HIGHEST);
-
- // Expected result: throttles 1-3 @ medium priority (the callback should
- // have overridden the priority setting above), only throttle 4 blocked
- // (throttle3 should have been unblocked by either of the priority changes),
- // and one state changes (the unblocking).
- EXPECT_EQ(MEDIUM, throttle1->Priority());
- EXPECT_EQ(MEDIUM, throttle2->Priority());
- EXPECT_EQ(MEDIUM, throttle3->Priority());
- EXPECT_EQ(THROTTLED, throttle4->Priority());
- EXPECT_FALSE(throttle1->IsBlocked());
- EXPECT_FALSE(throttle2->IsBlocked());
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_TRUE(throttle4->IsBlocked());
- EXPECT_EQ(1, throttle_state_change_count());
-}
-
-// Check that modifying the priority of a request from a non-THROTTLED
-// value to THROTTLED causes no change in behavior.
-TEST_F(NetworkThrottleManagerTest, ThrottlePriorityResetToThrottled) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(THROTTLED, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(LOW, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
- throttle3->SetPriority(THROTTLED);
- EXPECT_EQ(0, throttle_state_change_count());
-
- EXPECT_FALSE(throttle1->IsBlocked());
- EXPECT_FALSE(throttle2->IsBlocked());
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_TRUE(throttle4->IsBlocked());
-
- EXPECT_EQ(THROTTLED, throttle1->Priority());
- EXPECT_EQ(THROTTLED, throttle2->Priority());
- EXPECT_EQ(THROTTLED, throttle3->Priority());
- EXPECT_EQ(THROTTLED, throttle4->Priority());
-}
-
-// Confirm that old requests don't count against the limit.
-TEST_F(NetworkThrottleManagerTest, DontCountAgedRequests) {
- const int age_in_days_of_old_throttles = 4;
-
- // Confirm default median and timing means that 4 days is long enough ago
- // to be aged out.
- EXPECT_GT(age_in_days_of_old_throttles * 24 * 60 * 60 * 1000,
- kInitialAgeHorizonForUncountedRequests);
-
- SetClockDelta(-base::TimeDelta::FromDays(age_in_days_of_old_throttles));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
-
- SetClockDelta(base::TimeDelta());
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(LOW, UNBLOCKED));
-
- // First throttled request should not be blocked.
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, UNBLOCKED));
-
- // Second should be.
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(THROTTLED, BLOCKED));
-
- // Destroying the old requests should not result in any upcalls.
- EXPECT_EQ(0, throttle_state_change_count());
- throttle1.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(0, throttle_state_change_count());
- throttle2.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(0, throttle_state_change_count());
-
- // But destroying a new request should result in a state change.
- throttle3.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle5.get(), last_throttle_to_change_state());
-}
-
-// Confirm that a slew of throttles of a specific age will shift the
-// median for determining "aged requests" to that age.
-TEST_F(NetworkThrottleManagerTest, ShiftMedian) {
- // Setup two throttles of age *just short* of aging out; confirm
- // they result in blocked THROTTLED requests.
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests - 1));
- EXPECT_FALSE(throttle_manager()->ConditionallyTriggerTimerForTesting());
-
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
-
- throttle1.reset();
- throttle2.reset();
- throttle3.reset();
- base::RunLoop().RunUntilIdle(); // Allow posttasks to run.
-
- // Create 100 throttles and destroy them, effectively with lifetime zero.
- // This should substantially decrease the median age estimate.
- SetClockDelta(base::TimeDelta());
- for (int i = 0; i < 100; ++i) {
- std::unique_ptr<NetworkThrottleManager::Throttle> tmp(
- CreateThrottle(IDLE, UNBLOCKED));
- }
-
- // Clear out any possible leftover timer by setting the clock to a point
- // in the future at which it will definitely go off, and triggering it.
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- 2 * kInitialAgeHorizonForUncountedRequests + kAgeHorizonFudgeFactor));
- throttle_manager()->ConditionallyTriggerTimerForTesting();
-
- // The identical test above should no longer result in blocked throttles.
- SetClockDelta(base::TimeDelta());
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle6(
- CreateThrottle(IDLE, UNBLOCKED));
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests - 1));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle7(
- CreateThrottle(THROTTLED, UNBLOCKED));
-}
-
-// Confirm that just "aging out" requests will result in unblocking
-// blocked requests.
-TEST_F(NetworkThrottleManagerTest, AgeInvalidThrottles) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests + kAgeHorizonFudgeFactor));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle3.get(), last_throttle_to_change_state());
- EXPECT_FALSE(throttle3->IsBlocked());
-}
-
-// Confirm that if throttles are unblocked and made active by all
-// existing outstanding throttles aging out, they will also eventually
-// age out and let new throttles through.
-TEST_F(NetworkThrottleManagerTest, NewlyUnblockedThrottlesAlsoAge) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle6(
- CreateThrottle(THROTTLED, BLOCKED));
-
- // Age the first two throttles out of the outstanding, which should
- // result in the next two throttles becoming unblocked (and in the
- // oustanding list). (The internal implementation will zero out
- // the outstanding queue and then add in the two new unblocked throttles.)
- EXPECT_EQ(0, throttle_state_change_count());
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests + kAgeHorizonFudgeFactor));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(2, throttle_state_change_count());
- EXPECT_FALSE(throttle3->IsBlocked());
- EXPECT_FALSE(throttle4->IsBlocked());
-
- // Age the next two throttles out of the outstanding queue, which
- // should result in the next two throttles becoming unblocked (and
- // in the oustanding list). This will only happen if a timer was properly
- // set in the above age process as the oustanding queue went through
- // the empty state.
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- 2 * (kInitialAgeHorizonForUncountedRequests + kAgeHorizonFudgeFactor)));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(4, throttle_state_change_count());
- EXPECT_FALSE(throttle5->IsBlocked());
- EXPECT_FALSE(throttle6->IsBlocked());
-}
-
-// Confirm that throttles that are blocked for a while and then
-// unblocked don't "age out".
-TEST_F(NetworkThrottleManagerTest, AgeBlockedThrottles) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(THROTTLED, BLOCKED));
-
- EXPECT_EQ(0, throttle_state_change_count());
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests + kAgeHorizonFudgeFactor));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
-
- // If blocked throttles aged out, all three throttles should have been
- // unblocked. If not, only the two replacing the IDLE throttles should
- // have.
- EXPECT_EQ(2, throttle_state_change_count());
-}
-
-// Confirm that deleting old throttles before they age out doesn't
-// interfere with the aging out of more recent throttles.
-TEST_F(NetworkThrottleManagerTest, DeletionAgingInterference) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(THROTTLED, BLOCKED));
- EXPECT_EQ(0, throttle_state_change_count());
-
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- kInitialAgeHorizonForUncountedRequests / 2));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottle(IDLE, UNBLOCKED));
- EXPECT_FALSE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(0, throttle_state_change_count());
-
- throttle1.reset();
- throttle2.reset();
- EXPECT_FALSE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(0, throttle_state_change_count());
-
- SetClockDelta(base::TimeDelta::FromMilliseconds(
- (3 * kInitialAgeHorizonForUncountedRequests / 2 +
- 2 * kAgeHorizonFudgeFactor)));
- EXPECT_TRUE(throttle_manager()->ConditionallyTriggerTimerForTesting());
- EXPECT_EQ(1, throttle_state_change_count());
- EXPECT_EQ(throttle3.get(), last_throttle_to_change_state());
- EXPECT_FALSE(throttle3->IsBlocked());
-}
-
-// Confirm that "ignore_limits" boolean is respected.
-TEST_F(NetworkThrottleManagerTest, IgnoreLimits) {
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle1(
- CreateThrottle(HIGHEST, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle2(
- CreateThrottle(LOW, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle3(
- CreateThrottle(IDLE, UNBLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle4(
- CreateThrottle(THROTTLED, BLOCKED));
- std::unique_ptr<NetworkThrottleManager::Throttle> throttle5(
- CreateThrottleIgnoringLimits(THROTTLED));
-}
-
-} // namespace
-
-} // namespace net
« no previous file with comments | « net/base/network_throttle_manager_impl.cc ('k') | net/base/percentile_estimator.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698