OLD | NEW |
---|---|
1 // Copyright 2011 The Chromium Authors. All rights reserved. | 1 // Copyright 2011 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 "cc/scheduler/scheduler.h" | 5 #include "cc/scheduler/scheduler.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include "base/auto_reset.h" | 8 #include "base/auto_reset.h" |
9 #include "base/debug/trace_event.h" | 9 #include "base/debug/trace_event.h" |
10 #include "base/debug/trace_event_argument.h" | 10 #include "base/debug/trace_event_argument.h" |
11 #include "base/logging.h" | 11 #include "base/logging.h" |
12 #include "base/single_thread_task_runner.h" | 12 #include "base/single_thread_task_runner.h" |
13 #include "cc/debug/devtools_instrumentation.h" | 13 #include "cc/debug/devtools_instrumentation.h" |
14 #include "cc/debug/traced_value.h" | 14 #include "cc/debug/traced_value.h" |
15 #include "cc/scheduler/delay_based_time_source.h" | 15 #include "cc/scheduler/delay_based_time_source.h" |
16 #include "ui/gfx/frame_time.h" | 16 #include "ui/gfx/frame_time.h" |
17 | 17 |
18 namespace cc { | 18 namespace cc { |
19 | 19 |
20 Scheduler::SyntheticBeginFrameSource::SyntheticBeginFrameSource( | 20 BeginFrameSource* SchedulerFrameSourcesConstructor::ConstructPrimaryFrameSource( |
21 Scheduler* scheduler, | 21 Scheduler* scheduler) { |
22 scoped_refptr<DelayBasedTimeSource> time_source) | 22 if (!scheduler->settings_.throttle_frame_production) { |
23 : scheduler_(scheduler), time_source_(time_source) { | 23 TRACE_EVENT1("cc", |
24 time_source_->SetClient(this); | 24 "Scheduler::Scheduler()", |
25 } | 25 "PrimaryFrameSource", |
26 "BackToBackBeginFrameSource"); | |
27 DCHECK(!scheduler->primary_frame_source_internal_); | |
28 scheduler->primary_frame_source_internal_ = | |
29 BackToBackBeginFrameSource::Create(scheduler->task_runner_.get()); | |
30 return scheduler->primary_frame_source_internal_.get(); | |
31 } else if (scheduler->settings_.begin_frame_scheduling_enabled) { | |
32 TRACE_EVENT1("cc", | |
33 "Scheduler::Scheduler()", | |
34 "PrimaryFrameSource", | |
35 "SchedulerClient"); | |
36 return scheduler->client_->ExternalBeginFrameSource(); | |
37 } else { | |
38 TRACE_EVENT1("cc", | |
39 "Scheduler::Scheduler()", | |
40 "PrimaryFrameSource", | |
41 "SyntheticBeginFrameSource"); | |
42 scoped_ptr<SyntheticBeginFrameSource> synthetic_source = | |
43 SyntheticBeginFrameSource::Create(scheduler->task_runner_.get(), | |
44 scheduler->Now(), | |
45 BeginFrameArgs::DefaultInterval()); | |
26 | 46 |
27 Scheduler::SyntheticBeginFrameSource::~SyntheticBeginFrameSource() { | 47 DCHECK(!scheduler->vsync_observer_); |
28 } | 48 scheduler->vsync_observer_ = synthetic_source.get(); |
29 | 49 |
30 void Scheduler::SyntheticBeginFrameSource::CommitVSyncParameters( | 50 DCHECK(!scheduler->primary_frame_source_internal_); |
31 base::TimeTicks timebase, | 51 scheduler->primary_frame_source_internal_ = synthetic_source.Pass(); |
32 base::TimeDelta interval) { | 52 return scheduler->primary_frame_source_internal_.get(); |
33 time_source_->SetTimebaseAndInterval(timebase, interval); | |
34 } | |
35 | |
36 void Scheduler::SyntheticBeginFrameSource::SetNeedsBeginFrame( | |
37 bool needs_begin_frame, | |
38 std::deque<BeginFrameArgs>* begin_retro_frame_args) { | |
39 DCHECK(begin_retro_frame_args); | |
40 base::TimeTicks missed_tick_time = | |
41 time_source_->SetActive(needs_begin_frame); | |
42 if (!missed_tick_time.is_null()) { | |
43 begin_retro_frame_args->push_back( | |
44 CreateSyntheticBeginFrameArgs(missed_tick_time)); | |
45 } | 53 } |
46 } | 54 } |
47 | 55 |
48 bool Scheduler::SyntheticBeginFrameSource::IsActive() const { | 56 BeginFrameSource* |
49 return time_source_->Active(); | 57 SchedulerFrameSourcesConstructor::ConstructBackgroundFrameSource( |
50 } | 58 Scheduler* scheduler) { |
51 | 59 TRACE_EVENT1("cc", |
52 void Scheduler::SyntheticBeginFrameSource::OnTimerTick() { | 60 "Scheduler::Scheduler()", |
53 BeginFrameArgs begin_frame_args( | 61 "BackgroundFrameSource", |
54 CreateSyntheticBeginFrameArgs(time_source_->LastTickTime())); | 62 "SyntheticBeginFrameSource"); |
55 scheduler_->BeginFrame(begin_frame_args); | 63 DCHECK(!(scheduler->background_frame_source_internal_)); |
56 } | 64 scheduler->background_frame_source_internal_ = |
57 | 65 SyntheticBeginFrameSource::Create(scheduler->task_runner_.get(), |
58 void Scheduler::SyntheticBeginFrameSource::AsValueInto( | 66 scheduler->Now(), |
59 base::debug::TracedValue* state) const { | 67 base::TimeDelta::FromSeconds(1)); |
60 time_source_->AsValueInto(state); | 68 return scheduler->background_frame_source_internal_.get(); |
61 } | |
62 | |
63 BeginFrameArgs | |
64 Scheduler::SyntheticBeginFrameSource::CreateSyntheticBeginFrameArgs( | |
65 base::TimeTicks frame_time) { | |
66 base::TimeTicks deadline = time_source_->NextTickTime(); | |
67 return BeginFrameArgs::Create( | |
68 frame_time, deadline, scheduler_->VSyncInterval()); | |
69 } | 69 } |
70 | 70 |
71 Scheduler::Scheduler( | 71 Scheduler::Scheduler( |
72 SchedulerClient* client, | 72 SchedulerClient* client, |
73 const SchedulerSettings& scheduler_settings, | 73 const SchedulerSettings& scheduler_settings, |
74 int layer_tree_host_id, | 74 int layer_tree_host_id, |
75 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner) | 75 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
76 SchedulerFrameSourcesConstructor frame_sources_constructor) | |
76 : settings_(scheduler_settings), | 77 : settings_(scheduler_settings), |
77 client_(client), | 78 client_(client), |
78 layer_tree_host_id_(layer_tree_host_id), | 79 layer_tree_host_id_(layer_tree_host_id), |
79 task_runner_(task_runner), | 80 task_runner_(task_runner), |
80 vsync_interval_(BeginFrameArgs::DefaultInterval()), | |
81 last_set_needs_begin_frame_(false), | |
82 begin_unthrottled_frame_posted_(false), | |
83 begin_retro_frame_posted_(false), | 81 begin_retro_frame_posted_(false), |
84 state_machine_(scheduler_settings), | 82 state_machine_(scheduler_settings), |
85 inside_process_scheduled_actions_(false), | 83 inside_process_scheduled_actions_(false), |
86 inside_action_(SchedulerStateMachine::ACTION_NONE), | 84 inside_action_(SchedulerStateMachine::ACTION_NONE), |
87 weak_factory_(this) { | 85 weak_factory_(this) { |
88 TRACE_EVENT1(TRACE_DISABLED_BY_DEFAULT("cc.debug.scheduler"), | 86 TRACE_EVENT1(TRACE_DISABLED_BY_DEFAULT("cc.debug.scheduler"), |
89 "Scheduler::Scheduler", | 87 "Scheduler::Scheduler", |
90 "settings", | 88 "settings", |
91 settings_.AsValue()); | 89 settings_.AsValue()); |
92 DCHECK(client_); | 90 DCHECK(client_); |
93 DCHECK(!state_machine_.BeginFrameNeeded()); | 91 DCHECK(!state_machine_.BeginFrameNeeded()); |
94 if (settings_.main_frame_before_activation_enabled) { | 92 if (settings_.main_frame_before_activation_enabled) { |
95 DCHECK(settings_.main_frame_before_draw_enabled); | 93 DCHECK(settings_.main_frame_before_draw_enabled); |
96 } | 94 } |
97 | 95 |
98 begin_retro_frame_closure_ = | 96 begin_retro_frame_closure_ = |
99 base::Bind(&Scheduler::BeginRetroFrame, weak_factory_.GetWeakPtr()); | 97 base::Bind(&Scheduler::BeginRetroFrame, weak_factory_.GetWeakPtr()); |
100 begin_unthrottled_frame_closure_ = | |
101 base::Bind(&Scheduler::BeginUnthrottledFrame, weak_factory_.GetWeakPtr()); | |
102 begin_impl_frame_deadline_closure_ = base::Bind( | 98 begin_impl_frame_deadline_closure_ = base::Bind( |
103 &Scheduler::OnBeginImplFrameDeadline, weak_factory_.GetWeakPtr()); | 99 &Scheduler::OnBeginImplFrameDeadline, weak_factory_.GetWeakPtr()); |
104 poll_for_draw_triggers_closure_ = base::Bind( | 100 poll_for_draw_triggers_closure_ = base::Bind( |
105 &Scheduler::PollForAnticipatedDrawTriggers, weak_factory_.GetWeakPtr()); | 101 &Scheduler::PollForAnticipatedDrawTriggers, weak_factory_.GetWeakPtr()); |
106 advance_commit_state_closure_ = base::Bind( | 102 advance_commit_state_closure_ = base::Bind( |
107 &Scheduler::PollToAdvanceCommitState, weak_factory_.GetWeakPtr()); | 103 &Scheduler::PollToAdvanceCommitState, weak_factory_.GetWeakPtr()); |
108 | 104 |
109 if (!settings_.begin_frame_scheduling_enabled) { | 105 frame_source_ = BeginFrameSourceMultiplexer::Create(); |
110 SetupSyntheticBeginFrames(); | 106 frame_source_->AddObserver(this); |
111 } | 107 |
108 // Primary frame source | |
109 primary_frame_source_ = | |
110 frame_sources_constructor.ConstructPrimaryFrameSource(this); | |
111 frame_source_->AddSource(primary_frame_source_); | |
112 | |
113 // Background ticking frame source | |
114 background_frame_source_ = | |
115 frame_sources_constructor.ConstructBackgroundFrameSource(this); | |
116 frame_source_->AddSource(background_frame_source_); | |
112 } | 117 } |
113 | 118 |
114 Scheduler::~Scheduler() { | 119 Scheduler::~Scheduler() { |
115 if (synthetic_begin_frame_source_) { | |
116 synthetic_begin_frame_source_->SetNeedsBeginFrame(false, | |
117 &begin_retro_frame_args_); | |
118 } | |
119 } | |
120 | |
121 void Scheduler::SetupSyntheticBeginFrames() { | |
122 scoped_refptr<DelayBasedTimeSource> time_source; | |
123 if (gfx::FrameTime::TimestampsAreHighRes()) { | |
124 time_source = DelayBasedTimeSourceHighRes::Create(VSyncInterval(), | |
125 task_runner_.get()); | |
126 } else { | |
127 time_source = | |
128 DelayBasedTimeSource::Create(VSyncInterval(), task_runner_.get()); | |
129 } | |
130 DCHECK(!synthetic_begin_frame_source_); | |
131 synthetic_begin_frame_source_.reset( | |
132 new SyntheticBeginFrameSource(this, time_source)); | |
133 } | 120 } |
134 | 121 |
135 base::TimeTicks Scheduler::Now() const { | 122 base::TimeTicks Scheduler::Now() const { |
136 return gfx::FrameTime::Now(); | 123 return gfx::FrameTime::Now(); |
137 } | 124 } |
138 | 125 |
139 void Scheduler::CommitVSyncParameters(base::TimeTicks timebase, | 126 void Scheduler::CommitVSyncParameters(base::TimeTicks timebase, |
140 base::TimeDelta interval) { | 127 base::TimeDelta interval) { |
141 // TODO(brianderson): We should not be receiving 0 intervals. | 128 // TODO(brianderson): We should not be receiving 0 intervals. |
142 if (interval == base::TimeDelta()) | 129 if (interval == base::TimeDelta()) |
143 interval = BeginFrameArgs::DefaultInterval(); | 130 interval = BeginFrameArgs::DefaultInterval(); |
144 vsync_interval_ = interval; | 131 |
145 if (!settings_.begin_frame_scheduling_enabled) | 132 if (vsync_observer_) |
146 synthetic_begin_frame_source_->CommitVSyncParameters(timebase, interval); | 133 vsync_observer_->OnUpdateVSyncParameters(timebase, interval); |
147 } | 134 } |
148 | 135 |
149 void Scheduler::SetEstimatedParentDrawTime(base::TimeDelta draw_time) { | 136 void Scheduler::SetEstimatedParentDrawTime(base::TimeDelta draw_time) { |
150 DCHECK_GE(draw_time.ToInternalValue(), 0); | 137 DCHECK_GE(draw_time.ToInternalValue(), 0); |
151 estimated_parent_draw_time_ = draw_time; | 138 estimated_parent_draw_time_ = draw_time; |
152 } | 139 } |
153 | 140 |
154 void Scheduler::SetCanStart() { | 141 void Scheduler::SetCanStart() { |
155 state_machine_.SetCanStart(); | 142 state_machine_.SetCanStart(); |
156 ProcessScheduledActions(); | 143 ProcessScheduledActions(); |
157 } | 144 } |
158 | 145 |
159 void Scheduler::SetVisible(bool visible) { | 146 void Scheduler::SetVisible(bool visible) { |
160 state_machine_.SetVisible(visible); | 147 state_machine_.SetVisible(visible); |
148 if (visible) { | |
149 frame_source_->SetActiveSource(primary_frame_source_); | |
150 } else { | |
151 frame_source_->SetActiveSource(background_frame_source_); | |
152 } | |
161 ProcessScheduledActions(); | 153 ProcessScheduledActions(); |
162 } | 154 } |
163 | 155 |
164 void Scheduler::SetCanDraw(bool can_draw) { | 156 void Scheduler::SetCanDraw(bool can_draw) { |
165 state_machine_.SetCanDraw(can_draw); | 157 state_machine_.SetCanDraw(can_draw); |
166 ProcessScheduledActions(); | 158 ProcessScheduledActions(); |
167 } | 159 } |
168 | 160 |
169 void Scheduler::NotifyReadyToActivate() { | 161 void Scheduler::NotifyReadyToActivate() { |
170 state_machine_.NotifyReadyToActivate(); | 162 state_machine_.NotifyReadyToActivate(); |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
233 ProcessScheduledActions(); | 225 ProcessScheduledActions(); |
234 } | 226 } |
235 | 227 |
236 void Scheduler::DidManageTiles() { | 228 void Scheduler::DidManageTiles() { |
237 state_machine_.DidManageTiles(); | 229 state_machine_.DidManageTiles(); |
238 } | 230 } |
239 | 231 |
240 void Scheduler::DidLoseOutputSurface() { | 232 void Scheduler::DidLoseOutputSurface() { |
241 TRACE_EVENT0("cc", "Scheduler::DidLoseOutputSurface"); | 233 TRACE_EVENT0("cc", "Scheduler::DidLoseOutputSurface"); |
242 state_machine_.DidLoseOutputSurface(); | 234 state_machine_.DidLoseOutputSurface(); |
243 last_set_needs_begin_frame_ = false; | 235 if (frame_source_->NeedsBeginFrames()) |
244 if (!settings_.begin_frame_scheduling_enabled) { | 236 frame_source_->SetNeedsBeginFrames(false); |
245 synthetic_begin_frame_source_->SetNeedsBeginFrame(false, | |
246 &begin_retro_frame_args_); | |
247 } | |
248 begin_retro_frame_args_.clear(); | 237 begin_retro_frame_args_.clear(); |
249 ProcessScheduledActions(); | 238 ProcessScheduledActions(); |
250 } | 239 } |
251 | 240 |
252 void Scheduler::DidCreateAndInitializeOutputSurface() { | 241 void Scheduler::DidCreateAndInitializeOutputSurface() { |
253 TRACE_EVENT0("cc", "Scheduler::DidCreateAndInitializeOutputSurface"); | 242 TRACE_EVENT0("cc", "Scheduler::DidCreateAndInitializeOutputSurface"); |
254 DCHECK(!last_set_needs_begin_frame_); | 243 DCHECK(!frame_source_->NeedsBeginFrames()); |
255 DCHECK(begin_impl_frame_deadline_task_.IsCancelled()); | 244 DCHECK(begin_impl_frame_deadline_task_.IsCancelled()); |
256 state_machine_.DidCreateAndInitializeOutputSurface(); | 245 state_machine_.DidCreateAndInitializeOutputSurface(); |
257 ProcessScheduledActions(); | 246 ProcessScheduledActions(); |
258 } | 247 } |
259 | 248 |
260 void Scheduler::NotifyBeginMainFrameStarted() { | 249 void Scheduler::NotifyBeginMainFrameStarted() { |
261 TRACE_EVENT0("cc", "Scheduler::NotifyBeginMainFrameStarted"); | 250 TRACE_EVENT0("cc", "Scheduler::NotifyBeginMainFrameStarted"); |
262 state_machine_.NotifyBeginMainFrameStarted(); | 251 state_machine_.NotifyBeginMainFrameStarted(); |
263 } | 252 } |
264 | 253 |
265 base::TimeTicks Scheduler::AnticipatedDrawTime() const { | 254 base::TimeTicks Scheduler::AnticipatedDrawTime() const { |
266 if (!last_set_needs_begin_frame_ || | 255 if (!frame_source_->NeedsBeginFrames() || |
267 begin_impl_frame_args_.interval <= base::TimeDelta()) | 256 begin_impl_frame_args_.interval <= base::TimeDelta()) |
268 return base::TimeTicks(); | 257 return base::TimeTicks(); |
269 | 258 |
270 base::TimeTicks now = Now(); | 259 base::TimeTicks now = Now(); |
271 base::TimeTicks timebase = std::max(begin_impl_frame_args_.frame_time, | 260 base::TimeTicks timebase = std::max(begin_impl_frame_args_.frame_time, |
272 begin_impl_frame_args_.deadline); | 261 begin_impl_frame_args_.deadline); |
273 int64 intervals = 1 + ((now - timebase) / begin_impl_frame_args_.interval); | 262 int64 intervals = 1 + ((now - timebase) / begin_impl_frame_args_.interval); |
274 return timebase + (begin_impl_frame_args_.interval * intervals); | 263 return timebase + (begin_impl_frame_args_.interval * intervals); |
275 } | 264 } |
276 | 265 |
277 base::TimeTicks Scheduler::LastBeginImplFrameTime() { | 266 base::TimeTicks Scheduler::LastBeginImplFrameTime() { |
278 return begin_impl_frame_args_.frame_time; | 267 return begin_impl_frame_args_.frame_time; |
279 } | 268 } |
280 | 269 |
281 void Scheduler::SetupNextBeginFrameIfNeeded() { | 270 void Scheduler::SetupNextBeginFrameIfNeeded() { |
282 if (!task_runner_.get()) | 271 if (!task_runner_.get()) |
283 return; | 272 return; |
284 | 273 |
285 bool needs_begin_frame = state_machine_.BeginFrameNeeded(); | 274 bool needs_begin_frame = state_machine_.BeginFrameNeeded(); |
286 | 275 |
287 if (settings_.throttle_frame_production) { | 276 bool at_end_of_deadline = |
288 SetupNextBeginFrameWhenVSyncThrottlingEnabled(needs_begin_frame); | 277 (state_machine_.begin_impl_frame_state() == |
289 } else { | 278 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_INSIDE_DEADLINE); |
290 SetupNextBeginFrameWhenVSyncThrottlingDisabled(needs_begin_frame); | 279 |
280 bool should_call_set_needs_begin_frame = | |
281 // Always request the BeginFrame immediately if it wasn't needed before. | |
282 (needs_begin_frame && !frame_source_->NeedsBeginFrames()) || | |
283 // Only stop requesting BeginFrames after a deadline. | |
284 (!needs_begin_frame && frame_source_->NeedsBeginFrames() && | |
285 at_end_of_deadline); | |
286 | |
287 if (should_call_set_needs_begin_frame) { | |
288 frame_source_->SetNeedsBeginFrames(needs_begin_frame); | |
291 } | 289 } |
290 | |
291 if (at_end_of_deadline) { | |
292 frame_source_->DidFinishFrame(begin_retro_frame_args_.size()); | |
293 } | |
294 | |
295 PostBeginRetroFrameIfNeeded(); | |
292 SetupPollingMechanisms(needs_begin_frame); | 296 SetupPollingMechanisms(needs_begin_frame); |
293 } | 297 } |
294 | 298 |
295 // When we are throttling frame production, we request BeginFrames | |
296 // from the OutputSurface. | |
297 void Scheduler::SetupNextBeginFrameWhenVSyncThrottlingEnabled( | |
298 bool needs_begin_frame) { | |
299 bool at_end_of_deadline = | |
300 state_machine_.begin_impl_frame_state() == | |
301 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_INSIDE_DEADLINE; | |
302 | |
303 bool should_call_set_needs_begin_frame = | |
304 // Always request the BeginFrame immediately if it wasn't needed before. | |
305 (needs_begin_frame && !last_set_needs_begin_frame_) || | |
306 // Only stop requesting BeginFrames after a deadline. | |
307 (!needs_begin_frame && last_set_needs_begin_frame_ && at_end_of_deadline); | |
308 | |
309 if (should_call_set_needs_begin_frame) { | |
310 if (settings_.begin_frame_scheduling_enabled) { | |
311 client_->SetNeedsBeginFrame(needs_begin_frame); | |
312 } else { | |
313 synthetic_begin_frame_source_->SetNeedsBeginFrame( | |
314 needs_begin_frame, &begin_retro_frame_args_); | |
315 } | |
316 last_set_needs_begin_frame_ = needs_begin_frame; | |
317 } | |
318 | |
319 PostBeginRetroFrameIfNeeded(); | |
320 } | |
321 | |
322 // When we aren't throttling frame production, we initiate a BeginFrame | |
323 // as soon as one is needed. | |
324 void Scheduler::SetupNextBeginFrameWhenVSyncThrottlingDisabled( | |
325 bool needs_begin_frame) { | |
326 last_set_needs_begin_frame_ = needs_begin_frame; | |
327 | |
328 if (!needs_begin_frame || begin_unthrottled_frame_posted_) | |
329 return; | |
330 | |
331 if (state_machine_.begin_impl_frame_state() != | |
332 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_IDLE && | |
333 state_machine_.begin_impl_frame_state() != | |
334 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_INSIDE_DEADLINE) { | |
335 return; | |
336 } | |
337 | |
338 begin_unthrottled_frame_posted_ = true; | |
339 task_runner_->PostTask(FROM_HERE, begin_unthrottled_frame_closure_); | |
340 } | |
341 | |
342 // BeginUnthrottledFrame is used when we aren't throttling frame production. | |
343 // This will usually be because VSync is disabled. | |
344 void Scheduler::BeginUnthrottledFrame() { | |
345 DCHECK(!settings_.throttle_frame_production); | |
346 DCHECK(begin_retro_frame_args_.empty()); | |
347 | |
348 base::TimeTicks now = Now(); | |
349 base::TimeTicks deadline = now + vsync_interval_; | |
350 | |
351 BeginFrameArgs begin_frame_args = | |
352 BeginFrameArgs::Create(now, deadline, vsync_interval_); | |
353 BeginImplFrame(begin_frame_args); | |
354 | |
355 begin_unthrottled_frame_posted_ = false; | |
356 } | |
357 | |
358 // We may need to poll when we can't rely on BeginFrame to advance certain | 299 // We may need to poll when we can't rely on BeginFrame to advance certain |
359 // state or to avoid deadlock. | 300 // state or to avoid deadlock. |
360 void Scheduler::SetupPollingMechanisms(bool needs_begin_frame) { | 301 void Scheduler::SetupPollingMechanisms(bool needs_begin_frame) { |
361 bool needs_advance_commit_state_timer = false; | 302 bool needs_advance_commit_state_timer = false; |
362 // Setup PollForAnticipatedDrawTriggers if we need to monitor state but | 303 // Setup PollForAnticipatedDrawTriggers if we need to monitor state but |
363 // aren't expecting any more BeginFrames. This should only be needed by | 304 // aren't expecting any more BeginFrames. This should only be needed by |
364 // the synchronous compositor when BeginFrameNeeded is false. | 305 // the synchronous compositor when BeginFrameNeeded is false. |
365 if (state_machine_.ShouldPollForAnticipatedDrawTriggers()) { | 306 if (state_machine_.ShouldPollForAnticipatedDrawTriggers()) { |
366 DCHECK(!state_machine_.SupportsProactiveBeginFrame()); | 307 DCHECK(!state_machine_.SupportsProactiveBeginFrame()); |
367 DCHECK(!needs_begin_frame); | 308 DCHECK(!needs_begin_frame); |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
401 } | 342 } |
402 } else { | 343 } else { |
403 advance_commit_state_task_.Cancel(); | 344 advance_commit_state_task_.Cancel(); |
404 } | 345 } |
405 } | 346 } |
406 | 347 |
407 // BeginFrame is the mechanism that tells us that now is a good time to start | 348 // BeginFrame is the mechanism that tells us that now is a good time to start |
408 // making a frame. Usually this means that user input for the frame is complete. | 349 // making a frame. Usually this means that user input for the frame is complete. |
409 // If the scheduler is busy, we queue the BeginFrame to be handled later as | 350 // If the scheduler is busy, we queue the BeginFrame to be handled later as |
410 // a BeginRetroFrame. | 351 // a BeginRetroFrame. |
411 void Scheduler::BeginFrame(const BeginFrameArgs& args) { | 352 bool Scheduler::OnBeginFrameImpl(const BeginFrameArgs& args) { |
brianderson
2014/09/23 01:31:06
Why did this become OnBeginFrameImpl? A little con
mithro-old
2014/09/23 12:43:54
Fixed. Should be significantly clearer now.
| |
412 TRACE_EVENT1("cc", "Scheduler::BeginFrame", "args", args.AsValue()); | 353 TRACE_EVENT1("cc", "Scheduler::BeginFrame", "args", args.AsValue()); |
413 DCHECK(settings_.throttle_frame_production); | |
414 | 354 |
415 BeginFrameArgs adjusted_args(args); | 355 BeginFrameArgs adjusted_args(args); |
416 adjusted_args.deadline -= EstimatedParentDrawTime(); | 356 adjusted_args.deadline -= EstimatedParentDrawTime(); |
417 | 357 |
418 bool should_defer_begin_frame; | 358 bool should_defer_begin_frame; |
419 if (settings_.using_synchronous_renderer_compositor) { | 359 if (settings_.using_synchronous_renderer_compositor) { |
420 should_defer_begin_frame = false; | 360 should_defer_begin_frame = false; |
421 } else { | 361 } else { |
422 should_defer_begin_frame = | 362 should_defer_begin_frame = |
423 !begin_retro_frame_args_.empty() || begin_retro_frame_posted_ || | 363 !begin_retro_frame_args_.empty() || begin_retro_frame_posted_ || |
424 !last_set_needs_begin_frame_ || | 364 !frame_source_->NeedsBeginFrames() || |
425 (state_machine_.begin_impl_frame_state() != | 365 (state_machine_.begin_impl_frame_state() != |
426 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_IDLE); | 366 SchedulerStateMachine::BEGIN_IMPL_FRAME_STATE_IDLE); |
427 } | 367 } |
428 | 368 |
429 if (should_defer_begin_frame) { | 369 if (should_defer_begin_frame) { |
430 begin_retro_frame_args_.push_back(adjusted_args); | 370 begin_retro_frame_args_.push_back(adjusted_args); |
431 TRACE_EVENT_INSTANT0( | 371 TRACE_EVENT_INSTANT0( |
432 "cc", "Scheduler::BeginFrame deferred", TRACE_EVENT_SCOPE_THREAD); | 372 "cc", "Scheduler::BeginFrame deferred", TRACE_EVENT_SCOPE_THREAD); |
433 return; | 373 // Queuing the frame counts as "using it", so we need to return true. |
374 return true; | |
434 } | 375 } |
435 | 376 |
436 BeginImplFrame(adjusted_args); | 377 BeginImplFrame(adjusted_args); |
378 return true; | |
379 } | |
380 | |
381 // We have just called SetNeedsBeginFrame(true) and the BeginFrameSource has | |
382 // sent us the last BeginFrame we have missed. As we might not be able to | |
383 // actually make rendering for this call, handle it like a "retro frame". | |
384 // TODO(brainderson): Add a test for this functionality ASAP! | |
385 void Scheduler::OnMissedBeginFrame(const BeginFrameArgs& args) { | |
386 begin_retro_frame_args_.push_back(args); | |
387 PostBeginRetroFrameIfNeeded(); | |
437 } | 388 } |
438 | 389 |
439 // BeginRetroFrame is called for BeginFrames that we've deferred because | 390 // BeginRetroFrame is called for BeginFrames that we've deferred because |
440 // the scheduler was in the middle of processing a previous BeginFrame. | 391 // the scheduler was in the middle of processing a previous BeginFrame. |
441 void Scheduler::BeginRetroFrame() { | 392 void Scheduler::BeginRetroFrame() { |
442 TRACE_EVENT0("cc", "Scheduler::BeginRetroFrame"); | 393 TRACE_EVENT0("cc", "Scheduler::BeginRetroFrame"); |
443 DCHECK(!settings_.using_synchronous_renderer_compositor); | 394 DCHECK(!settings_.using_synchronous_renderer_compositor); |
444 DCHECK(begin_retro_frame_posted_); | 395 DCHECK(begin_retro_frame_posted_); |
445 begin_retro_frame_posted_ = false; | 396 begin_retro_frame_posted_ = false; |
446 | 397 |
447 // If there aren't any retroactive BeginFrames, then we've lost the | 398 // If there aren't any retroactive BeginFrames, then we've lost the |
448 // OutputSurface and should abort. | 399 // OutputSurface and should abort. |
449 if (begin_retro_frame_args_.empty()) | 400 if (begin_retro_frame_args_.empty()) |
450 return; | 401 return; |
451 | 402 |
452 // Discard expired BeginRetroFrames | 403 // Discard expired BeginRetroFrames |
453 // Today, we should always end up with at most one un-expired BeginRetroFrame | 404 // Today, we should always end up with at most one un-expired BeginRetroFrame |
454 // because deadlines will not be greater than the next frame time. We don't | 405 // because deadlines will not be greater than the next frame time. We don't |
455 // DCHECK though because some systems don't always have monotonic timestamps. | 406 // DCHECK though because some systems don't always have monotonic timestamps. |
456 // TODO(brianderson): In the future, long deadlines could result in us not | 407 // TODO(brianderson): In the future, long deadlines could result in us not |
457 // draining the queue if we don't catch up. If we consistently can't catch | 408 // draining the queue if we don't catch up. If we consistently can't catch |
458 // up, our fallback should be to lower our frame rate. | 409 // up, our fallback should be to lower our frame rate. |
459 base::TimeTicks now = Now(); | 410 base::TimeTicks now = Now(); |
460 base::TimeDelta draw_duration_estimate = client_->DrawDurationEstimate(); | 411 base::TimeDelta draw_duration_estimate = client_->DrawDurationEstimate(); |
461 while (!begin_retro_frame_args_.empty() && | 412 while (!begin_retro_frame_args_.empty()) { |
462 now > AdjustedBeginImplFrameDeadline(begin_retro_frame_args_.front(), | 413 base::TimeTicks adjusted_deadline = AdjustedBeginImplFrameDeadline( |
463 draw_duration_estimate)) { | 414 begin_retro_frame_args_.front(), draw_duration_estimate); |
464 TRACE_EVENT1("cc", | 415 if (now <= adjusted_deadline) |
465 "Scheduler::BeginRetroFrame discarding", | 416 break; |
466 "frame_time", | 417 |
467 begin_retro_frame_args_.front().frame_time); | 418 TRACE_EVENT_INSTANT2("cc", |
419 "Scheduler::BeginRetroFrame discarding", | |
420 TRACE_EVENT_SCOPE_THREAD, | |
421 "deadline - now", | |
422 (adjusted_deadline - now).InMicroseconds(), | |
423 "BeginFrameArgs", | |
424 begin_retro_frame_args_.front().AsValue()); | |
468 begin_retro_frame_args_.pop_front(); | 425 begin_retro_frame_args_.pop_front(); |
426 frame_source_->DidFinishFrame(begin_retro_frame_args_.size()); | |
469 } | 427 } |
470 | 428 |
471 if (begin_retro_frame_args_.empty()) { | 429 if (begin_retro_frame_args_.empty()) { |
472 DCHECK(settings_.throttle_frame_production); | |
473 TRACE_EVENT_INSTANT0("cc", | 430 TRACE_EVENT_INSTANT0("cc", |
474 "Scheduler::BeginRetroFrames all expired", | 431 "Scheduler::BeginRetroFrames all expired", |
475 TRACE_EVENT_SCOPE_THREAD); | 432 TRACE_EVENT_SCOPE_THREAD); |
476 } else { | 433 } else { |
477 BeginImplFrame(begin_retro_frame_args_.front()); | 434 BeginImplFrame(begin_retro_frame_args_.front()); |
478 begin_retro_frame_args_.pop_front(); | 435 begin_retro_frame_args_.pop_front(); |
479 } | 436 } |
480 } | 437 } |
481 | 438 |
482 // There could be a race between the posted BeginRetroFrame and a new | 439 // There could be a race between the posted BeginRetroFrame and a new |
483 // BeginFrame arriving via the normal mechanism. Scheduler::BeginFrame | 440 // BeginFrame arriving via the normal mechanism. Scheduler::BeginFrame |
484 // will check if there is a pending BeginRetroFrame to ensure we handle | 441 // will check if there is a pending BeginRetroFrame to ensure we handle |
485 // BeginFrames in FIFO order. | 442 // BeginFrames in FIFO order. |
486 void Scheduler::PostBeginRetroFrameIfNeeded() { | 443 void Scheduler::PostBeginRetroFrameIfNeeded() { |
487 TRACE_EVENT1(TRACE_DISABLED_BY_DEFAULT("cc.debug.scheduler"), | 444 TRACE_EVENT1(TRACE_DISABLED_BY_DEFAULT("cc.debug.scheduler"), |
488 "Scheduler::PostBeginRetroFrameIfNeeded", | 445 "Scheduler::PostBeginRetroFrameIfNeeded", |
489 "state", | 446 "state", |
490 AsValue()); | 447 AsValue()); |
491 if (!last_set_needs_begin_frame_) | 448 if (!frame_source_->NeedsBeginFrames()) |
492 return; | 449 return; |
493 | 450 |
494 if (begin_retro_frame_args_.empty() || begin_retro_frame_posted_) | 451 if (begin_retro_frame_args_.empty() || begin_retro_frame_posted_) |
495 return; | 452 return; |
496 | 453 |
497 // begin_retro_frame_args_ should always be empty for the | 454 // begin_retro_frame_args_ should always be empty for the |
498 // synchronous compositor. | 455 // synchronous compositor. |
499 DCHECK(!settings_.using_synchronous_renderer_compositor); | 456 DCHECK(!settings_.using_synchronous_renderer_compositor); |
500 | 457 |
501 if (state_machine_.begin_impl_frame_state() != | 458 if (state_machine_.begin_impl_frame_state() != |
(...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
699 scoped_refptr<base::debug::TracedValue> state = | 656 scoped_refptr<base::debug::TracedValue> state = |
700 new base::debug::TracedValue(); | 657 new base::debug::TracedValue(); |
701 AsValueInto(state.get()); | 658 AsValueInto(state.get()); |
702 return state; | 659 return state; |
703 } | 660 } |
704 | 661 |
705 void Scheduler::AsValueInto(base::debug::TracedValue* state) const { | 662 void Scheduler::AsValueInto(base::debug::TracedValue* state) const { |
706 state->BeginDictionary("state_machine"); | 663 state->BeginDictionary("state_machine"); |
707 state_machine_.AsValueInto(state, Now()); | 664 state_machine_.AsValueInto(state, Now()); |
708 state->EndDictionary(); | 665 state->EndDictionary(); |
709 if (synthetic_begin_frame_source_) { | 666 |
710 state->BeginDictionary("synthetic_begin_frame_source_"); | 667 state->BeginDictionary("frame_source_"); |
711 synthetic_begin_frame_source_->AsValueInto(state); | 668 frame_source_->AsValueInto(state); |
712 state->EndDictionary(); | 669 state->EndDictionary(); |
713 } | |
714 | 670 |
715 state->BeginDictionary("scheduler_state"); | 671 state->BeginDictionary("scheduler_state"); |
716 state->SetDouble("time_until_anticipated_draw_time_ms", | 672 state->SetDouble("time_until_anticipated_draw_time_ms", |
717 (AnticipatedDrawTime() - Now()).InMillisecondsF()); | 673 (AnticipatedDrawTime() - Now()).InMillisecondsF()); |
718 state->SetDouble("vsync_interval_ms", vsync_interval_.InMillisecondsF()); | |
719 state->SetDouble("estimated_parent_draw_time_ms", | 674 state->SetDouble("estimated_parent_draw_time_ms", |
720 estimated_parent_draw_time_.InMillisecondsF()); | 675 estimated_parent_draw_time_.InMillisecondsF()); |
721 state->SetBoolean("last_set_needs_begin_frame_", last_set_needs_begin_frame_); | 676 state->SetBoolean("last_set_needs_begin_frame_", |
722 state->SetBoolean("begin_unthrottled_frame_posted_", | 677 frame_source_->NeedsBeginFrames()); |
723 begin_unthrottled_frame_posted_); | |
724 state->SetBoolean("begin_retro_frame_posted_", begin_retro_frame_posted_); | 678 state->SetBoolean("begin_retro_frame_posted_", begin_retro_frame_posted_); |
725 state->SetInteger("begin_retro_frame_args_", begin_retro_frame_args_.size()); | 679 state->SetInteger("begin_retro_frame_args_", begin_retro_frame_args_.size()); |
726 state->SetBoolean("begin_impl_frame_deadline_task_", | 680 state->SetBoolean("begin_impl_frame_deadline_task_", |
727 !begin_impl_frame_deadline_task_.IsCancelled()); | 681 !begin_impl_frame_deadline_task_.IsCancelled()); |
728 state->SetBoolean("poll_for_draw_triggers_task_", | 682 state->SetBoolean("poll_for_draw_triggers_task_", |
729 !poll_for_draw_triggers_task_.IsCancelled()); | 683 !poll_for_draw_triggers_task_.IsCancelled()); |
730 state->SetBoolean("advance_commit_state_task_", | 684 state->SetBoolean("advance_commit_state_task_", |
731 !advance_commit_state_task_.IsCancelled()); | 685 !advance_commit_state_task_.IsCancelled()); |
732 state->BeginDictionary("begin_impl_frame_args"); | 686 state->BeginDictionary("begin_impl_frame_args"); |
733 begin_impl_frame_args_.AsValueInto(state); | 687 begin_impl_frame_args_.AsValueInto(state); |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
767 } | 721 } |
768 | 722 |
769 bool Scheduler::IsBeginMainFrameSentOrStarted() const { | 723 bool Scheduler::IsBeginMainFrameSentOrStarted() const { |
770 return (state_machine_.commit_state() == | 724 return (state_machine_.commit_state() == |
771 SchedulerStateMachine::COMMIT_STATE_BEGIN_MAIN_FRAME_SENT || | 725 SchedulerStateMachine::COMMIT_STATE_BEGIN_MAIN_FRAME_SENT || |
772 state_machine_.commit_state() == | 726 state_machine_.commit_state() == |
773 SchedulerStateMachine::COMMIT_STATE_BEGIN_MAIN_FRAME_STARTED); | 727 SchedulerStateMachine::COMMIT_STATE_BEGIN_MAIN_FRAME_STARTED); |
774 } | 728 } |
775 | 729 |
776 } // namespace cc | 730 } // namespace cc |
OLD | NEW |