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

Side by Side Diff: components/scheduler/child/idle_helper.cc

Issue 1151353003: [scheduler]: Avoid waking up the scheduler to end long idle periods. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@end_idle_sync_2
Patch Set: Fix tests and update for review. Created 5 years, 6 months 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 unified diff | Download patch
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 "components/scheduler/child/idle_helper.h" 5 #include "components/scheduler/child/idle_helper.h"
6 6
7 #include "base/trace_event/trace_event.h" 7 #include "base/trace_event/trace_event.h"
8 #include "base/trace_event/trace_event_argument.h" 8 #include "base/trace_event/trace_event_argument.h"
9 #include "components/scheduler/child/scheduler_helper.h" 9 #include "components/scheduler/child/scheduler_helper.h"
10 10
11 namespace scheduler { 11 namespace scheduler {
12 12
13 IdleHelper::IdleHelper( 13 IdleHelper::IdleHelper(
14 SchedulerHelper* helper, 14 SchedulerHelper* helper,
15 Delegate* delegate, 15 Delegate* delegate,
16 size_t idle_queue_index, 16 size_t idle_queue_index,
17 const char* tracing_category, 17 const char* tracing_category,
18 const char* disabled_by_default_tracing_category, 18 const char* disabled_by_default_tracing_category,
19 const char* idle_period_tracing_name, 19 const char* idle_period_tracing_name,
20 base::TimeDelta required_quiescence_duration_before_long_idle_period) 20 base::TimeDelta required_quiescence_duration_before_long_idle_period)
21 : helper_(helper), 21 : helper_(helper),
22 delegate_(delegate), 22 delegate_(delegate),
23 idle_queue_index_(idle_queue_index), 23 idle_queue_index_(idle_queue_index),
24 idle_period_state_(IdlePeriodState::NOT_IN_IDLE_PERIOD), 24 state_(helper,
25 tracing_category,
26 disabled_by_default_tracing_category,
27 idle_period_tracing_name),
25 quiescence_monitored_task_queue_mask_( 28 quiescence_monitored_task_queue_mask_(
26 helper_->GetQuiescenceMonitoredTaskQueueMask() & 29 helper_->GetQuiescenceMonitoredTaskQueueMask() &
27 ~(1ull << idle_queue_index_)), 30 ~(1ull << idle_queue_index_)),
28 required_quiescence_duration_before_long_idle_period_( 31 required_quiescence_duration_before_long_idle_period_(
29 required_quiescence_duration_before_long_idle_period), 32 required_quiescence_duration_before_long_idle_period),
30 tracing_category_(tracing_category),
31 disabled_by_default_tracing_category_( 33 disabled_by_default_tracing_category_(
32 disabled_by_default_tracing_category), 34 disabled_by_default_tracing_category),
33 idle_period_tracing_name_(idle_period_tracing_name),
34 weak_factory_(this) { 35 weak_factory_(this) {
35 weak_idle_helper_ptr_ = weak_factory_.GetWeakPtr(); 36 weak_idle_helper_ptr_ = weak_factory_.GetWeakPtr();
36 end_idle_period_closure_.Reset(
37 base::Bind(&IdleHelper::EndIdlePeriod, weak_idle_helper_ptr_));
38 enable_next_long_idle_period_closure_.Reset( 37 enable_next_long_idle_period_closure_.Reset(
39 base::Bind(&IdleHelper::EnableLongIdlePeriod, weak_idle_helper_ptr_)); 38 base::Bind(&IdleHelper::EnableLongIdlePeriod, weak_idle_helper_ptr_));
40 enable_next_long_idle_period_after_wakeup_closure_.Reset(base::Bind(
41 &IdleHelper::EnableLongIdlePeriodAfterWakeup, weak_idle_helper_ptr_));
42 39
43 idle_task_runner_ = make_scoped_refptr(new SingleThreadIdleTaskRunner( 40 idle_task_runner_ = make_scoped_refptr(new SingleThreadIdleTaskRunner(
44 helper_->TaskRunnerForQueue(idle_queue_index_), 41 helper_->TaskRunnerForQueue(idle_queue_index_),
45 helper_->ControlAfterWakeUpTaskRunner(), 42 helper_->ControlAfterWakeUpTaskRunner(), this, tracing_category));
46 base::Bind(&IdleHelper::CurrentIdleTaskDeadlineCallback,
47 weak_idle_helper_ptr_),
48 tracing_category));
49 43
50 helper_->DisableQueue(idle_queue_index_); 44 helper_->DisableQueue(idle_queue_index_);
51 helper_->SetPumpPolicy(idle_queue_index_, 45 helper_->SetPumpPolicy(idle_queue_index_,
52 TaskQueueManager::PumpPolicy::MANUAL); 46 TaskQueueManager::PumpPolicy::MANUAL);
47
48 helper_->AddTaskObserver(this);
53 } 49 }
54 50
55 IdleHelper::~IdleHelper() { 51 IdleHelper::~IdleHelper() {
52 helper_->RemoveTaskObserver(this);
56 } 53 }
57 54
58 IdleHelper::Delegate::Delegate() { 55 IdleHelper::Delegate::Delegate() {
59 } 56 }
60 57
61 IdleHelper::Delegate::~Delegate() { 58 IdleHelper::Delegate::~Delegate() {
62 } 59 }
63 60
64 scoped_refptr<SingleThreadIdleTaskRunner> IdleHelper::IdleTaskRunner() { 61 scoped_refptr<SingleThreadIdleTaskRunner> IdleHelper::IdleTaskRunner() {
65 helper_->CheckOnValidThread(); 62 helper_->CheckOnValidThread();
66 return idle_task_runner_; 63 return idle_task_runner_;
67 } 64 }
68 65
69 void IdleHelper::CurrentIdleTaskDeadlineCallback(
70 base::TimeTicks* deadline_out) const {
71 helper_->CheckOnValidThread();
72 *deadline_out = idle_period_deadline_;
73 }
74
75 IdleHelper::IdlePeriodState IdleHelper::ComputeNewLongIdlePeriodState( 66 IdleHelper::IdlePeriodState IdleHelper::ComputeNewLongIdlePeriodState(
76 const base::TimeTicks now, 67 const base::TimeTicks now,
77 base::TimeDelta* next_long_idle_period_delay_out) { 68 base::TimeDelta* next_long_idle_period_delay_out) {
78 helper_->CheckOnValidThread(); 69 helper_->CheckOnValidThread();
79 70
80 if (!delegate_->CanEnterLongIdlePeriod(now, 71 if (!delegate_->CanEnterLongIdlePeriod(now,
81 next_long_idle_period_delay_out)) { 72 next_long_idle_period_delay_out)) {
82 return IdlePeriodState::NOT_IN_IDLE_PERIOD; 73 return IdlePeriodState::NOT_IN_IDLE_PERIOD;
83 } 74 }
84 75
85 base::TimeTicks next_pending_delayed_task = 76 base::TimeTicks next_pending_delayed_task =
86 helper_->NextPendingDelayedTaskRunTime(); 77 helper_->NextPendingDelayedTaskRunTime();
87 base::TimeDelta max_long_idle_period_duration = 78 base::TimeDelta max_long_idle_period_duration =
88 base::TimeDelta::FromMilliseconds(kMaximumIdlePeriodMillis); 79 base::TimeDelta::FromMilliseconds(kMaximumIdlePeriodMillis);
89 base::TimeDelta long_idle_period_duration; 80 base::TimeDelta long_idle_period_duration;
90 if (next_pending_delayed_task.is_null()) { 81 if (next_pending_delayed_task.is_null()) {
91 long_idle_period_duration = max_long_idle_period_duration; 82 long_idle_period_duration = max_long_idle_period_duration;
92 } else { 83 } else {
93 // Limit the idle period duration to be before the next pending task. 84 // Limit the idle period duration to be before the next pending task.
94 long_idle_period_duration = std::min(next_pending_delayed_task - now, 85 long_idle_period_duration = std::min(next_pending_delayed_task - now,
95 max_long_idle_period_duration); 86 max_long_idle_period_duration);
96 } 87 }
97 88
98 if (long_idle_period_duration > base::TimeDelta()) { 89 if (long_idle_period_duration > base::TimeDelta()) {
99 *next_long_idle_period_delay_out = long_idle_period_duration; 90 *next_long_idle_period_delay_out = long_idle_period_duration;
100 return long_idle_period_duration == max_long_idle_period_duration 91 if (helper_->IsQueueEmpty(idle_queue_index_)) {
101 ? IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE 92 return IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED;
102 : IdlePeriodState::IN_LONG_IDLE_PERIOD; 93 } else if (long_idle_period_duration == max_long_idle_period_duration) {
94 return IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE;
95 } else {
96 return IdlePeriodState::IN_LONG_IDLE_PERIOD;
97 }
103 } else { 98 } else {
104 // If we can't start the idle period yet then try again after wakeup. 99 // If we can't start the idle period yet then try again after wakeup.
105 *next_long_idle_period_delay_out = base::TimeDelta::FromMilliseconds( 100 *next_long_idle_period_delay_out = base::TimeDelta::FromMilliseconds(
106 kRetryEnableLongIdlePeriodDelayMillis); 101 kRetryEnableLongIdlePeriodDelayMillis);
107 return IdlePeriodState::NOT_IN_IDLE_PERIOD; 102 return IdlePeriodState::NOT_IN_IDLE_PERIOD;
108 } 103 }
109 } 104 }
110 105
111 bool IdleHelper::ShouldWaitForQuiescence() { 106 bool IdleHelper::ShouldWaitForQuiescence() {
112 helper_->CheckOnValidThread(); 107 helper_->CheckOnValidThread();
(...skipping 14 matching lines...) Expand all
127 task_queues_run_since_last_check_bitmap); 122 task_queues_run_since_last_check_bitmap);
128 123
129 // If anything was run on the queues we care about, then we're not quiescent 124 // If anything was run on the queues we care about, then we're not quiescent
130 // and we should wait. 125 // and we should wait.
131 return task_queues_run_since_last_check_bitmap != 0; 126 return task_queues_run_since_last_check_bitmap != 0;
132 } 127 }
133 128
134 void IdleHelper::EnableLongIdlePeriod() { 129 void IdleHelper::EnableLongIdlePeriod() {
135 TRACE_EVENT0(disabled_by_default_tracing_category_, "EnableLongIdlePeriod"); 130 TRACE_EVENT0(disabled_by_default_tracing_category_, "EnableLongIdlePeriod");
136 helper_->CheckOnValidThread(); 131 helper_->CheckOnValidThread();
132 if (helper_->IsShutdown())
133 return;
137 134
138 // End any previous idle period. 135 // End any previous idle period.
139 EndIdlePeriod(); 136 EndIdlePeriod();
140 137
141 if (ShouldWaitForQuiescence()) { 138 if (ShouldWaitForQuiescence()) {
142 helper_->ControlTaskRunner()->PostDelayedTask( 139 helper_->ControlTaskRunner()->PostDelayedTask(
143 FROM_HERE, enable_next_long_idle_period_closure_.callback(), 140 FROM_HERE, enable_next_long_idle_period_closure_.callback(),
144 required_quiescence_duration_before_long_idle_period_); 141 required_quiescence_duration_before_long_idle_period_);
145 delegate_->IsNotQuiescent(); 142 delegate_->IsNotQuiescent();
146 return; 143 return;
147 } 144 }
148 145
149 base::TimeTicks now(helper_->Now()); 146 base::TimeTicks now(helper_->Now());
150 base::TimeDelta next_long_idle_period_delay; 147 base::TimeDelta next_long_idle_period_delay;
151 IdlePeriodState new_idle_period_state = 148 IdlePeriodState new_idle_period_state =
152 ComputeNewLongIdlePeriodState(now, &next_long_idle_period_delay); 149 ComputeNewLongIdlePeriodState(now, &next_long_idle_period_delay);
153 if (IsInIdlePeriod(new_idle_period_state)) { 150 if (IsInIdlePeriod(new_idle_period_state)) {
154 StartIdlePeriod(new_idle_period_state, now, 151 StartIdlePeriod(new_idle_period_state, now,
155 now + next_long_idle_period_delay, false); 152 now + next_long_idle_period_delay);
156 }
157
158 if (helper_->IsQueueEmpty(idle_queue_index_)) {
159 // If there are no current idle tasks then post the call to initiate the
160 // next idle for execution after wakeup (at which point after-wakeup idle
161 // tasks might be eligible to run or more idle tasks posted).
162 helper_->ControlAfterWakeUpTaskRunner()->PostDelayedTask(
163 FROM_HERE,
164 enable_next_long_idle_period_after_wakeup_closure_.callback(),
165 next_long_idle_period_delay);
166 } else { 153 } else {
167 // Otherwise post on the normal control task queue. 154 // Otherwise wait for the next long idle period delay before trying again.
168 helper_->ControlTaskRunner()->PostDelayedTask( 155 helper_->ControlTaskRunner()->PostDelayedTask(
169 FROM_HERE, enable_next_long_idle_period_closure_.callback(), 156 FROM_HERE, enable_next_long_idle_period_closure_.callback(),
170 next_long_idle_period_delay); 157 next_long_idle_period_delay);
171 } 158 }
172 } 159 }
173 160
174 void IdleHelper::EnableLongIdlePeriodAfterWakeup() {
175 TRACE_EVENT0(disabled_by_default_tracing_category_,
176 "EnableLongIdlePeriodAfterWakeup");
177 helper_->CheckOnValidThread();
178
179 if (IsInIdlePeriod(idle_period_state_)) {
180 // Since we were asleep until now, end the async idle period trace event at
181 // the time when it would have ended were we awake.
182 TRACE_EVENT_ASYNC_END_WITH_TIMESTAMP0(
183 tracing_category_, idle_period_tracing_name_, this,
184 std::min(idle_period_deadline_, helper_->Now()).ToInternalValue());
185 idle_period_state_ = IdlePeriodState::ENDING_LONG_IDLE_PERIOD;
186 EndIdlePeriod();
187 }
188
189 // Post a task to initiate the next long idle period rather than calling it
190 // directly to allow all pending PostIdleTaskAfterWakeup tasks to get enqueued
191 // on the idle task queue before the next idle period starts so they are
192 // eligible to be run during the new idle period.
193 helper_->ControlTaskRunner()->PostTask(
194 FROM_HERE, enable_next_long_idle_period_closure_.callback());
195 }
196
197 void IdleHelper::StartIdlePeriod(IdlePeriodState new_state, 161 void IdleHelper::StartIdlePeriod(IdlePeriodState new_state,
198 base::TimeTicks now, 162 base::TimeTicks now,
199 base::TimeTicks idle_period_deadline, 163 base::TimeTicks idle_period_deadline) {
200 bool post_end_idle_period) {
201 DCHECK_GT(idle_period_deadline, now); 164 DCHECK_GT(idle_period_deadline, now);
202 TRACE_EVENT_ASYNC_BEGIN0(tracing_category_, idle_period_tracing_name_, this);
203 helper_->CheckOnValidThread(); 165 helper_->CheckOnValidThread();
204 DCHECK(IsInIdlePeriod(new_state)); 166 DCHECK(IsInIdlePeriod(new_state));
167 TRACE_EVENT0(disabled_by_default_tracing_category_, "StartIdlePeriod");
205 168
206 helper_->EnableQueue(idle_queue_index_, 169 helper_->EnableQueue(idle_queue_index_,
207 PrioritizingTaskQueueSelector::BEST_EFFORT_PRIORITY); 170 PrioritizingTaskQueueSelector::BEST_EFFORT_PRIORITY);
208 helper_->PumpQueue(idle_queue_index_); 171 helper_->PumpQueue(idle_queue_index_);
209 idle_period_state_ = new_state;
210 172
211 idle_period_deadline_ = idle_period_deadline; 173 state_.UpdateState(new_state, idle_period_deadline, now);
212 if (post_end_idle_period) {
213 helper_->ControlTaskRunner()->PostDelayedTask(
214 FROM_HERE, end_idle_period_closure_.callback(),
215 idle_period_deadline_ - now);
216 }
217 } 174 }
218 175
219 void IdleHelper::EndIdlePeriod() { 176 void IdleHelper::EndIdlePeriod() {
220 helper_->CheckOnValidThread(); 177 helper_->CheckOnValidThread();
178 TRACE_EVENT0(disabled_by_default_tracing_category_, "EndIdlePeriod");
221 179
222 end_idle_period_closure_.Cancel();
223 enable_next_long_idle_period_closure_.Cancel(); 180 enable_next_long_idle_period_closure_.Cancel();
224 enable_next_long_idle_period_after_wakeup_closure_.Cancel();
225 181
226 // If we weren't already within an idle period then early-out. 182 // If we weren't already within an idle period then early-out.
227 if (!IsInIdlePeriod(idle_period_state_)) 183 if (!IsInIdlePeriod(state_.idle_period_state()))
228 return; 184 return;
229 185
230 // If we are in the ENDING_LONG_IDLE_PERIOD state we have already logged the 186 helper_->DisableQueue(idle_queue_index_);
231 // trace event. 187 state_.UpdateState(IdlePeriodState::NOT_IN_IDLE_PERIOD, base::TimeTicks(),
232 if (idle_period_state_ != IdlePeriodState::ENDING_LONG_IDLE_PERIOD) { 188 base::TimeTicks());
233 bool is_tracing; 189 }
234 TRACE_EVENT_CATEGORY_GROUP_ENABLED(tracing_category_, &is_tracing); 190
235 if (is_tracing && !idle_period_deadline_.is_null() && 191 void IdleHelper::WillProcessTask(const base::PendingTask& pending_task) {
236 helper_->Now() > idle_period_deadline_) { 192 }
237 TRACE_EVENT_ASYNC_STEP_INTO_WITH_TIMESTAMP0( 193
238 tracing_category_, idle_period_tracing_name_, this, "DeadlineOverrun", 194 void IdleHelper::DidProcessTask(const base::PendingTask& pending_task) {
239 idle_period_deadline_.ToInternalValue()); 195 helper_->CheckOnValidThread();
196 TRACE_EVENT0(disabled_by_default_tracing_category_, "DidProcessTask");
197 if (IsInIdlePeriod(state_.idle_period_state()) &&
198 state_.idle_period_state() !=
199 IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED &&
200 helper_->Now() >= state_.idle_period_deadline()) {
201 // If the idle period deadline has now been reached, either end the idle
202 // period or trigger a new long-idle period.
203 if (IsInLongIdlePeriod(state_.idle_period_state())) {
204 EnableLongIdlePeriod();
205 } else {
206 DCHECK(IdlePeriodState::IN_SHORT_IDLE_PERIOD ==
207 state_.idle_period_state());
208 EndIdlePeriod();
240 } 209 }
241 TRACE_EVENT_ASYNC_END0(tracing_category_, idle_period_tracing_name_, this);
242 } 210 }
211 }
243 212
244 helper_->DisableQueue(idle_queue_index_); 213 void IdleHelper::UpdateLongIdlePeriodStateAfterIdleTask() {
245 idle_period_state_ = IdlePeriodState::NOT_IN_IDLE_PERIOD; 214 helper_->CheckOnValidThread();
246 idle_period_deadline_ = base::TimeTicks(); 215 DCHECK(IsInLongIdlePeriod(state_.idle_period_state()));
216 TRACE_EVENT0(disabled_by_default_tracing_category_,
217 "UpdateLongIdlePeriodStateAfterIdleTask");
218 TaskQueueManager::QueueState queue_state =
219 helper_->GetQueueState(idle_queue_index_);
220 if (queue_state == TaskQueueManager::QueueState::EMPTY) {
221 // If there are no more idle tasks then pause long idle period ticks until a
222 // new idle task is posted.
223 state_.UpdateState(IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED,
224 state_.idle_period_deadline(), base::TimeTicks());
225 } else if (queue_state == TaskQueueManager::QueueState::NEEDS_PUMPING) {
226 // If there is still idle work to do then just start the next idle period.
227 base::TimeDelta next_long_idle_period_delay;
228 if (state_.idle_period_state() ==
229 IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE) {
230 // If we are in a max deadline long idle period then start the next
231 // idle period immediately.
232 next_long_idle_period_delay = base::TimeDelta();
233 } else {
234 // Otherwise ensure that we kick the scheduler at the right time to
235 // initiate the next idle period.
236 next_long_idle_period_delay = std::max(
237 base::TimeDelta(), state_.idle_period_deadline() - helper_->Now());
238 }
239 helper_->ControlTaskRunner()->PostDelayedTask(
240 FROM_HERE, enable_next_long_idle_period_closure_.callback(),
241 next_long_idle_period_delay);
242 }
243 }
244
245 base::TimeTicks IdleHelper::CurrentIdleTaskDeadline() const {
246 helper_->CheckOnValidThread();
247 return state_.idle_period_deadline();
248 }
249
250 void IdleHelper::OnIdleTaskPosted() {
251 if (state_.idle_period_paused_flag()) {
Sami 2015/06/01 17:11:57 Since we're reading this without a lock, could we
rmcilroy 2015/06/01 19:12:43 I was trying to avoid having to post a task here f
Sami 2015/06/02 10:33:15 Thanks, this looks better. I guess the use case of
252 // Restart long idle period ticks.
253 helper_->ControlTaskRunner()->PostTask(
254 FROM_HERE, enable_next_long_idle_period_closure_.callback());
255 }
256 }
257
258 base::TimeTicks IdleHelper::WillProcessIdleTask() const {
259 helper_->CheckOnValidThread();
260 DCHECK(IsInIdlePeriod(state_.idle_period_state()));
261
262 state_.TraceIdleIdleTaskStart();
263 return CurrentIdleTaskDeadline();
264 }
265
266 void IdleHelper::DidProcessIdleTask() {
267 helper_->CheckOnValidThread();
268 state_.TraceIdleIdleTaskEnd();
269 if (IsInLongIdlePeriod(state_.idle_period_state())) {
270 UpdateLongIdlePeriodStateAfterIdleTask();
271 }
247 } 272 }
248 273
249 // static 274 // static
250 bool IdleHelper::IsInIdlePeriod(IdlePeriodState state) { 275 bool IdleHelper::IsInIdlePeriod(IdlePeriodState state) {
251 return state != IdlePeriodState::NOT_IN_IDLE_PERIOD; 276 return state != IdlePeriodState::NOT_IN_IDLE_PERIOD;
252 } 277 }
253 278
279 // static
280 bool IdleHelper::IsInLongIdlePeriod(IdlePeriodState state) {
281 return state == IdlePeriodState::IN_LONG_IDLE_PERIOD ||
282 state == IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE ||
283 state == IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED;
284 }
285
254 bool IdleHelper::CanExceedIdleDeadlineIfRequired() const { 286 bool IdleHelper::CanExceedIdleDeadlineIfRequired() const {
255 TRACE_EVENT0(tracing_category_, "CanExceedIdleDeadlineIfRequired"); 287 TRACE_EVENT0(disabled_by_default_tracing_category_,
288 "CanExceedIdleDeadlineIfRequired");
256 helper_->CheckOnValidThread(); 289 helper_->CheckOnValidThread();
257 return idle_period_state_ == 290 return state_.idle_period_state() ==
258 IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE; 291 IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE;
259 } 292 }
260 293
261 IdleHelper::IdlePeriodState IdleHelper::SchedulerIdlePeriodState() const { 294 IdleHelper::IdlePeriodState IdleHelper::SchedulerIdlePeriodState() const {
295 return state_.idle_period_state();
296 }
297
298 IdleHelper::State::State(SchedulerHelper* helper,
299 const char* tracing_category,
300 const char* disabled_by_default_tracing_category,
301 const char* idle_period_tracing_name)
302 : helper_(helper),
303 idle_period_state_(IdlePeriodState::NOT_IN_IDLE_PERIOD),
304 idle_period_paused_flag_(&write_lock_),
305 nestable_events_started_(false),
306 tracing_category_(tracing_category),
307 disabled_by_default_tracing_category_(
308 disabled_by_default_tracing_category),
309 idle_period_tracing_name_(idle_period_tracing_name) {
310 }
311
312 IdleHelper::State::~State() {
313 }
314
315 IdleHelper::IdlePeriodState IdleHelper::State::idle_period_state() const {
316 helper_->CheckOnValidThread();
262 return idle_period_state_; 317 return idle_period_state_;
263 } 318 }
264 319
320 base::TimeTicks IdleHelper::State::idle_period_deadline() const {
321 helper_->CheckOnValidThread();
322 return idle_period_deadline_;
323 }
324
325 bool IdleHelper::State::idle_period_paused_flag() const {
326 return idle_period_paused_flag_.IsSet();
327 }
328
329 void IdleHelper::State::UpdateState(IdlePeriodState new_state,
330 base::TimeTicks new_deadline,
331 base::TimeTicks optional_now) {
332 helper_->CheckOnValidThread();
333 if (new_state == idle_period_state_) {
334 DCHECK_EQ(new_deadline, idle_period_deadline_);
335 return;
336 }
337
338 base::AutoLock lock(write_lock_);
339
340 bool is_tracing;
341 TRACE_EVENT_CATEGORY_GROUP_ENABLED(tracing_category_, &is_tracing);
342 if (is_tracing) {
343 base::TimeTicks now(optional_now.is_null() ? helper_->Now() : optional_now);
344 TraceEventIdlePeriodStateChange(new_state, new_deadline, now);
345 idle_period_deadline_for_tracing_ =
346 base::TimeTicks::NowFromSystemTraceTime() + (new_deadline - now);
347 }
348
349 idle_period_state_ = new_state;
350 idle_period_deadline_ = new_deadline;
351 idle_period_paused_flag_.SetWhileLocked(
352 new_state == IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED);
353 }
354
355 void IdleHelper::State::TraceIdleIdleTaskStart() const {
356 helper_->CheckOnValidThread();
357
358 bool is_tracing;
359 TRACE_EVENT_CATEGORY_GROUP_ENABLED(tracing_category_, &is_tracing);
360 if (is_tracing && nestable_events_started_) {
361 last_idle_task_trace_time_ = base::TimeTicks::NowFromSystemTraceTime();
362 TRACE_EVENT_NESTABLE_ASYNC_BEGIN_WITH_TIMESTAMP0(
363 tracing_category_, "RunningIdleTask", this,
364 last_idle_task_trace_time_.ToInternalValue());
365 }
366 }
367
368 void IdleHelper::State::TraceIdleIdleTaskEnd() const {
369 helper_->CheckOnValidThread();
370
371 bool is_tracing;
372 TRACE_EVENT_CATEGORY_GROUP_ENABLED(tracing_category_, &is_tracing);
373 if (is_tracing && nestable_events_started_) {
374 if (!idle_period_deadline_for_tracing_.is_null() &&
375 base::TimeTicks::NowFromSystemTraceTime() >
376 idle_period_deadline_for_tracing_) {
377 TRACE_EVENT_NESTABLE_ASYNC_BEGIN_WITH_TIMESTAMP0(
378 tracing_category_, "DeadlineOverrun", this,
Primiano Tucci (use gerrit) 2015/06/01 17:20:04 Just to doublecheck, the logic here would be that
rmcilroy 2015/06/01 19:12:43 Yes exactly. The second case is not only due to ov
379 std::max(idle_period_deadline_for_tracing_,
380 last_idle_task_trace_time_).ToInternalValue());
381 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_, "DeadlineOverrun",
382 this);
383 }
384 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_, "RunningIdleTask", this);
385 }
386 }
387
388 void IdleHelper::State::TraceEventIdlePeriodStateChange(
389 IdlePeriodState new_state,
390 base::TimeTicks new_deadline,
391 base::TimeTicks now) const {
392 TRACE_EVENT2(disabled_by_default_tracing_category_, "SetIdlePeriodState",
393 "old_state",
394 IdleHelper::IdlePeriodStateToString(idle_period_state_),
395 "new_state", IdleHelper::IdlePeriodStateToString(new_state));
396 if (nestable_events_started_) {
397 // End async tracing events for the state we are leaving.
398 if (idle_period_state_ == IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED) {
399 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_, "LongIdlePeriodPaused",
400 this);
401 }
402 if (IsInLongIdlePeriod(idle_period_state_) &&
403 !IsInLongIdlePeriod(new_state)) {
404 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_, "LongIdlePeriod",
405 this);
406 }
407 if (idle_period_state_ == IdlePeriodState::IN_SHORT_IDLE_PERIOD) {
408 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_, "ShortIdlePeriod",
409 this);
410 }
411 if (IsInIdlePeriod(idle_period_state_) && !IsInIdlePeriod(new_state)) {
412 TRACE_EVENT_NESTABLE_ASYNC_END0(tracing_category_,
413 idle_period_tracing_name_, this);
414 nestable_events_started_ = false;
415 }
416 }
417
418 // Start async tracing events for the state we are entering.
419 if (IsInIdlePeriod(new_state) && !IsInIdlePeriod(idle_period_state_)) {
420 nestable_events_started_ = true;
421 TRACE_EVENT_NESTABLE_ASYNC_BEGIN1(
422 tracing_category_, idle_period_tracing_name_, this,
423 "idle_period_length_ms", (new_deadline - now).ToInternalValue());
424 }
425 if (new_state == IdlePeriodState::IN_SHORT_IDLE_PERIOD) {
426 TRACE_EVENT_NESTABLE_ASYNC_BEGIN0(tracing_category_, "ShortIdlePeriod",
427 this);
428 }
429 if (IsInLongIdlePeriod(new_state) &&
430 !IsInLongIdlePeriod(idle_period_state_)) {
431 TRACE_EVENT_NESTABLE_ASYNC_BEGIN0(tracing_category_, "LongIdlePeriod",
432 this);
433 }
434 if (new_state == IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED) {
435 TRACE_EVENT_NESTABLE_ASYNC_BEGIN0(tracing_category_, "LongIdlePeriodPaused",
436 this);
437 }
438 }
439
265 // static 440 // static
266 const char* IdleHelper::IdlePeriodStateToString( 441 const char* IdleHelper::IdlePeriodStateToString(
267 IdlePeriodState idle_period_state) { 442 IdlePeriodState idle_period_state) {
268 switch (idle_period_state) { 443 switch (idle_period_state) {
269 case IdlePeriodState::NOT_IN_IDLE_PERIOD: 444 case IdlePeriodState::NOT_IN_IDLE_PERIOD:
270 return "not_in_idle_period"; 445 return "not_in_idle_period";
271 case IdlePeriodState::IN_SHORT_IDLE_PERIOD: 446 case IdlePeriodState::IN_SHORT_IDLE_PERIOD:
272 return "in_short_idle_period"; 447 return "in_short_idle_period";
273 case IdlePeriodState::IN_LONG_IDLE_PERIOD: 448 case IdlePeriodState::IN_LONG_IDLE_PERIOD:
274 return "in_long_idle_period"; 449 return "in_long_idle_period";
275 case IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE: 450 case IdlePeriodState::IN_LONG_IDLE_PERIOD_WITH_MAX_DEADLINE:
276 return "in_long_idle_period_with_max_deadline"; 451 return "in_long_idle_period_with_max_deadline";
277 case IdlePeriodState::ENDING_LONG_IDLE_PERIOD: 452 case IdlePeriodState::IN_LONG_IDLE_PERIOD_PAUSED:
278 return "ending_long_idle_period"; 453 return "in_long_idle_period_paused";
279 default: 454 default:
280 NOTREACHED(); 455 NOTREACHED();
281 return nullptr; 456 return nullptr;
282 } 457 }
283 } 458 }
284 459
285 } // namespace scheduler 460 } // namespace scheduler
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698