| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "cc/trees/remote_channel_impl.h" | 5 #include "cc/trees/remote_channel_impl.h" |
| 6 | 6 |
| 7 #include "base/bind_helpers.h" | 7 #include "base/bind_helpers.h" |
| 8 #include "base/memory/ptr_util.h" |
| 8 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
| 9 #include "cc/animation/animation_events.h" | 10 #include "cc/animation/animation_events.h" |
| 10 #include "cc/proto/compositor_message.pb.h" | 11 #include "cc/proto/compositor_message.pb.h" |
| 11 #include "cc/proto/compositor_message_to_impl.pb.h" | 12 #include "cc/proto/compositor_message_to_impl.pb.h" |
| 12 #include "cc/proto/compositor_message_to_main.pb.h" | 13 #include "cc/proto/compositor_message_to_main.pb.h" |
| 13 #include "cc/proto/gfx_conversions.h" | 14 #include "cc/proto/gfx_conversions.h" |
| 14 #include "cc/trees/layer_tree_host.h" | 15 #include "cc/trees/layer_tree_host.h" |
| 15 #include "cc/trees/layer_tree_settings.h" | 16 #include "cc/trees/layer_tree_settings.h" |
| 16 | 17 |
| 17 namespace cc { | 18 namespace cc { |
| 18 | 19 |
| 19 scoped_ptr<RemoteChannelImpl> RemoteChannelImpl::Create( | 20 std::unique_ptr<RemoteChannelImpl> RemoteChannelImpl::Create( |
| 20 LayerTreeHost* layer_tree_host, | 21 LayerTreeHost* layer_tree_host, |
| 21 RemoteProtoChannel* remote_proto_channel, | 22 RemoteProtoChannel* remote_proto_channel, |
| 22 TaskRunnerProvider* task_runner_provider) { | 23 TaskRunnerProvider* task_runner_provider) { |
| 23 return make_scoped_ptr(new RemoteChannelImpl( | 24 return base::WrapUnique(new RemoteChannelImpl( |
| 24 layer_tree_host, remote_proto_channel, task_runner_provider)); | 25 layer_tree_host, remote_proto_channel, task_runner_provider)); |
| 25 } | 26 } |
| 26 | 27 |
| 27 RemoteChannelImpl::RemoteChannelImpl(LayerTreeHost* layer_tree_host, | 28 RemoteChannelImpl::RemoteChannelImpl(LayerTreeHost* layer_tree_host, |
| 28 RemoteProtoChannel* remote_proto_channel, | 29 RemoteProtoChannel* remote_proto_channel, |
| 29 TaskRunnerProvider* task_runner_provider) | 30 TaskRunnerProvider* task_runner_provider) |
| 30 : task_runner_provider_(task_runner_provider), | 31 : task_runner_provider_(task_runner_provider), |
| 31 main_thread_vars_unsafe_(this, layer_tree_host, remote_proto_channel), | 32 main_thread_vars_unsafe_(this, layer_tree_host, remote_proto_channel), |
| 32 compositor_thread_vars_unsafe_( | 33 compositor_thread_vars_unsafe_( |
| 33 main().remote_channel_weak_factory.GetWeakPtr()) { | 34 main().remote_channel_weak_factory.GetWeakPtr()) { |
| 34 DCHECK(task_runner_provider_->IsMainThread()); | 35 DCHECK(task_runner_provider_->IsMainThread()); |
| 35 | 36 |
| 36 main().remote_proto_channel->SetProtoReceiver(this); | 37 main().remote_proto_channel->SetProtoReceiver(this); |
| 37 } | 38 } |
| 38 | 39 |
| 39 RemoteChannelImpl::~RemoteChannelImpl() { | 40 RemoteChannelImpl::~RemoteChannelImpl() { |
| 40 DCHECK(task_runner_provider_->IsMainThread()); | 41 DCHECK(task_runner_provider_->IsMainThread()); |
| 41 DCHECK(!main().started); | 42 DCHECK(!main().started); |
| 42 | 43 |
| 43 main().remote_proto_channel->SetProtoReceiver(nullptr); | 44 main().remote_proto_channel->SetProtoReceiver(nullptr); |
| 44 } | 45 } |
| 45 | 46 |
| 46 scoped_ptr<ProxyImpl> RemoteChannelImpl::CreateProxyImpl( | 47 std::unique_ptr<ProxyImpl> RemoteChannelImpl::CreateProxyImpl( |
| 47 ChannelImpl* channel_impl, | 48 ChannelImpl* channel_impl, |
| 48 LayerTreeHost* layer_tree_host, | 49 LayerTreeHost* layer_tree_host, |
| 49 TaskRunnerProvider* task_runner_provider, | 50 TaskRunnerProvider* task_runner_provider, |
| 50 scoped_ptr<BeginFrameSource> external_begin_frame_source) { | 51 std::unique_ptr<BeginFrameSource> external_begin_frame_source) { |
| 51 DCHECK(task_runner_provider_->IsImplThread()); | 52 DCHECK(task_runner_provider_->IsImplThread()); |
| 52 DCHECK(!external_begin_frame_source); | 53 DCHECK(!external_begin_frame_source); |
| 53 return ProxyImpl::Create(channel_impl, layer_tree_host, task_runner_provider, | 54 return ProxyImpl::Create(channel_impl, layer_tree_host, task_runner_provider, |
| 54 std::move(external_begin_frame_source)); | 55 std::move(external_begin_frame_source)); |
| 55 } | 56 } |
| 56 | 57 |
| 57 void RemoteChannelImpl::OnProtoReceived( | 58 void RemoteChannelImpl::OnProtoReceived( |
| 58 scoped_ptr<proto::CompositorMessage> proto) { | 59 std::unique_ptr<proto::CompositorMessage> proto) { |
| 59 DCHECK(task_runner_provider_->IsMainThread()); | 60 DCHECK(task_runner_provider_->IsMainThread()); |
| 60 DCHECK(main().started); | 61 DCHECK(main().started); |
| 61 DCHECK(proto->has_to_impl()); | 62 DCHECK(proto->has_to_impl()); |
| 62 | 63 |
| 63 // If we don't have an output surface, queue the message and defer processing | 64 // If we don't have an output surface, queue the message and defer processing |
| 64 // it till we initialize a new output surface. | 65 // it till we initialize a new output surface. |
| 65 if (main().waiting_for_output_surface_initialization) { | 66 if (main().waiting_for_output_surface_initialization) { |
| 66 VLOG(1) << "Queueing message proto since output surface was released."; | 67 VLOG(1) << "Queueing message proto since output surface was released."; |
| 67 main().pending_messages.push(proto->to_impl()); | 68 main().pending_messages.push(proto->to_impl()); |
| 68 } else { | 69 } else { |
| (...skipping 177 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 246 NOTREACHED() << "Should not be called on the remote client LayerTreeHost"; | 247 NOTREACHED() << "Should not be called on the remote client LayerTreeHost"; |
| 247 return false; | 248 return false; |
| 248 } | 249 } |
| 249 | 250 |
| 250 bool RemoteChannelImpl::BeginMainFrameRequested() const { | 251 bool RemoteChannelImpl::BeginMainFrameRequested() const { |
| 251 NOTREACHED() << "Should not be called on the remote client LayerTreeHost"; | 252 NOTREACHED() << "Should not be called on the remote client LayerTreeHost"; |
| 252 return false; | 253 return false; |
| 253 } | 254 } |
| 254 | 255 |
| 255 void RemoteChannelImpl::Start( | 256 void RemoteChannelImpl::Start( |
| 256 scoped_ptr<BeginFrameSource> external_begin_frame_source) { | 257 std::unique_ptr<BeginFrameSource> external_begin_frame_source) { |
| 257 DCHECK(task_runner_provider_->IsMainThread()); | 258 DCHECK(task_runner_provider_->IsMainThread()); |
| 258 DCHECK(!main().started); | 259 DCHECK(!main().started); |
| 259 DCHECK(!external_begin_frame_source); | 260 DCHECK(!external_begin_frame_source); |
| 260 | 261 |
| 261 CompletionEvent completion; | 262 CompletionEvent completion; |
| 262 { | 263 { |
| 263 DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); | 264 DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_); |
| 264 ImplThreadTaskRunner()->PostTask( | 265 ImplThreadTaskRunner()->PostTask( |
| 265 FROM_HERE, base::Bind(&RemoteChannelImpl::InitializeImplOnImpl, | 266 FROM_HERE, base::Bind(&RemoteChannelImpl::InitializeImplOnImpl, |
| 266 base::Unretained(this), &completion, | 267 base::Unretained(this), &completion, |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 336 | 337 |
| 337 void RemoteChannelImpl::DidCompleteSwapBuffers() {} | 338 void RemoteChannelImpl::DidCompleteSwapBuffers() {} |
| 338 | 339 |
| 339 void RemoteChannelImpl::SetRendererCapabilitiesMainCopy( | 340 void RemoteChannelImpl::SetRendererCapabilitiesMainCopy( |
| 340 const RendererCapabilities& capabilities) {} | 341 const RendererCapabilities& capabilities) {} |
| 341 | 342 |
| 342 void RemoteChannelImpl::BeginMainFrameNotExpectedSoon() {} | 343 void RemoteChannelImpl::BeginMainFrameNotExpectedSoon() {} |
| 343 | 344 |
| 344 void RemoteChannelImpl::DidCommitAndDrawFrame() {} | 345 void RemoteChannelImpl::DidCommitAndDrawFrame() {} |
| 345 | 346 |
| 346 void RemoteChannelImpl::SetAnimationEvents(scoped_ptr<AnimationEvents> queue) {} | 347 void RemoteChannelImpl::SetAnimationEvents( |
| 348 std::unique_ptr<AnimationEvents> queue) {} |
| 347 | 349 |
| 348 void RemoteChannelImpl::DidLoseOutputSurface() { | 350 void RemoteChannelImpl::DidLoseOutputSurface() { |
| 349 DCHECK(task_runner_provider_->IsImplThread()); | 351 DCHECK(task_runner_provider_->IsImplThread()); |
| 350 | 352 |
| 351 MainThreadTaskRunner()->PostTask( | 353 MainThreadTaskRunner()->PostTask( |
| 352 FROM_HERE, base::Bind(&RemoteChannelImpl::DidLoseOutputSurfaceOnMain, | 354 FROM_HERE, base::Bind(&RemoteChannelImpl::DidLoseOutputSurfaceOnMain, |
| 353 impl().remote_channel_weak_ptr)); | 355 impl().remote_channel_weak_ptr)); |
| 354 } | 356 } |
| 355 | 357 |
| 356 void RemoteChannelImpl::RequestNewOutputSurface() { | 358 void RemoteChannelImpl::RequestNewOutputSurface() { |
| (...skipping 11 matching lines...) Expand all Loading... |
| 368 | 370 |
| 369 MainThreadTaskRunner()->PostTask( | 371 MainThreadTaskRunner()->PostTask( |
| 370 FROM_HERE, | 372 FROM_HERE, |
| 371 base::Bind(&RemoteChannelImpl::DidInitializeOutputSurfaceOnMain, | 373 base::Bind(&RemoteChannelImpl::DidInitializeOutputSurfaceOnMain, |
| 372 impl().remote_channel_weak_ptr, success, capabilities)); | 374 impl().remote_channel_weak_ptr, success, capabilities)); |
| 373 } | 375 } |
| 374 | 376 |
| 375 void RemoteChannelImpl::DidCompletePageScaleAnimation() {} | 377 void RemoteChannelImpl::DidCompletePageScaleAnimation() {} |
| 376 | 378 |
| 377 void RemoteChannelImpl::PostFrameTimingEventsOnMain( | 379 void RemoteChannelImpl::PostFrameTimingEventsOnMain( |
| 378 scoped_ptr<FrameTimingTracker::CompositeTimingSet> composite_events, | 380 std::unique_ptr<FrameTimingTracker::CompositeTimingSet> composite_events, |
| 379 scoped_ptr<FrameTimingTracker::MainFrameTimingSet> main_frame_events) {} | 381 std::unique_ptr<FrameTimingTracker::MainFrameTimingSet> main_frame_events) { |
| 382 } |
| 380 | 383 |
| 381 void RemoteChannelImpl::BeginMainFrame( | 384 void RemoteChannelImpl::BeginMainFrame( |
| 382 scoped_ptr<BeginMainFrameAndCommitState> begin_main_frame_state) { | 385 std::unique_ptr<BeginMainFrameAndCommitState> begin_main_frame_state) { |
| 383 scoped_ptr<proto::CompositorMessage> proto; | 386 std::unique_ptr<proto::CompositorMessage> proto; |
| 384 proto.reset(new proto::CompositorMessage); | 387 proto.reset(new proto::CompositorMessage); |
| 385 proto::CompositorMessageToMain* to_main_proto = proto->mutable_to_main(); | 388 proto::CompositorMessageToMain* to_main_proto = proto->mutable_to_main(); |
| 386 | 389 |
| 387 to_main_proto->set_message_type( | 390 to_main_proto->set_message_type( |
| 388 proto::CompositorMessageToMain::BEGIN_MAIN_FRAME); | 391 proto::CompositorMessageToMain::BEGIN_MAIN_FRAME); |
| 389 proto::BeginMainFrame* begin_main_frame_message = | 392 proto::BeginMainFrame* begin_main_frame_message = |
| 390 to_main_proto->mutable_begin_main_frame_message(); | 393 to_main_proto->mutable_begin_main_frame_message(); |
| 391 begin_main_frame_state->ToProtobuf( | 394 begin_main_frame_state->ToProtobuf( |
| 392 begin_main_frame_message->mutable_begin_main_frame_state()); | 395 begin_main_frame_message->mutable_begin_main_frame_state()); |
| 393 | 396 |
| 394 SendMessageProto(std::move(proto)); | 397 SendMessageProto(std::move(proto)); |
| 395 } | 398 } |
| 396 | 399 |
| 397 void RemoteChannelImpl::SendMessageProto( | 400 void RemoteChannelImpl::SendMessageProto( |
| 398 scoped_ptr<proto::CompositorMessage> proto) { | 401 std::unique_ptr<proto::CompositorMessage> proto) { |
| 399 DCHECK(task_runner_provider_->IsImplThread()); | 402 DCHECK(task_runner_provider_->IsImplThread()); |
| 400 | 403 |
| 401 MainThreadTaskRunner()->PostTask( | 404 MainThreadTaskRunner()->PostTask( |
| 402 FROM_HERE, | 405 FROM_HERE, |
| 403 base::Bind(&RemoteChannelImpl::SendMessageProtoOnMain, | 406 base::Bind(&RemoteChannelImpl::SendMessageProtoOnMain, |
| 404 impl().remote_channel_weak_ptr, base::Passed(&proto))); | 407 impl().remote_channel_weak_ptr, base::Passed(&proto))); |
| 405 } | 408 } |
| 406 | 409 |
| 407 void RemoteChannelImpl::DidLoseOutputSurfaceOnMain() { | 410 void RemoteChannelImpl::DidLoseOutputSurfaceOnMain() { |
| 408 DCHECK(task_runner_provider_->IsMainThread()); | 411 DCHECK(task_runner_provider_->IsMainThread()); |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 440 main().pending_messages.pop(); | 443 main().pending_messages.pop(); |
| 441 } | 444 } |
| 442 | 445 |
| 443 // The commit after a new output surface can early out, in which case we will | 446 // The commit after a new output surface can early out, in which case we will |
| 444 // never redraw. Schedule one just to be safe. | 447 // never redraw. Schedule one just to be safe. |
| 445 PostSetNeedsRedrawToImpl( | 448 PostSetNeedsRedrawToImpl( |
| 446 gfx::Rect(main().layer_tree_host->device_viewport_size())); | 449 gfx::Rect(main().layer_tree_host->device_viewport_size())); |
| 447 } | 450 } |
| 448 | 451 |
| 449 void RemoteChannelImpl::SendMessageProtoOnMain( | 452 void RemoteChannelImpl::SendMessageProtoOnMain( |
| 450 scoped_ptr<proto::CompositorMessage> proto) { | 453 std::unique_ptr<proto::CompositorMessage> proto) { |
| 451 DCHECK(task_runner_provider_->IsMainThread()); | 454 DCHECK(task_runner_provider_->IsMainThread()); |
| 452 VLOG(1) << "Sending BeginMainFrame request to the engine."; | 455 VLOG(1) << "Sending BeginMainFrame request to the engine."; |
| 453 | 456 |
| 454 main().remote_proto_channel->SendCompositorProto(*proto); | 457 main().remote_proto_channel->SendCompositorProto(*proto); |
| 455 } | 458 } |
| 456 | 459 |
| 457 void RemoteChannelImpl::PostSetNeedsRedrawToImpl( | 460 void RemoteChannelImpl::PostSetNeedsRedrawToImpl( |
| 458 const gfx::Rect& damaged_rect) { | 461 const gfx::Rect& damaged_rect) { |
| 459 DCHECK(task_runner_provider_->IsMainThread()); | 462 DCHECK(task_runner_provider_->IsMainThread()); |
| 460 | 463 |
| 461 ImplThreadTaskRunner()->PostTask( | 464 ImplThreadTaskRunner()->PostTask( |
| 462 FROM_HERE, base::Bind(&ProxyImpl::SetNeedsRedrawOnImpl, | 465 FROM_HERE, base::Bind(&ProxyImpl::SetNeedsRedrawOnImpl, |
| 463 proxy_impl_weak_ptr_, damaged_rect)); | 466 proxy_impl_weak_ptr_, damaged_rect)); |
| 464 } | 467 } |
| 465 | 468 |
| 466 void RemoteChannelImpl::InitializeImplOnImpl(CompletionEvent* completion, | 469 void RemoteChannelImpl::InitializeImplOnImpl(CompletionEvent* completion, |
| 467 LayerTreeHost* layer_tree_host) { | 470 LayerTreeHost* layer_tree_host) { |
| 468 DCHECK(task_runner_provider_->IsMainThreadBlocked()); | 471 DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
| 469 DCHECK(task_runner_provider_->IsImplThread()); | 472 DCHECK(task_runner_provider_->IsImplThread()); |
| 470 | 473 |
| 471 impl().proxy_impl = | 474 impl().proxy_impl = |
| 472 CreateProxyImpl(this, layer_tree_host, task_runner_provider_, nullptr); | 475 CreateProxyImpl(this, layer_tree_host, task_runner_provider_, nullptr); |
| 473 impl().proxy_impl_weak_factory = make_scoped_ptr( | 476 impl().proxy_impl_weak_factory = base::WrapUnique( |
| 474 new base::WeakPtrFactory<ProxyImpl>(impl().proxy_impl.get())); | 477 new base::WeakPtrFactory<ProxyImpl>(impl().proxy_impl.get())); |
| 475 proxy_impl_weak_ptr_ = impl().proxy_impl_weak_factory->GetWeakPtr(); | 478 proxy_impl_weak_ptr_ = impl().proxy_impl_weak_factory->GetWeakPtr(); |
| 476 completion->Signal(); | 479 completion->Signal(); |
| 477 } | 480 } |
| 478 | 481 |
| 479 void RemoteChannelImpl::ShutdownImplOnImpl(CompletionEvent* completion) { | 482 void RemoteChannelImpl::ShutdownImplOnImpl(CompletionEvent* completion) { |
| 480 DCHECK(task_runner_provider_->IsMainThreadBlocked()); | 483 DCHECK(task_runner_provider_->IsMainThreadBlocked()); |
| 481 DCHECK(task_runner_provider_->IsImplThread()); | 484 DCHECK(task_runner_provider_->IsImplThread()); |
| 482 | 485 |
| 483 // We must invalidate the proxy_impl weak ptrs and destroy the weak ptr | 486 // We must invalidate the proxy_impl weak ptrs and destroy the weak ptr |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 534 | 537 |
| 535 RemoteChannelImpl::CompositorThreadOnly::CompositorThreadOnly( | 538 RemoteChannelImpl::CompositorThreadOnly::CompositorThreadOnly( |
| 536 base::WeakPtr<RemoteChannelImpl> remote_channel_weak_ptr) | 539 base::WeakPtr<RemoteChannelImpl> remote_channel_weak_ptr) |
| 537 : proxy_impl(nullptr), | 540 : proxy_impl(nullptr), |
| 538 proxy_impl_weak_factory(nullptr), | 541 proxy_impl_weak_factory(nullptr), |
| 539 remote_channel_weak_ptr(remote_channel_weak_ptr) {} | 542 remote_channel_weak_ptr(remote_channel_weak_ptr) {} |
| 540 | 543 |
| 541 RemoteChannelImpl::CompositorThreadOnly::~CompositorThreadOnly() {} | 544 RemoteChannelImpl::CompositorThreadOnly::~CompositorThreadOnly() {} |
| 542 | 545 |
| 543 } // namespace cc | 546 } // namespace cc |
| OLD | NEW |