Index: cc/trees/thread_proxy.cc |
diff --git a/cc/trees/thread_proxy.cc b/cc/trees/thread_proxy.cc |
deleted file mode 100644 |
index 60d13688383f2f5a450e0d5105b7e6d9a9c03809..0000000000000000000000000000000000000000 |
--- a/cc/trees/thread_proxy.cc |
+++ /dev/null |
@@ -1,1196 +0,0 @@ |
-// Copyright 2011 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "cc/trees/thread_proxy.h" |
- |
-#include <algorithm> |
-#include <string> |
- |
-#include "base/auto_reset.h" |
-#include "base/bind.h" |
-#include "base/trace_event/trace_event.h" |
-#include "base/trace_event/trace_event_argument.h" |
-#include "base/trace_event/trace_event_synthetic_delay.h" |
-#include "cc/debug/benchmark_instrumentation.h" |
-#include "cc/debug/devtools_instrumentation.h" |
-#include "cc/input/input_handler.h" |
-#include "cc/input/top_controls_manager.h" |
-#include "cc/output/context_provider.h" |
-#include "cc/output/output_surface.h" |
-#include "cc/output/swap_promise.h" |
-#include "cc/quads/draw_quad.h" |
-#include "cc/scheduler/commit_earlyout_reason.h" |
-#include "cc/scheduler/compositor_timing_history.h" |
-#include "cc/scheduler/scheduler.h" |
-#include "cc/trees/blocking_task_runner.h" |
-#include "cc/trees/layer_tree_host.h" |
-#include "cc/trees/layer_tree_impl.h" |
-#include "cc/trees/scoped_abort_remaining_swap_promises.h" |
-#include "gpu/command_buffer/client/gles2_interface.h" |
- |
-namespace cc { |
- |
-namespace { |
- |
-// Measured in seconds. |
-const double kSmoothnessTakesPriorityExpirationDelay = 0.25; |
- |
-unsigned int nextBeginFrameId = 0; |
- |
-} // namespace |
- |
-struct ThreadProxy::SchedulerStateRequest { |
- CompletionEvent completion; |
- scoped_ptr<base::Value> state; |
-}; |
- |
-scoped_ptr<Proxy> ThreadProxy::Create( |
- LayerTreeHost* layer_tree_host, |
- TaskRunnerProvider* task_runner_provider, |
- scoped_ptr<BeginFrameSource> external_begin_frame_source) { |
- return make_scoped_ptr(new ThreadProxy(layer_tree_host, task_runner_provider, |
- external_begin_frame_source.Pass())); |
-} |
- |
-ThreadProxy::ThreadProxy( |
- LayerTreeHost* layer_tree_host, |
- TaskRunnerProvider* task_runner_provider, |
- scoped_ptr<BeginFrameSource> external_begin_frame_source) |
- : task_runner_provider_(task_runner_provider), |
- main_thread_only_vars_unsafe_(this, layer_tree_host), |
- compositor_thread_vars_unsafe_( |
- this, |
- layer_tree_host->id(), |
- layer_tree_host->rendering_stats_instrumentation(), |
- external_begin_frame_source.Pass()) { |
- TRACE_EVENT0("cc", "ThreadProxy::ThreadProxy"); |
- DCHECK(task_runner_provider_); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(this->main().layer_tree_host); |
- // TODO(khushalsagar): Move this to LayerTreeHost#InitializeThreaded once |
- // ThreadProxy is split. LayerTreeHost creates the channel and passes it to |
- // ProxyMain#SetChannel. |
- SetChannel(ThreadedChannel::Create(this, task_runner_provider_)); |
-} |
- |
-ThreadProxy::MainThreadOnly::MainThreadOnly(ThreadProxy* proxy, |
- LayerTreeHost* layer_tree_host) |
- : layer_tree_host_id(layer_tree_host->id()), |
- layer_tree_host(layer_tree_host), |
- max_requested_pipeline_stage(NO_PIPELINE_STAGE), |
- current_pipeline_stage(NO_PIPELINE_STAGE), |
- final_pipeline_stage(NO_PIPELINE_STAGE), |
- commit_waits_for_activation(false), |
- started(false), |
- prepare_tiles_pending(false), |
- defer_commits(false), |
- weak_factory(proxy) {} |
- |
-ThreadProxy::MainThreadOnly::~MainThreadOnly() {} |
- |
-ThreadProxy::BlockedMainCommitOnly::BlockedMainCommitOnly() |
- : layer_tree_host(nullptr) {} |
- |
-ThreadProxy::BlockedMainCommitOnly::~BlockedMainCommitOnly() {} |
- |
-ThreadProxy::CompositorThreadOnly::CompositorThreadOnly( |
- ThreadProxy* proxy, |
- int layer_tree_host_id, |
- RenderingStatsInstrumentation* rendering_stats_instrumentation, |
- scoped_ptr<BeginFrameSource> external_begin_frame_source) |
- : layer_tree_host_id(layer_tree_host_id), |
- next_commit_waits_for_activation(false), |
- commit_completion_event(nullptr), |
- next_frame_is_newly_committed_frame(false), |
- inside_draw(false), |
- input_throttled_until_commit(false), |
- smoothness_priority_expiration_notifier( |
- proxy->task_runner_provider() |
- ->ImplThreadTaskRunner(), |
- base::Bind(&ThreadProxy::RenewTreePriority, base::Unretained(proxy)), |
- base::TimeDelta::FromMilliseconds( |
- kSmoothnessTakesPriorityExpirationDelay * 1000)), |
- external_begin_frame_source(external_begin_frame_source.Pass()), |
- rendering_stats_instrumentation(rendering_stats_instrumentation), |
- weak_factory(proxy) {} |
- |
-ThreadProxy::CompositorThreadOnly::~CompositorThreadOnly() {} |
- |
-ThreadProxy::~ThreadProxy() { |
- TRACE_EVENT0("cc", "ThreadProxy::~ThreadProxy"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(!main().started); |
-} |
- |
-void ThreadProxy::SetChannel(scoped_ptr<ThreadedChannel> threaded_channel) { |
- threaded_channel_ = threaded_channel.Pass(); |
- main().channel_main = threaded_channel_.get(); |
-} |
- |
-void ThreadProxy::FinishAllRendering() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(!main().defer_commits); |
- |
- // Make sure all GL drawing is finished on the impl thread. |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- CompletionEvent completion; |
- main().channel_main->FinishAllRenderingOnImpl(&completion); |
- completion.Wait(); |
-} |
- |
-bool ThreadProxy::IsStarted() const { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- return main().started; |
-} |
- |
-bool ThreadProxy::CommitToActiveTree() const { |
- // With ThreadProxy, we use a pending tree and activate it once it's ready to |
- // draw to allow input to modify the active tree and draw during raster. |
- return false; |
-} |
- |
-void ThreadProxy::SetVisible(bool visible) { |
- TRACE_EVENT1("cc", "ThreadProxy::SetVisible", "visible", visible); |
- main().channel_main->SetVisibleOnImpl(visible); |
-} |
- |
-void ThreadProxy::SetVisibleOnImpl(bool visible) { |
- TRACE_EVENT1("cc", "ThreadProxy::SetVisibleOnImplThread", "visible", visible); |
- impl().layer_tree_host_impl->SetVisible(visible); |
- impl().scheduler->SetVisible(visible); |
-} |
- |
-void ThreadProxy::SetThrottleFrameProduction(bool throttle) { |
- TRACE_EVENT1("cc", "ThreadProxy::SetThrottleFrameProduction", "throttle", |
- throttle); |
- main().channel_main->SetThrottleFrameProductionOnImpl(throttle); |
-} |
- |
-void ThreadProxy::SetThrottleFrameProductionOnImpl(bool throttle) { |
- TRACE_EVENT1("cc", "ThreadProxy::SetThrottleFrameProductionOnImplThread", |
- "throttle", throttle); |
- impl().scheduler->SetThrottleFrameProduction(throttle); |
-} |
- |
-void ThreadProxy::DidLoseOutputSurface() { |
- TRACE_EVENT0("cc", "ThreadProxy::DidLoseOutputSurface"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->DidLoseOutputSurface(); |
-} |
- |
-void ThreadProxy::RequestNewOutputSurface() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->RequestNewOutputSurface(); |
-} |
- |
-void ThreadProxy::SetOutputSurface(OutputSurface* output_surface) { |
- main().channel_main->InitializeOutputSurfaceOnImpl(output_surface); |
-} |
- |
-void ThreadProxy::ReleaseOutputSurface() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(main().layer_tree_host->output_surface_lost()); |
- |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- CompletionEvent completion; |
- main().channel_main->ReleaseOutputSurfaceOnImpl(&completion); |
- completion.Wait(); |
-} |
- |
-void ThreadProxy::DidInitializeOutputSurface( |
- bool success, |
- const RendererCapabilities& capabilities) { |
- TRACE_EVENT0("cc", "ThreadProxy::DidInitializeOutputSurface"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- |
- if (!success) { |
- main().layer_tree_host->DidFailToInitializeOutputSurface(); |
- return; |
- } |
- main().renderer_capabilities_main_thread_copy = capabilities; |
- main().layer_tree_host->DidInitializeOutputSurface(); |
-} |
- |
-void ThreadProxy::SetRendererCapabilitiesMainCopy( |
- const RendererCapabilities& capabilities) { |
- main().renderer_capabilities_main_thread_copy = capabilities; |
-} |
- |
-bool ThreadProxy::SendCommitRequestToImplThreadIfNeeded( |
- CommitPipelineStage required_stage) { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK_NE(NO_PIPELINE_STAGE, required_stage); |
- bool already_posted = |
- main().max_requested_pipeline_stage != NO_PIPELINE_STAGE; |
- main().max_requested_pipeline_stage = |
- std::max(main().max_requested_pipeline_stage, required_stage); |
- if (already_posted) |
- return false; |
- main().channel_main->SetNeedsCommitOnImpl(); |
- return true; |
-} |
- |
-void ThreadProxy::SetNeedsCommitOnImpl() { |
- SetNeedsCommitOnImplThread(); |
-} |
- |
-void ThreadProxy::DidCompletePageScaleAnimation() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->DidCompletePageScaleAnimation(); |
-} |
- |
-const RendererCapabilities& ThreadProxy::GetRendererCapabilities() const { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(!main().layer_tree_host->output_surface_lost()); |
- return main().renderer_capabilities_main_thread_copy; |
-} |
- |
-void ThreadProxy::SetNeedsAnimate() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- if (SendCommitRequestToImplThreadIfNeeded(ANIMATE_PIPELINE_STAGE)) { |
- TRACE_EVENT_INSTANT0("cc", "ThreadProxy::SetNeedsAnimate", |
- TRACE_EVENT_SCOPE_THREAD); |
- } |
-} |
- |
-void ThreadProxy::SetNeedsUpdateLayers() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- // If we are currently animating, make sure we also update the layers. |
- if (main().current_pipeline_stage == ANIMATE_PIPELINE_STAGE) { |
- main().final_pipeline_stage = |
- std::max(main().final_pipeline_stage, UPDATE_LAYERS_PIPELINE_STAGE); |
- return; |
- } |
- if (SendCommitRequestToImplThreadIfNeeded(UPDATE_LAYERS_PIPELINE_STAGE)) { |
- TRACE_EVENT_INSTANT0("cc", "ThreadProxy::SetNeedsUpdateLayers", |
- TRACE_EVENT_SCOPE_THREAD); |
- } |
-} |
- |
-void ThreadProxy::SetNeedsCommit() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- // If we are currently animating, make sure we don't skip the commit. Note |
- // that requesting a commit during the layer update stage means we need to |
- // schedule another full commit. |
- if (main().current_pipeline_stage == ANIMATE_PIPELINE_STAGE) { |
- main().final_pipeline_stage = |
- std::max(main().final_pipeline_stage, COMMIT_PIPELINE_STAGE); |
- return; |
- } |
- if (SendCommitRequestToImplThreadIfNeeded(COMMIT_PIPELINE_STAGE)) { |
- TRACE_EVENT_INSTANT0("cc", "ThreadProxy::SetNeedsCommit", |
- TRACE_EVENT_SCOPE_THREAD); |
- } |
-} |
- |
-void ThreadProxy::UpdateRendererCapabilitiesOnImplThread() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->SetRendererCapabilitiesMainCopy( |
- impl() |
- .layer_tree_host_impl->GetRendererCapabilities() |
- .MainThreadCapabilities()); |
-} |
- |
-void ThreadProxy::DidLoseOutputSurfaceOnImplThread() { |
- TRACE_EVENT0("cc", "ThreadProxy::DidLoseOutputSurfaceOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->DidLoseOutputSurface(); |
- impl().scheduler->DidLoseOutputSurface(); |
-} |
- |
-void ThreadProxy::CommitVSyncParameters(base::TimeTicks timebase, |
- base::TimeDelta interval) { |
- impl().scheduler->CommitVSyncParameters(timebase, interval); |
-} |
- |
-void ThreadProxy::SetEstimatedParentDrawTime(base::TimeDelta draw_time) { |
- impl().scheduler->SetEstimatedParentDrawTime(draw_time); |
-} |
- |
-void ThreadProxy::SetMaxSwapsPendingOnImplThread(int max) { |
- impl().scheduler->SetMaxSwapsPending(max); |
-} |
- |
-void ThreadProxy::DidSwapBuffersOnImplThread() { |
- impl().scheduler->DidSwapBuffers(); |
-} |
- |
-void ThreadProxy::DidSwapBuffersCompleteOnImplThread() { |
- TRACE_EVENT0("cc,benchmark", |
- "ThreadProxy::DidSwapBuffersCompleteOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->DidSwapBuffersComplete(); |
- impl().channel_impl->DidCompleteSwapBuffers(); |
-} |
- |
-void ThreadProxy::WillBeginImplFrame(const BeginFrameArgs& args) { |
- impl().layer_tree_host_impl->WillBeginImplFrame(args); |
- if (impl().last_processed_begin_main_frame_args.IsValid()) { |
- // Last processed begin main frame args records the frame args that we sent |
- // to the main thread for the last frame that we've processed. If that is |
- // set, that means the current frame is one past the frame in which we've |
- // finished the processing. |
- impl().layer_tree_host_impl->RecordMainFrameTiming( |
- impl().last_processed_begin_main_frame_args, args); |
- impl().last_processed_begin_main_frame_args = BeginFrameArgs(); |
- } |
-} |
- |
-void ThreadProxy::OnResourcelessSoftareDrawStateChanged( |
- bool resourceless_draw) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetResourcelessSoftareDraw(resourceless_draw); |
-} |
- |
-void ThreadProxy::OnCanDrawStateChanged(bool can_draw) { |
- TRACE_EVENT1( |
- "cc", "ThreadProxy::OnCanDrawStateChanged", "can_draw", can_draw); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetCanDraw(can_draw); |
-} |
- |
-void ThreadProxy::NotifyReadyToActivate() { |
- TRACE_EVENT0("cc", "ThreadProxy::NotifyReadyToActivate"); |
- impl().scheduler->NotifyReadyToActivate(); |
-} |
- |
-void ThreadProxy::NotifyReadyToDraw() { |
- TRACE_EVENT0("cc", "ThreadProxy::NotifyReadyToDraw"); |
- impl().scheduler->NotifyReadyToDraw(); |
-} |
- |
-void ThreadProxy::SetNeedsCommitOnImplThread() { |
- TRACE_EVENT0("cc", "ThreadProxy::SetNeedsCommitOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetNeedsBeginMainFrame(); |
-} |
- |
-void ThreadProxy::SetVideoNeedsBeginFrames(bool needs_begin_frames) { |
- TRACE_EVENT1("cc", "ThreadProxy::SetVideoNeedsBeginFrames", |
- "needs_begin_frames", needs_begin_frames); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- // In tests the layer tree is destroyed after the scheduler is. |
- if (impl().scheduler) |
- impl().scheduler->SetVideoNeedsBeginFrames(needs_begin_frames); |
-} |
- |
-void ThreadProxy::PostAnimationEventsToMainThreadOnImplThread( |
- scoped_ptr<AnimationEventsVector> events) { |
- TRACE_EVENT0("cc", |
- "ThreadProxy::PostAnimationEventsToMainThreadOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->SetAnimationEvents(events.Pass()); |
-} |
- |
-bool ThreadProxy::IsInsideDraw() { return impl().inside_draw; } |
- |
-void ThreadProxy::SetNeedsRedraw(const gfx::Rect& damage_rect) { |
- TRACE_EVENT0("cc", "ThreadProxy::SetNeedsRedraw"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().channel_main->SetNeedsRedrawOnImpl(damage_rect); |
-} |
- |
-void ThreadProxy::SetNeedsRedrawOnImpl(const gfx::Rect& damage_rect) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- SetNeedsRedrawRectOnImplThread(damage_rect); |
-} |
- |
-void ThreadProxy::SetNextCommitWaitsForActivation() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().commit_waits_for_activation = true; |
-} |
- |
-void ThreadProxy::SetDeferCommits(bool defer_commits) { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- if (main().defer_commits == defer_commits) |
- return; |
- |
- main().defer_commits = defer_commits; |
- if (main().defer_commits) |
- TRACE_EVENT_ASYNC_BEGIN0("cc", "ThreadProxy::SetDeferCommits", this); |
- else |
- TRACE_EVENT_ASYNC_END0("cc", "ThreadProxy::SetDeferCommits", this); |
- |
- main().channel_main->SetDeferCommitsOnImpl(defer_commits); |
-} |
- |
-void ThreadProxy::SetDeferCommitsOnImpl(bool defer_commits) const { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetDeferCommits(defer_commits); |
-} |
- |
-bool ThreadProxy::CommitRequested() const { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- // TODO(skyostil): Split this into something like CommitRequested() and |
- // CommitInProgress(). |
- return main().current_pipeline_stage != NO_PIPELINE_STAGE || |
- main().max_requested_pipeline_stage >= COMMIT_PIPELINE_STAGE; |
-} |
- |
-bool ThreadProxy::BeginMainFrameRequested() const { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- return main().max_requested_pipeline_stage != NO_PIPELINE_STAGE; |
-} |
- |
-void ThreadProxy::SetNeedsRedrawOnImplThread() { |
- TRACE_EVENT0("cc", "ThreadProxy::SetNeedsRedrawOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetNeedsRedraw(); |
-} |
- |
-void ThreadProxy::SetNeedsAnimateOnImplThread() { |
- TRACE_EVENT0("cc", "ThreadProxy::SetNeedsAnimateOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetNeedsAnimate(); |
-} |
- |
-void ThreadProxy::SetNeedsPrepareTilesOnImplThread() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->SetNeedsPrepareTiles(); |
-} |
- |
-void ThreadProxy::SetNeedsRedrawRectOnImplThread(const gfx::Rect& damage_rect) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().layer_tree_host_impl->SetViewportDamage(damage_rect); |
- SetNeedsRedrawOnImplThread(); |
-} |
- |
-void ThreadProxy::MainThreadHasStoppedFlinging() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().channel_main->MainThreadHasStoppedFlingingOnImpl(); |
-} |
- |
-void ThreadProxy::MainThreadHasStoppedFlingingOnImpl() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().layer_tree_host_impl->MainThreadHasStoppedFlinging(); |
-} |
- |
-void ThreadProxy::NotifyInputThrottledUntilCommit() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().channel_main->SetInputThrottledUntilCommitOnImpl(true); |
-} |
- |
-void ThreadProxy::SetInputThrottledUntilCommitOnImpl(bool is_throttled) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- if (is_throttled == impl().input_throttled_until_commit) |
- return; |
- impl().input_throttled_until_commit = is_throttled; |
- RenewTreePriority(); |
-} |
- |
-ThreadProxy::MainThreadOnly& ThreadProxy::main() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- return main_thread_only_vars_unsafe_; |
-} |
-const ThreadProxy::MainThreadOnly& ThreadProxy::main() const { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- return main_thread_only_vars_unsafe_; |
-} |
- |
-ThreadProxy::BlockedMainCommitOnly& ThreadProxy::blocked_main_commit() { |
- DCHECK(impl().commit_completion_event); |
- DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
- return main_thread_blocked_commit_vars_unsafe_; |
-} |
- |
-ThreadProxy::CompositorThreadOnly& ThreadProxy::impl() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- return compositor_thread_vars_unsafe_; |
-} |
- |
-const ThreadProxy::CompositorThreadOnly& ThreadProxy::impl() const { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- return compositor_thread_vars_unsafe_; |
-} |
- |
-void ThreadProxy::Start() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(task_runner_provider_->HasImplThread()); |
- |
- // Create LayerTreeHostImpl. |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- CompletionEvent completion; |
- main().channel_main->InitializeImplOnImpl(&completion, |
- main().layer_tree_host); |
- completion.Wait(); |
- |
- main_thread_weak_ptr_ = main().weak_factory.GetWeakPtr(); |
- |
- main().started = true; |
-} |
- |
-void ThreadProxy::Stop() { |
- TRACE_EVENT0("cc", "ThreadProxy::Stop"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK(main().started); |
- |
- // Synchronously finishes pending GL operations and deletes the impl. |
- // The two steps are done as separate post tasks, so that tasks posted |
- // by the GL implementation due to the Finish can be executed by the |
- // renderer before shutting it down. |
- { |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- CompletionEvent completion; |
- main().channel_main->FinishGLOnImpl(&completion); |
- completion.Wait(); |
- } |
- { |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- |
- CompletionEvent completion; |
- main().channel_main->LayerTreeHostClosedOnImpl(&completion); |
- completion.Wait(); |
- } |
- |
- main().weak_factory.InvalidateWeakPtrs(); |
- main().layer_tree_host = nullptr; |
- main().started = false; |
-} |
- |
-bool ThreadProxy::SupportsImplScrolling() const { |
- return true; |
-} |
- |
-void ThreadProxy::FinishAllRenderingOnImpl(CompletionEvent* completion) { |
- TRACE_EVENT0("cc", "ThreadProxy::FinishAllRenderingOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().layer_tree_host_impl->FinishAllRendering(); |
- completion->Signal(); |
-} |
- |
-void ThreadProxy::ScheduledActionSendBeginMainFrame( |
- const BeginFrameArgs& args) { |
- unsigned int begin_frame_id = nextBeginFrameId++; |
- benchmark_instrumentation::ScopedBeginFrameTask begin_frame_task( |
- benchmark_instrumentation::kSendBeginFrame, begin_frame_id); |
- scoped_ptr<BeginMainFrameAndCommitState> begin_main_frame_state( |
- new BeginMainFrameAndCommitState); |
- begin_main_frame_state->begin_frame_id = begin_frame_id; |
- begin_main_frame_state->begin_frame_args = args; |
- begin_main_frame_state->scroll_info = |
- impl().layer_tree_host_impl->ProcessScrollDeltas(); |
- begin_main_frame_state->memory_allocation_limit_bytes = |
- impl().layer_tree_host_impl->memory_allocation_limit_bytes(); |
- begin_main_frame_state->evicted_ui_resources = |
- impl().layer_tree_host_impl->EvictedUIResourcesExist(); |
- // TODO(vmpstr): This needs to be fixed if |
- // main_frame_before_activation_enabled is set, since we might run this code |
- // twice before recording a duration. crbug.com/469824 |
- impl().last_begin_main_frame_args = begin_main_frame_state->begin_frame_args; |
- impl().channel_impl->BeginMainFrame(begin_main_frame_state.Pass()); |
- devtools_instrumentation::DidRequestMainThreadFrame( |
- impl().layer_tree_host_id); |
-} |
- |
-void ThreadProxy::SendBeginMainFrameNotExpectedSoon() { |
- impl().channel_impl->BeginMainFrameNotExpectedSoon(); |
-} |
- |
-void ThreadProxy::BeginMainFrame( |
- scoped_ptr<BeginMainFrameAndCommitState> begin_main_frame_state) { |
- benchmark_instrumentation::ScopedBeginFrameTask begin_frame_task( |
- benchmark_instrumentation::kDoBeginFrame, |
- begin_main_frame_state->begin_frame_id); |
- |
- base::TimeTicks begin_main_frame_start_time = base::TimeTicks::Now(); |
- |
- TRACE_EVENT_SYNTHETIC_DELAY_BEGIN("cc.BeginMainFrame"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- DCHECK_EQ(NO_PIPELINE_STAGE, main().current_pipeline_stage); |
- |
- if (main().defer_commits) { |
- TRACE_EVENT_INSTANT0("cc", "EarlyOut_DeferCommit", |
- TRACE_EVENT_SCOPE_THREAD); |
- main().channel_main->BeginMainFrameAbortedOnImpl( |
- CommitEarlyOutReason::ABORTED_DEFERRED_COMMIT, |
- begin_main_frame_start_time); |
- return; |
- } |
- |
- // If the commit finishes, LayerTreeHost will transfer its swap promises to |
- // LayerTreeImpl. The destructor of ScopedSwapPromiseChecker aborts the |
- // remaining swap promises. |
- ScopedAbortRemainingSwapPromises swap_promise_checker(main().layer_tree_host); |
- |
- main().final_pipeline_stage = main().max_requested_pipeline_stage; |
- main().max_requested_pipeline_stage = NO_PIPELINE_STAGE; |
- |
- if (!main().layer_tree_host->visible()) { |
- TRACE_EVENT_INSTANT0("cc", "EarlyOut_NotVisible", TRACE_EVENT_SCOPE_THREAD); |
- main().channel_main->BeginMainFrameAbortedOnImpl( |
- CommitEarlyOutReason::ABORTED_NOT_VISIBLE, begin_main_frame_start_time); |
- return; |
- } |
- |
- if (main().layer_tree_host->output_surface_lost()) { |
- TRACE_EVENT_INSTANT0( |
- "cc", "EarlyOut_OutputSurfaceLost", TRACE_EVENT_SCOPE_THREAD); |
- main().channel_main->BeginMainFrameAbortedOnImpl( |
- CommitEarlyOutReason::ABORTED_OUTPUT_SURFACE_LOST, |
- begin_main_frame_start_time); |
- return; |
- } |
- |
- main().current_pipeline_stage = ANIMATE_PIPELINE_STAGE; |
- |
- main().layer_tree_host->ApplyScrollAndScale( |
- begin_main_frame_state->scroll_info.get()); |
- |
- main().layer_tree_host->WillBeginMainFrame(); |
- |
- main().layer_tree_host->BeginMainFrame( |
- begin_main_frame_state->begin_frame_args); |
- main().layer_tree_host->AnimateLayers( |
- begin_main_frame_state->begin_frame_args.frame_time); |
- |
- // Recreate all UI resources if there were evicted UI resources when the impl |
- // thread initiated the commit. |
- if (begin_main_frame_state->evicted_ui_resources) |
- main().layer_tree_host->RecreateUIResources(); |
- |
- main().layer_tree_host->RequestMainFrameUpdate(); |
- TRACE_EVENT_SYNTHETIC_DELAY_END("cc.BeginMainFrame"); |
- |
- bool can_cancel_this_commit = |
- main().final_pipeline_stage < COMMIT_PIPELINE_STAGE && |
- !begin_main_frame_state->evicted_ui_resources; |
- |
- main().current_pipeline_stage = UPDATE_LAYERS_PIPELINE_STAGE; |
- bool should_update_layers = |
- main().final_pipeline_stage >= UPDATE_LAYERS_PIPELINE_STAGE; |
- bool updated = should_update_layers && main().layer_tree_host->UpdateLayers(); |
- |
- main().layer_tree_host->WillCommit(); |
- devtools_instrumentation::ScopedCommitTrace commit_task( |
- main().layer_tree_host->id()); |
- |
- main().current_pipeline_stage = COMMIT_PIPELINE_STAGE; |
- if (!updated && can_cancel_this_commit) { |
- TRACE_EVENT_INSTANT0("cc", "EarlyOut_NoUpdates", TRACE_EVENT_SCOPE_THREAD); |
- main().channel_main->BeginMainFrameAbortedOnImpl( |
- CommitEarlyOutReason::FINISHED_NO_UPDATES, begin_main_frame_start_time); |
- |
- // Although the commit is internally aborted, this is because it has been |
- // detected to be a no-op. From the perspective of an embedder, this commit |
- // went through, and input should no longer be throttled, etc. |
- main().current_pipeline_stage = NO_PIPELINE_STAGE; |
- main().layer_tree_host->CommitComplete(); |
- main().layer_tree_host->DidBeginMainFrame(); |
- main().layer_tree_host->BreakSwapPromises(SwapPromise::COMMIT_NO_UPDATE); |
- return; |
- } |
- |
- // Notify the impl thread that the main thread is ready to commit. This will |
- // begin the commit process, which is blocking from the main thread's |
- // point of view, but asynchronously performed on the impl thread, |
- // coordinated by the Scheduler. |
- { |
- TRACE_EVENT0("cc", "ThreadProxy::BeginMainFrame::commit"); |
- |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- |
- // This CapturePostTasks should be destroyed before CommitComplete() is |
- // called since that goes out to the embedder, and we want the embedder |
- // to receive its callbacks before that. |
- BlockingTaskRunner::CapturePostTasks blocked( |
- task_runner_provider_->blocking_main_thread_task_runner()); |
- |
- CompletionEvent completion; |
- main().channel_main->StartCommitOnImpl(&completion, main().layer_tree_host, |
- begin_main_frame_start_time, |
- main().commit_waits_for_activation); |
- completion.Wait(); |
- main().commit_waits_for_activation = false; |
- } |
- |
- main().current_pipeline_stage = NO_PIPELINE_STAGE; |
- main().layer_tree_host->CommitComplete(); |
- main().layer_tree_host->DidBeginMainFrame(); |
-} |
- |
-void ThreadProxy::BeginMainFrameNotExpectedSoon() { |
- TRACE_EVENT0("cc", "ThreadProxy::BeginMainFrameNotExpectedSoon"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->BeginMainFrameNotExpectedSoon(); |
-} |
- |
-void ThreadProxy::StartCommitOnImpl(CompletionEvent* completion, |
- LayerTreeHost* layer_tree_host, |
- base::TimeTicks main_thread_start_time, |
- bool hold_commit_for_activation) { |
- TRACE_EVENT0("cc", "ThreadProxy::StartCommitOnImplThread"); |
- DCHECK(!impl().commit_completion_event); |
- DCHECK(task_runner_provider_->IsImplThread() && |
- task_runner_provider_->IsMainThreadBlocked()); |
- DCHECK(impl().scheduler); |
- DCHECK(impl().scheduler->CommitPending()); |
- |
- if (hold_commit_for_activation) { |
- // This commit may be aborted. Store the value for |
- // hold_commit_for_activation so that whenever the next commit is started, |
- // the main thread will be unblocked only after pending tree activation. |
- impl().next_commit_waits_for_activation = hold_commit_for_activation; |
- } |
- |
- if (!impl().layer_tree_host_impl) { |
- TRACE_EVENT_INSTANT0( |
- "cc", "EarlyOut_NoLayerTree", TRACE_EVENT_SCOPE_THREAD); |
- completion->Signal(); |
- return; |
- } |
- |
- // Ideally, we should inform to impl thread when BeginMainFrame is started. |
- // But, we can avoid a PostTask in here. |
- impl().scheduler->NotifyBeginMainFrameStarted(main_thread_start_time); |
- impl().commit_completion_event = completion; |
- DCHECK(!blocked_main_commit().layer_tree_host); |
- blocked_main_commit().layer_tree_host = layer_tree_host; |
- impl().scheduler->NotifyReadyToCommit(); |
-} |
- |
-void ThreadProxy::BeginMainFrameAbortedOnImpl( |
- CommitEarlyOutReason reason, |
- base::TimeTicks main_thread_start_time) { |
- TRACE_EVENT1("cc", "ThreadProxy::BeginMainFrameAbortedOnImplThread", "reason", |
- CommitEarlyOutReasonToString(reason)); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- DCHECK(impl().scheduler); |
- DCHECK(impl().scheduler->CommitPending()); |
- DCHECK(!impl().layer_tree_host_impl->pending_tree()); |
- |
- if (CommitEarlyOutHandledCommit(reason)) { |
- SetInputThrottledUntilCommitOnImpl(false); |
- impl().last_processed_begin_main_frame_args = |
- impl().last_begin_main_frame_args; |
- } |
- impl().layer_tree_host_impl->BeginMainFrameAborted(reason); |
- impl().scheduler->NotifyBeginMainFrameStarted(main_thread_start_time); |
- impl().scheduler->BeginMainFrameAborted(reason); |
-} |
- |
-void ThreadProxy::ScheduledActionAnimate() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionAnimate"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- |
- impl().layer_tree_host_impl->Animate(); |
-} |
- |
-void ThreadProxy::ScheduledActionCommit() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionCommit"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
- DCHECK(impl().commit_completion_event); |
- DCHECK(blocked_main_commit().layer_tree_host); |
- |
- impl().layer_tree_host_impl->BeginCommit(); |
- blocked_main_commit().layer_tree_host->FinishCommitOnImplThread( |
- impl().layer_tree_host_impl.get()); |
- |
- // Remove the LayerTreeHost reference before the completion event is signaled |
- // and cleared. This is necessary since blocked_main_commit() allows access |
- // only while we have the completion event to ensure the main thread is |
- // blocked for a commit. |
- blocked_main_commit().layer_tree_host = nullptr; |
- |
- if (impl().next_commit_waits_for_activation) { |
- // For some layer types in impl-side painting, the commit is held until |
- // the sync tree is activated. It's also possible that the |
- // sync tree has already activated if there was no work to be done. |
- TRACE_EVENT_INSTANT0("cc", "HoldCommit", TRACE_EVENT_SCOPE_THREAD); |
- } else { |
- impl().commit_completion_event->Signal(); |
- impl().commit_completion_event = nullptr; |
- } |
- |
- impl().scheduler->DidCommit(); |
- |
- // Delay this step until afer the main thread has been released as it's |
- // often a good bit of work to update the tree and prepare the new frame. |
- impl().layer_tree_host_impl->CommitComplete(); |
- |
- SetInputThrottledUntilCommitOnImpl(false); |
- |
- impl().next_frame_is_newly_committed_frame = true; |
-} |
- |
-void ThreadProxy::ScheduledActionActivateSyncTree() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionActivateSyncTree"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().layer_tree_host_impl->ActivateSyncTree(); |
-} |
- |
-void ThreadProxy::ScheduledActionBeginOutputSurfaceCreation() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionBeginOutputSurfaceCreation"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->RequestNewOutputSurface(); |
-} |
- |
-DrawResult ThreadProxy::DrawSwapInternal(bool forced_draw) { |
- TRACE_EVENT_SYNTHETIC_DELAY("cc.DrawAndSwap"); |
- DrawResult result; |
- |
- DCHECK(task_runner_provider_->IsImplThread()); |
- DCHECK(impl().layer_tree_host_impl.get()); |
- |
- base::AutoReset<bool> mark_inside(&impl().inside_draw, true); |
- |
- if (impl().layer_tree_host_impl->pending_tree()) { |
- bool update_lcd_text = false; |
- impl().layer_tree_host_impl->pending_tree()->UpdateDrawProperties( |
- update_lcd_text); |
- } |
- |
- // This method is called on a forced draw, regardless of whether we are able |
- // to produce a frame, as the calling site on main thread is blocked until its |
- // request completes, and we signal completion here. If CanDraw() is false, we |
- // will indicate success=false to the caller, but we must still signal |
- // completion to avoid deadlock. |
- |
- // We guard PrepareToDraw() with CanDraw() because it always returns a valid |
- // frame, so can only be used when such a frame is possible. Since |
- // DrawLayers() depends on the result of PrepareToDraw(), it is guarded on |
- // CanDraw() as well. |
- |
- LayerTreeHostImpl::FrameData frame; |
- bool draw_frame = false; |
- |
- if (impl().layer_tree_host_impl->CanDraw()) { |
- result = impl().layer_tree_host_impl->PrepareToDraw(&frame); |
- draw_frame = forced_draw || result == DRAW_SUCCESS; |
- } else { |
- result = DRAW_ABORTED_CANT_DRAW; |
- } |
- |
- if (draw_frame) { |
- impl().layer_tree_host_impl->DrawLayers(&frame); |
- result = DRAW_SUCCESS; |
- } else { |
- DCHECK_NE(DRAW_SUCCESS, result); |
- } |
- impl().layer_tree_host_impl->DidDrawAllLayers(frame); |
- |
- bool start_ready_animations = draw_frame; |
- impl().layer_tree_host_impl->UpdateAnimationState(start_ready_animations); |
- |
- if (draw_frame) |
- impl().layer_tree_host_impl->SwapBuffers(frame); |
- |
- // Tell the main thread that the the newly-commited frame was drawn. |
- if (impl().next_frame_is_newly_committed_frame) { |
- impl().next_frame_is_newly_committed_frame = false; |
- impl().channel_impl->DidCommitAndDrawFrame(); |
- } |
- |
- DCHECK_NE(INVALID_RESULT, result); |
- return result; |
-} |
- |
-void ThreadProxy::ScheduledActionPrepareTiles() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionPrepareTiles"); |
- impl().layer_tree_host_impl->PrepareTiles(); |
-} |
- |
-DrawResult ThreadProxy::ScheduledActionDrawAndSwapIfPossible() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionDrawAndSwap"); |
- |
- // SchedulerStateMachine::DidDrawIfPossibleCompleted isn't set up to |
- // handle DRAW_ABORTED_CANT_DRAW. Moreover, the scheduler should |
- // never generate this call when it can't draw. |
- DCHECK(impl().layer_tree_host_impl->CanDraw()); |
- |
- bool forced_draw = false; |
- return DrawSwapInternal(forced_draw); |
-} |
- |
-DrawResult ThreadProxy::ScheduledActionDrawAndSwapForced() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionDrawAndSwapForced"); |
- bool forced_draw = true; |
- return DrawSwapInternal(forced_draw); |
-} |
- |
-void ThreadProxy::ScheduledActionInvalidateOutputSurface() { |
- TRACE_EVENT0("cc", "ThreadProxy::ScheduledActionInvalidateOutputSurface"); |
- DCHECK(impl().layer_tree_host_impl->output_surface()); |
- impl().layer_tree_host_impl->output_surface()->Invalidate(); |
-} |
- |
-void ThreadProxy::DidFinishImplFrame() { |
- impl().layer_tree_host_impl->DidFinishImplFrame(); |
-} |
- |
-void ThreadProxy::SendBeginFramesToChildren(const BeginFrameArgs& args) { |
- NOTREACHED() << "Only used by SingleThreadProxy"; |
-} |
- |
-void ThreadProxy::SetAuthoritativeVSyncInterval( |
- const base::TimeDelta& interval) { |
- NOTREACHED() << "Only used by SingleThreadProxy"; |
-} |
- |
-void ThreadProxy::DidCommitAndDrawFrame() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->DidCommitAndDrawFrame(); |
-} |
- |
-void ThreadProxy::DidCompleteSwapBuffers() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->DidCompleteSwapBuffers(); |
-} |
- |
-void ThreadProxy::SetAnimationEvents(scoped_ptr<AnimationEventsVector> events) { |
- TRACE_EVENT0("cc", "ThreadProxy::SetAnimationEvents"); |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->SetAnimationEvents(events.Pass()); |
-} |
- |
-void ThreadProxy::InitializeImplOnImpl(CompletionEvent* completion, |
- LayerTreeHost* layer_tree_host) { |
- TRACE_EVENT0("cc", "ThreadProxy::InitializeImplOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
- DCHECK(layer_tree_host); |
- |
- // TODO(khushalsagar): ThreadedChannel will create ProxyImpl here and pass a |
- // reference to itself. |
- impl().channel_impl = threaded_channel_.get(); |
- |
- impl().layer_tree_host_impl = layer_tree_host->CreateLayerTreeHostImpl(this); |
- |
- SchedulerSettings scheduler_settings( |
- layer_tree_host->settings().ToSchedulerSettings()); |
- |
- scoped_ptr<CompositorTimingHistory> compositor_timing_history( |
- new CompositorTimingHistory(CompositorTimingHistory::RENDERER_UMA, |
- impl().rendering_stats_instrumentation)); |
- |
- impl().scheduler = |
- Scheduler::Create(this, scheduler_settings, impl().layer_tree_host_id, |
- task_runner_provider_->ImplThreadTaskRunner(), |
- impl().external_begin_frame_source.get(), |
- compositor_timing_history.Pass()); |
- |
- DCHECK_EQ(impl().scheduler->visible(), |
- impl().layer_tree_host_impl->visible()); |
- impl_thread_weak_ptr_ = impl().weak_factory.GetWeakPtr(); |
- completion->Signal(); |
-} |
- |
-void ThreadProxy::InitializeOutputSurfaceOnImpl(OutputSurface* output_surface) { |
- TRACE_EVENT0("cc", "ThreadProxy::InitializeOutputSurfaceOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- |
- LayerTreeHostImpl* host_impl = impl().layer_tree_host_impl.get(); |
- bool success = host_impl->InitializeRenderer(output_surface); |
- RendererCapabilities capabilities; |
- if (success) { |
- capabilities = |
- host_impl->GetRendererCapabilities().MainThreadCapabilities(); |
- } |
- |
- impl().channel_impl->DidInitializeOutputSurface(success, capabilities); |
- |
- if (success) |
- impl().scheduler->DidCreateAndInitializeOutputSurface(); |
-} |
- |
-void ThreadProxy::ReleaseOutputSurfaceOnImpl(CompletionEvent* completion) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- |
- // Unlike DidLoseOutputSurfaceOnImplThread, we don't need to call |
- // LayerTreeHost::DidLoseOutputSurface since it already knows. |
- impl().scheduler->DidLoseOutputSurface(); |
- impl().layer_tree_host_impl->ReleaseOutputSurface(); |
- completion->Signal(); |
-} |
- |
-void ThreadProxy::FinishGLOnImpl(CompletionEvent* completion) { |
- TRACE_EVENT0("cc", "ThreadProxy::FinishGLOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- if (impl().layer_tree_host_impl->output_surface()) { |
- ContextProvider* context_provider = |
- impl().layer_tree_host_impl->output_surface()->context_provider(); |
- if (context_provider) |
- context_provider->ContextGL()->Finish(); |
- } |
- completion->Signal(); |
-} |
- |
-void ThreadProxy::LayerTreeHostClosedOnImpl(CompletionEvent* completion) { |
- TRACE_EVENT0("cc", "ThreadProxy::LayerTreeHostClosedOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
- impl().scheduler = nullptr; |
- impl().external_begin_frame_source = nullptr; |
- impl().layer_tree_host_impl = nullptr; |
- impl().weak_factory.InvalidateWeakPtrs(); |
- // We need to explicitly shutdown the notifier to destroy any weakptrs it is |
- // holding while still on the compositor thread. This also ensures any |
- // callbacks holding a ThreadProxy pointer are cancelled. |
- impl().smoothness_priority_expiration_notifier.Shutdown(); |
- completion->Signal(); |
-} |
- |
-bool ThreadProxy::MainFrameWillHappenForTesting() { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- bool main_frame_will_happen = false; |
- { |
- DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
- CompletionEvent completion; |
- main().channel_main->MainFrameWillHappenOnImplForTesting( |
- &completion, &main_frame_will_happen); |
- completion.Wait(); |
- } |
- return main_frame_will_happen; |
-} |
- |
-void ThreadProxy::SetChildrenNeedBeginFrames(bool children_need_begin_frames) { |
- NOTREACHED() << "Only used by SingleThreadProxy"; |
-} |
- |
-void ThreadProxy::MainFrameWillHappenOnImplForTesting( |
- CompletionEvent* completion, |
- bool* main_frame_will_happen) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- if (impl().layer_tree_host_impl->output_surface()) { |
- *main_frame_will_happen = impl().scheduler->MainFrameForTestingWillHappen(); |
- } else { |
- *main_frame_will_happen = false; |
- } |
- completion->Signal(); |
-} |
- |
-void ThreadProxy::RenewTreePriority() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- bool smoothness_takes_priority = |
- impl().layer_tree_host_impl->pinch_gesture_active() || |
- impl().layer_tree_host_impl->page_scale_animation_active() || |
- impl().layer_tree_host_impl->IsActivelyScrolling(); |
- |
- // Schedule expiration if smoothness currently takes priority. |
- if (smoothness_takes_priority) |
- impl().smoothness_priority_expiration_notifier.Schedule(); |
- |
- // We use the same priority for both trees by default. |
- TreePriority priority = SAME_PRIORITY_FOR_BOTH_TREES; |
- |
- // Smoothness takes priority if we have an expiration for it scheduled. |
- if (impl().smoothness_priority_expiration_notifier.HasPendingNotification()) |
- priority = SMOOTHNESS_TAKES_PRIORITY; |
- |
- // New content always takes priority when there is an invalid viewport size or |
- // ui resources have been evicted. |
- if (impl().layer_tree_host_impl->active_tree()->ViewportSizeInvalid() || |
- impl().layer_tree_host_impl->EvictedUIResourcesExist() || |
- impl().input_throttled_until_commit) { |
- // Once we enter NEW_CONTENTS_TAKES_PRIORITY mode, visible tiles on active |
- // tree might be freed. We need to set RequiresHighResToDraw to ensure that |
- // high res tiles will be required to activate pending tree. |
- impl().layer_tree_host_impl->SetRequiresHighResToDraw(); |
- priority = NEW_CONTENT_TAKES_PRIORITY; |
- } |
- |
- impl().layer_tree_host_impl->SetTreePriority(priority); |
- |
- // Only put the scheduler in impl latency prioritization mode if we don't |
- // have a scroll listener. This gives the scroll listener a better chance of |
- // handling scroll updates within the same frame. The tree itself is still |
- // kept in prefer smoothness mode to allow checkerboarding. |
- impl().scheduler->SetImplLatencyTakesPriority( |
- priority == SMOOTHNESS_TAKES_PRIORITY && |
- !impl().layer_tree_host_impl->scroll_affects_scroll_handler()); |
- |
- // Notify the the client of this compositor via the output surface. |
- // TODO(epenner): Route this to compositor-thread instead of output-surface |
- // after GTFO refactor of compositor-thread (http://crbug/170828). |
- if (impl().layer_tree_host_impl->output_surface()) { |
- impl() |
- .layer_tree_host_impl->output_surface() |
- ->UpdateSmoothnessTakesPriority(priority == SMOOTHNESS_TAKES_PRIORITY); |
- } |
-} |
- |
-void ThreadProxy::PostDelayedAnimationTaskOnImplThread( |
- const base::Closure& task, |
- base::TimeDelta delay) { |
- task_runner_provider_->ImplThreadTaskRunner()->PostDelayedTask(FROM_HERE, |
- task, delay); |
-} |
- |
-void ThreadProxy::DidActivateSyncTree() { |
- TRACE_EVENT0("cc", "ThreadProxy::DidActivateSyncTreeOnImplThread"); |
- DCHECK(task_runner_provider_->IsImplThread()); |
- |
- if (impl().next_commit_waits_for_activation) { |
- TRACE_EVENT_INSTANT0( |
- "cc", "ReleaseCommitbyActivation", TRACE_EVENT_SCOPE_THREAD); |
- DCHECK(impl().commit_completion_event); |
- impl().commit_completion_event->Signal(); |
- impl().commit_completion_event = nullptr; |
- impl().next_commit_waits_for_activation = false; |
- } |
- |
- impl().last_processed_begin_main_frame_args = |
- impl().last_begin_main_frame_args; |
-} |
- |
-void ThreadProxy::WillPrepareTiles() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->WillPrepareTiles(); |
-} |
- |
-void ThreadProxy::DidPrepareTiles() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->DidPrepareTiles(); |
-} |
- |
-void ThreadProxy::DidCompletePageScaleAnimationOnImplThread() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->DidCompletePageScaleAnimation(); |
-} |
- |
-void ThreadProxy::OnDrawForOutputSurface() { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().scheduler->OnDrawForOutputSurface(); |
-} |
- |
-void ThreadProxy::UpdateTopControlsState(TopControlsState constraints, |
- TopControlsState current, |
- bool animate) { |
- main().channel_main->UpdateTopControlsStateOnImpl(constraints, current, |
- animate); |
-} |
- |
-void ThreadProxy::UpdateTopControlsStateOnImpl(TopControlsState constraints, |
- TopControlsState current, |
- bool animate) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().layer_tree_host_impl->top_controls_manager()->UpdateTopControlsState( |
- constraints, current, animate); |
-} |
- |
-void ThreadProxy::PostFrameTimingEventsOnImplThread( |
- scoped_ptr<FrameTimingTracker::CompositeTimingSet> composite_events, |
- scoped_ptr<FrameTimingTracker::MainFrameTimingSet> main_frame_events) { |
- DCHECK(task_runner_provider_->IsImplThread()); |
- impl().channel_impl->PostFrameTimingEventsOnMain(composite_events.Pass(), |
- main_frame_events.Pass()); |
-} |
- |
-void ThreadProxy::PostFrameTimingEventsOnMain( |
- scoped_ptr<FrameTimingTracker::CompositeTimingSet> composite_events, |
- scoped_ptr<FrameTimingTracker::MainFrameTimingSet> main_frame_events) { |
- DCHECK(task_runner_provider_->IsMainThread()); |
- main().layer_tree_host->RecordFrameTimingEvents(composite_events.Pass(), |
- main_frame_events.Pass()); |
-} |
- |
-base::WeakPtr<ProxyMain> ThreadProxy::GetMainWeakPtr() { |
- return main_thread_weak_ptr_; |
-} |
- |
-base::WeakPtr<ProxyImpl> ThreadProxy::GetImplWeakPtr() { |
- return impl_thread_weak_ptr_; |
-} |
- |
-} // namespace cc |