Chromium Code Reviews| 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 |