| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "content/browser/memory/memory_state_updater.h" | 5 #include "content/browser/memory/memory_state_updater.h" |
| 6 | 6 |
| 7 #include "base/metrics/histogram_macros.h" | 7 #include "base/metrics/histogram_macros.h" |
| 8 #include "base/strings/string_number_conversions.h" | 8 #include "base/strings/string_number_conversions.h" |
| 9 #include "components/variations/variations_associated_data.h" | 9 #include "components/variations/variations_associated_data.h" |
| 10 #include "content/browser/memory/memory_monitor.h" | 10 #include "content/browser/memory/memory_monitor.h" |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 64 MemoryCoordinatorImpl* coordinator, | 64 MemoryCoordinatorImpl* coordinator, |
| 65 scoped_refptr<base::SingleThreadTaskRunner> task_runner) | 65 scoped_refptr<base::SingleThreadTaskRunner> task_runner) |
| 66 : coordinator_(coordinator), task_runner_(task_runner) { | 66 : coordinator_(coordinator), task_runner_(task_runner) { |
| 67 DCHECK(coordinator_); | 67 DCHECK(coordinator_); |
| 68 InitializeParameters(); | 68 InitializeParameters(); |
| 69 DCHECK(ValidateParameters()); | 69 DCHECK(ValidateParameters()); |
| 70 } | 70 } |
| 71 | 71 |
| 72 MemoryStateUpdater::~MemoryStateUpdater() {} | 72 MemoryStateUpdater::~MemoryStateUpdater() {} |
| 73 | 73 |
| 74 base::MemoryState MemoryStateUpdater::CalculateNextState() { | 74 void MemoryStateUpdater::ScheduleUpdateCondition(base::TimeDelta delta) { |
| 75 using MemoryState = base::MemoryState; | 75 update_condition_closure_.Reset( |
| 76 base::Bind(&MemoryStateUpdater::UpdateCondition, base::Unretained(this))); |
| 77 task_runner_->PostDelayedTask(FROM_HERE, update_condition_closure_.callback(), |
| 78 delta); |
| 79 } |
| 76 | 80 |
| 81 MemoryCondition MemoryStateUpdater::CalculateNextCondition() { |
| 77 int available = | 82 int available = |
| 78 coordinator_->memory_monitor()->GetFreeMemoryUntilCriticalMB(); | 83 coordinator_->memory_monitor()->GetFreeMemoryUntilCriticalMB(); |
| 79 | 84 |
| 80 // TODO(chrisha): Move this histogram recording to a better place when | 85 // TODO(chrisha): Move this histogram recording to a better place when |
| 81 // https://codereview.chromium.org/2479673002/ is landed. | 86 // https://codereview.chromium.org/2479673002/ is landed. |
| 82 UMA_HISTOGRAM_MEMORY_LARGE_MB("Memory.Coordinator.FreeMemoryUntilCritical", | 87 UMA_HISTOGRAM_MEMORY_LARGE_MB("Memory.Coordinator.FreeMemoryUntilCritical", |
| 83 available); | 88 available); |
| 84 | 89 |
| 85 if (available <= 0) | 90 if (available <= 0) |
| 86 return MemoryState::SUSPENDED; | 91 return MemoryCondition::CRITICAL; |
| 87 | 92 |
| 88 auto current_state = coordinator_->GetGlobalMemoryState(); | 93 auto current = coordinator_->GetMemoryCondtion(); |
| 89 int expected_renderer_count = available / expected_renderer_size_; | 94 int expected_renderer_count = available / expected_renderer_size_; |
| 90 | 95 |
| 91 switch (current_state) { | 96 switch (current) { |
| 92 case MemoryState::NORMAL: | 97 case MemoryCondition::NORMAL: |
| 93 if (expected_renderer_count <= new_renderers_until_suspended_) | 98 if (expected_renderer_count <= new_renderers_until_suspended_) |
| 94 return MemoryState::SUSPENDED; | 99 return MemoryCondition::CRITICAL; |
| 95 if (expected_renderer_count <= new_renderers_until_throttled_) | 100 if (expected_renderer_count <= new_renderers_until_throttled_) |
| 96 return MemoryState::THROTTLED; | 101 return MemoryCondition::WARNING; |
| 97 return MemoryState::NORMAL; | 102 return MemoryCondition::NORMAL; |
| 98 case MemoryState::THROTTLED: | 103 case MemoryCondition::WARNING: |
| 99 if (expected_renderer_count <= new_renderers_until_suspended_) | 104 if (expected_renderer_count <= new_renderers_until_suspended_) |
| 100 return MemoryState::SUSPENDED; | 105 return MemoryCondition::CRITICAL; |
| 101 if (expected_renderer_count >= new_renderers_back_to_normal_) | 106 if (expected_renderer_count >= new_renderers_back_to_normal_) |
| 102 return MemoryState::NORMAL; | 107 return MemoryCondition::NORMAL; |
| 103 return MemoryState::THROTTLED; | 108 return MemoryCondition::WARNING; |
| 104 case MemoryState::SUSPENDED: | 109 case MemoryCondition::CRITICAL: |
| 105 if (expected_renderer_count >= new_renderers_back_to_normal_) | 110 if (expected_renderer_count >= new_renderers_back_to_normal_) |
| 106 return MemoryState::NORMAL; | 111 return MemoryCondition::NORMAL; |
| 107 if (expected_renderer_count >= new_renderers_back_to_throttled_) | 112 if (expected_renderer_count >= new_renderers_back_to_throttled_) |
| 108 return MemoryState::THROTTLED; | 113 return MemoryCondition::WARNING; |
| 109 return MemoryState::SUSPENDED; | 114 return MemoryCondition::CRITICAL; |
| 110 case MemoryState::UNKNOWN: | |
| 111 // Fall through | |
| 112 default: | |
| 113 NOTREACHED(); | |
| 114 return MemoryState::UNKNOWN; | |
| 115 } | 115 } |
| 116 } | 116 } |
| 117 | 117 |
| 118 void MemoryStateUpdater::UpdateState() { | 118 void MemoryStateUpdater::UpdateCondition() { |
| 119 auto current_state = coordinator_->GetGlobalMemoryState(); | 119 auto next_condition = CalculateNextCondition(); |
| 120 auto next_state = CalculateNextState(); | 120 coordinator_->UpdateConditionIfNeeded(next_condition); |
| 121 if (coordinator_->ChangeStateIfNeeded(current_state, next_state)) { | 121 ScheduleUpdateCondition(monitoring_interval_); |
| 122 ScheduleUpdateState(minimum_transition_period_); | |
| 123 } else { | |
| 124 ScheduleUpdateState(monitoring_interval_); | |
| 125 } | |
| 126 } | |
| 127 | |
| 128 void MemoryStateUpdater::ScheduleUpdateState(base::TimeDelta delta) { | |
| 129 update_state_closure_.Reset(base::Bind(&MemoryStateUpdater::UpdateState, | |
| 130 base::Unretained(this))); | |
| 131 task_runner_->PostDelayedTask(FROM_HERE, update_state_closure_.callback(), | |
| 132 delta); | |
| 133 } | 122 } |
| 134 | 123 |
| 135 void MemoryStateUpdater::InitializeParameters() { | 124 void MemoryStateUpdater::InitializeParameters() { |
| 136 expected_renderer_size_ = kDefaultExpectedRendererSizeMB; | 125 expected_renderer_size_ = kDefaultExpectedRendererSizeMB; |
| 137 new_renderers_until_throttled_ = kDefaultNewRenderersUntilThrottled; | 126 new_renderers_until_throttled_ = kDefaultNewRenderersUntilThrottled; |
| 138 new_renderers_until_suspended_ = kDefaultNewRenderersUntilSuspended; | 127 new_renderers_until_suspended_ = kDefaultNewRenderersUntilSuspended; |
| 139 new_renderers_back_to_normal_ = kDefaultNewRenderersBackToNormal; | 128 new_renderers_back_to_normal_ = kDefaultNewRenderersBackToNormal; |
| 140 new_renderers_back_to_throttled_ = kDefaultNewRenderersBackToThrottled; | 129 new_renderers_back_to_throttled_ = kDefaultNewRenderersBackToThrottled; |
| 141 minimum_transition_period_ = | 130 minimum_transition_period_ = |
| 142 base::TimeDelta::FromSeconds(kDefaultMinimumTransitionPeriodSeconds); | 131 base::TimeDelta::FromSeconds(kDefaultMinimumTransitionPeriodSeconds); |
| (...skipping 21 matching lines...) Expand all Loading... |
| 164 } | 153 } |
| 165 | 154 |
| 166 bool MemoryStateUpdater::ValidateParameters() { | 155 bool MemoryStateUpdater::ValidateParameters() { |
| 167 return (new_renderers_until_throttled_ > new_renderers_until_suspended_) && | 156 return (new_renderers_until_throttled_ > new_renderers_until_suspended_) && |
| 168 (new_renderers_back_to_normal_ > new_renderers_back_to_throttled_) && | 157 (new_renderers_back_to_normal_ > new_renderers_back_to_throttled_) && |
| 169 (new_renderers_back_to_normal_ > new_renderers_until_throttled_) && | 158 (new_renderers_back_to_normal_ > new_renderers_until_throttled_) && |
| 170 (new_renderers_back_to_throttled_ > new_renderers_until_suspended_); | 159 (new_renderers_back_to_throttled_ > new_renderers_until_suspended_); |
| 171 } | 160 } |
| 172 | 161 |
| 173 } // namespace content | 162 } // namespace content |
| OLD | NEW |