| 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
|
|
|