Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/memory/tab_manager.h" | 5 #include "chrome/browser/memory/tab_manager.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <map> | 8 #include <map> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| 11 #include "base/callback_helpers.h" | |
| 11 #include "base/logging.h" | 12 #include "base/logging.h" |
| 12 #include "base/macros.h" | 13 #include "base/macros.h" |
| 13 #include "base/memory/ptr_util.h" | 14 #include "base/memory/ptr_util.h" |
| 14 #include "base/metrics/field_trial.h" | 15 #include "base/metrics/field_trial.h" |
| 15 #include "base/strings/string16.h" | 16 #include "base/strings/string16.h" |
| 16 #include "base/test/mock_entropy_provider.h" | 17 #include "base/test/mock_entropy_provider.h" |
| 17 #include "base/test/simple_test_tick_clock.h" | 18 #include "base/test/simple_test_tick_clock.h" |
| 18 #include "base/time/time.h" | 19 #include "base/time/time.h" |
| 19 #include "build/build_config.h" | 20 #include "build/build_config.h" |
| 20 #include "chrome/browser/memory/tab_manager_web_contents_data.h" | 21 #include "chrome/browser/memory/tab_manager_web_contents_data.h" |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 84 WebContents* new_contents_; | 85 WebContents* new_contents_; |
| 85 | 86 |
| 86 DISALLOW_COPY_AND_ASSIGN(MockTabStripModelObserver); | 87 DISALLOW_COPY_AND_ASSIGN(MockTabStripModelObserver); |
| 87 }; | 88 }; |
| 88 | 89 |
| 89 // A mock task runner. This isn't directly a TaskRunner as the reference | 90 // A mock task runner. This isn't directly a TaskRunner as the reference |
| 90 // counting confuses gmock. | 91 // counting confuses gmock. |
| 91 class LenientMockTaskRunner { | 92 class LenientMockTaskRunner { |
| 92 public: | 93 public: |
| 93 LenientMockTaskRunner() {} | 94 LenientMockTaskRunner() {} |
| 94 MOCK_METHOD3(PostDelayedTask, | 95 MOCK_METHOD2(PostDelayedTask, |
| 95 bool(const tracked_objects::Location&, | 96 bool(const tracked_objects::Location&, base::TimeDelta)); |
| 96 const base::Closure&, | 97 |
| 97 base::TimeDelta)); | |
| 98 private: | 98 private: |
| 99 DISALLOW_COPY_AND_ASSIGN(LenientMockTaskRunner); | 99 DISALLOW_COPY_AND_ASSIGN(LenientMockTaskRunner); |
| 100 }; | 100 }; |
| 101 using MockTaskRunner = testing::StrictMock<LenientMockTaskRunner>; | 101 using MockTaskRunner = testing::StrictMock<LenientMockTaskRunner>; |
| 102 | 102 |
| 103 // Represents a pending task. | 103 // Represents a pending task. |
| 104 using Task = std::pair<base::TimeTicks, base::Closure>; | 104 using Task = std::pair<base::TimeTicks, base::Closure>; |
| 105 | 105 |
| 106 // Comparator used for sorting Task objects. Can't use std::pair's default | 106 // Comparator used for sorting Task objects. Can't use std::pair's default |
| 107 // comparison operators because Closure's are comparable. | 107 // comparison operators because Closure's are comparable. |
| 108 struct TaskComparator { | 108 struct TaskComparator { |
| 109 bool operator()(const Task& t1, const Task& t2) const { | 109 bool operator()(const Task& t1, const Task& t2) const { |
| 110 // Reverse the sort order so this can be used with a min-heap. | 110 // Reverse the sort order so this can be used with a min-heap. |
| 111 return t1.first > t2.first; | 111 return t1.first > t2.first; |
| 112 } | 112 } |
| 113 }; | 113 }; |
| 114 | 114 |
| 115 // A TaskRunner implementation that delegates to a MockTaskRunner for asserting | 115 // A TaskRunner implementation that delegates to a MockTaskRunner for asserting |
| 116 // on task insertion order, and which stores tasks for actual later execution. | 116 // on task insertion order, and which stores tasks for actual later execution. |
| 117 class TaskRunnerProxy : public base::TaskRunner { | 117 class TaskRunnerProxy : public base::TaskRunner { |
| 118 public: | 118 public: |
| 119 TaskRunnerProxy(MockTaskRunner* mock, | 119 TaskRunnerProxy(MockTaskRunner* mock, |
| 120 base::SimpleTestTickClock* clock) | 120 base::SimpleTestTickClock* clock) |
| 121 : mock_(mock), clock_(clock) {} | 121 : mock_(mock), clock_(clock) {} |
| 122 bool RunsTasksOnCurrentThread() const override { return true; } | 122 bool RunsTasksOnCurrentThread() const override { return true; } |
| 123 bool PostDelayedTask(const tracked_objects::Location& location, | 123 bool PostDelayedTask(const tracked_objects::Location& location, |
| 124 const base::Closure& closure, | 124 base::Closure closure, |
| 125 base::TimeDelta delta) override { | 125 base::TimeDelta delta) override { |
| 126 mock_->PostDelayedTask(location, closure, delta); | 126 mock_->PostDelayedTask(location, delta); |
| 127 base::TimeTicks when = clock_->NowTicks() + delta; | 127 base::TimeTicks when = clock_->NowTicks() + delta; |
| 128 tasks_.push_back(Task(when, closure)); | 128 tasks_.push_back(Task(when, std::move(closure))); |
| 129 // Use 'greater' comparator to make this a min heap. | 129 // Use 'greater' comparator to make this a min heap. |
| 130 std::push_heap(tasks_.begin(), tasks_.end(), TaskComparator()); | 130 std::push_heap(tasks_.begin(), tasks_.end(), TaskComparator()); |
| 131 return true; | 131 return true; |
| 132 } | 132 } |
| 133 | 133 |
| 134 // Runs tasks up to the current time. Returns the number of tasks executed. | 134 // Runs tasks up to the current time. Returns the number of tasks executed. |
| 135 size_t RunTasks() { | 135 size_t RunTasks() { |
| 136 base::TimeTicks now = clock_->NowTicks(); | 136 base::TimeTicks now = clock_->NowTicks(); |
| 137 size_t count = 0; | 137 size_t count = 0; |
| 138 while (!tasks_.empty() && tasks_.front().first <= now) { | 138 while (!tasks_.empty() && tasks_.front().first <= now) { |
| 139 tasks_.front().second.Run(); | 139 std::move(tasks_.front().second).Run(); |
|
sky
2017/03/22 17:34:11
?
| |
| 140 std::pop_heap(tasks_.begin(), tasks_.end(), TaskComparator()); | 140 std::pop_heap(tasks_.begin(), tasks_.end(), TaskComparator()); |
| 141 tasks_.pop_back(); | 141 tasks_.pop_back(); |
| 142 ++count; | 142 ++count; |
| 143 } | 143 } |
| 144 return count; | 144 return count; |
| 145 } | 145 } |
| 146 | 146 |
| 147 // Advances the clock and runs the next task in the queue. Can run more than | 147 // Advances the clock and runs the next task in the queue. Can run more than |
| 148 // one task if multiple tasks have the same scheduled time. | 148 // one task if multiple tasks have the same scheduled time. |
| 149 size_t RunNextTask() { | 149 size_t RunNextTask() { |
| (...skipping 438 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 588 EXPECT_EQ(0u, tm.notified_renderers_.size()); | 588 EXPECT_EQ(0u, tm.notified_renderers_.size()); |
| 589 | 589 |
| 590 // START OF MEMORY PRESSURE | 590 // START OF MEMORY PRESSURE |
| 591 | 591 |
| 592 // Simulate a memory pressure situation that persists. This should cause a | 592 // Simulate a memory pressure situation that persists. This should cause a |
| 593 // task to be scheduled, and a background renderer to be notified. | 593 // task to be scheduled, and a background renderer to be notified. |
| 594 tm.get_current_pressure_level_ = base::Bind( | 594 tm.get_current_pressure_level_ = base::Bind( |
| 595 &ReturnSpecifiedPressure, base::Unretained(&level)); | 595 &ReturnSpecifiedPressure, base::Unretained(&level)); |
| 596 EXPECT_CALL(mock_task_runner, PostDelayedTask( | 596 EXPECT_CALL(mock_task_runner, PostDelayedTask( |
| 597 testing::_, | 597 testing::_, |
| 598 testing::_, | |
| 599 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); | 598 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); |
| 600 EXPECT_CALL(*this, NotifyRendererProcess(renderer2, level)); | 599 EXPECT_CALL(*this, NotifyRendererProcess(renderer2, level)); |
| 601 tm.OnMemoryPressure(level); | 600 tm.OnMemoryPressure(level); |
| 602 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); | 601 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); |
| 603 testing::Mock::VerifyAndClearExpectations(this); | 602 testing::Mock::VerifyAndClearExpectations(this); |
| 604 EXPECT_TRUE(tm.under_memory_pressure_); | 603 EXPECT_TRUE(tm.under_memory_pressure_); |
| 605 EXPECT_EQ(1u, task_runner->size()); | 604 EXPECT_EQ(1u, task_runner->size()); |
| 606 EXPECT_EQ(1u, tm.notified_renderers_.size()); | 605 EXPECT_EQ(1u, tm.notified_renderers_.size()); |
| 607 EXPECT_EQ(1u, tm.notified_renderers_.count(renderer2)); | 606 EXPECT_EQ(1u, tm.notified_renderers_.count(renderer2)); |
| 608 | 607 |
| 609 // REPEATED MEMORY PRESSURE SIGNAL | 608 // REPEATED MEMORY PRESSURE SIGNAL |
| 610 | 609 |
| 611 // Simulate another memory pressure event. This should not cause any | 610 // Simulate another memory pressure event. This should not cause any |
| 612 // additional tasks to be scheduled, nor any further renderer notifications. | 611 // additional tasks to be scheduled, nor any further renderer notifications. |
| 613 tm.OnMemoryPressure(level); | 612 tm.OnMemoryPressure(level); |
| 614 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); | 613 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); |
| 615 testing::Mock::VerifyAndClearExpectations(this); | 614 testing::Mock::VerifyAndClearExpectations(this); |
| 616 EXPECT_TRUE(tm.under_memory_pressure_); | 615 EXPECT_TRUE(tm.under_memory_pressure_); |
| 617 EXPECT_EQ(1u, task_runner->size()); | 616 EXPECT_EQ(1u, task_runner->size()); |
| 618 EXPECT_EQ(1u, tm.notified_renderers_.size()); | 617 EXPECT_EQ(1u, tm.notified_renderers_.size()); |
| 619 | 618 |
| 620 // FIRST SCHEDULED NOTIFICATION | 619 // FIRST SCHEDULED NOTIFICATION |
| 621 | 620 |
| 622 // Run the scheduled task. This should cause another notification, but this | 621 // Run the scheduled task. This should cause another notification, but this |
| 623 // time to the foreground tab. It should also cause another scheduled event. | 622 // time to the foreground tab. It should also cause another scheduled event. |
| 624 EXPECT_CALL(mock_task_runner, PostDelayedTask( | 623 EXPECT_CALL(mock_task_runner, PostDelayedTask( |
| 625 testing::_, | 624 testing::_, |
| 626 testing::_, | |
| 627 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); | 625 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); |
| 628 EXPECT_CALL(*this, NotifyRendererProcess(renderer1, level)); | 626 EXPECT_CALL(*this, NotifyRendererProcess(renderer1, level)); |
| 629 EXPECT_EQ(1u, task_runner->RunNextTask()); | 627 EXPECT_EQ(1u, task_runner->RunNextTask()); |
| 630 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); | 628 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); |
| 631 testing::Mock::VerifyAndClearExpectations(this); | 629 testing::Mock::VerifyAndClearExpectations(this); |
| 632 EXPECT_TRUE(tm.under_memory_pressure_); | 630 EXPECT_TRUE(tm.under_memory_pressure_); |
| 633 EXPECT_EQ(1u, task_runner->size()); | 631 EXPECT_EQ(1u, task_runner->size()); |
| 634 EXPECT_EQ(2u, tm.notified_renderers_.size()); | 632 EXPECT_EQ(2u, tm.notified_renderers_.size()); |
| 635 EXPECT_EQ(1u, tm.notified_renderers_.count(renderer1)); | 633 EXPECT_EQ(1u, tm.notified_renderers_.count(renderer1)); |
| 636 | 634 |
| 637 // SECOND SCHEDULED NOTIFICATION | 635 // SECOND SCHEDULED NOTIFICATION |
| 638 | 636 |
| 639 // Run the scheduled task. This should cause another notification, to the | 637 // Run the scheduled task. This should cause another notification, to the |
| 640 // background tab. It should also cause another scheduled event. | 638 // background tab. It should also cause another scheduled event. |
| 641 EXPECT_CALL(mock_task_runner, PostDelayedTask( | 639 EXPECT_CALL(mock_task_runner, PostDelayedTask( |
| 642 testing::_, | 640 testing::_, |
| 643 testing::_, | |
| 644 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); | 641 base::TimeDelta::FromSeconds(tm.kRendererNotificationDelayInSeconds))); |
| 645 EXPECT_CALL(*this, NotifyRendererProcess(renderer2, level)); | 642 EXPECT_CALL(*this, NotifyRendererProcess(renderer2, level)); |
| 646 EXPECT_EQ(1u, task_runner->RunNextTask()); | 643 EXPECT_EQ(1u, task_runner->RunNextTask()); |
| 647 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); | 644 testing::Mock::VerifyAndClearExpectations(&mock_task_runner); |
| 648 testing::Mock::VerifyAndClearExpectations(this); | 645 testing::Mock::VerifyAndClearExpectations(this); |
| 649 EXPECT_TRUE(tm.under_memory_pressure_); | 646 EXPECT_TRUE(tm.under_memory_pressure_); |
| 650 EXPECT_EQ(1u, task_runner->size()); | 647 EXPECT_EQ(1u, task_runner->size()); |
| 651 EXPECT_EQ(1u, tm.notified_renderers_.size()); | 648 EXPECT_EQ(1u, tm.notified_renderers_.size()); |
| 652 | 649 |
| 653 // Expect that the background tab has been notified. The list of notified | 650 // Expect that the background tab has been notified. The list of notified |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 748 // Since tab2 is kept inactive and background for more than time-to-purge, | 745 // Since tab2 is kept inactive and background for more than time-to-purge, |
| 749 // tab2 should be purged. | 746 // tab2 should be purged. |
| 750 EXPECT_TRUE(tab_manager.GetWebContentsData(tab2)->is_purged()); | 747 EXPECT_TRUE(tab_manager.GetWebContentsData(tab2)->is_purged()); |
| 751 | 748 |
| 752 // Activate tab2. Tab2's PurgeAndSuspend state should be NOT_PURGED. | 749 // Activate tab2. Tab2's PurgeAndSuspend state should be NOT_PURGED. |
| 753 tabstrip.ActivateTabAt(1, true /* user_gesture */); | 750 tabstrip.ActivateTabAt(1, true /* user_gesture */); |
| 754 EXPECT_FALSE(tab_manager.GetWebContentsData(tab2)->is_purged()); | 751 EXPECT_FALSE(tab_manager.GetWebContentsData(tab2)->is_purged()); |
| 755 } | 752 } |
| 756 | 753 |
| 757 } // namespace memory | 754 } // namespace memory |
| OLD | NEW |