| OLD | NEW |
| (Empty) |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "blimp/client/feature/compositor/blimp_compositor.h" | |
| 6 | |
| 7 #include "base/bind_helpers.h" | |
| 8 #include "base/command_line.h" | |
| 9 #include "base/memory/ptr_util.h" | |
| 10 #include "base/numerics/safe_conversions.h" | |
| 11 #include "base/single_thread_task_runner.h" | |
| 12 #include "base/threading/thread.h" | |
| 13 #include "base/threading/thread_local.h" | |
| 14 #include "base/threading/thread_restrictions.h" | |
| 15 #include "base/threading/thread_task_runner_handle.h" | |
| 16 #include "blimp/client/feature/compositor/blimp_context_provider.h" | |
| 17 #include "blimp/client/feature/compositor/blimp_output_surface.h" | |
| 18 #include "cc/animation/animation_host.h" | |
| 19 #include "cc/layers/layer.h" | |
| 20 #include "cc/output/output_surface.h" | |
| 21 #include "cc/proto/compositor_message.pb.h" | |
| 22 #include "cc/trees/layer_tree_host.h" | |
| 23 #include "net/base/net_errors.h" | |
| 24 #include "ui/gl/gl_surface.h" | |
| 25 | |
| 26 namespace blimp { | |
| 27 namespace client { | |
| 28 | |
| 29 BlimpCompositor::BlimpCompositor(int render_widget_id, | |
| 30 BlimpCompositorClient* client) | |
| 31 : render_widget_id_(render_widget_id), | |
| 32 client_(client), | |
| 33 window_(gfx::kNullAcceleratedWidget), | |
| 34 host_should_be_visible_(false), | |
| 35 output_surface_request_pending_(false), | |
| 36 remote_proto_channel_receiver_(nullptr) {} | |
| 37 | |
| 38 BlimpCompositor::~BlimpCompositor() { | |
| 39 if (host_) | |
| 40 DestroyLayerTreeHost(); | |
| 41 } | |
| 42 | |
| 43 void BlimpCompositor::SetVisible(bool visible) { | |
| 44 host_should_be_visible_ = visible; | |
| 45 SetVisibleInternal(host_should_be_visible_); | |
| 46 } | |
| 47 | |
| 48 void BlimpCompositor::SetAcceleratedWidget(gfx::AcceleratedWidget widget) { | |
| 49 if (widget == window_) | |
| 50 return; | |
| 51 | |
| 52 DCHECK(window_ == gfx::kNullAcceleratedWidget); | |
| 53 window_ = widget; | |
| 54 | |
| 55 // The compositor should not be visible if there is no output surface. | |
| 56 DCHECK(!host_ || !host_->visible()); | |
| 57 | |
| 58 // This will properly set visibility and will build the output surface if | |
| 59 // necessary. | |
| 60 SetVisibleInternal(host_should_be_visible_); | |
| 61 } | |
| 62 | |
| 63 void BlimpCompositor::ReleaseAcceleratedWidget() { | |
| 64 if (window_ == gfx::kNullAcceleratedWidget) | |
| 65 return; | |
| 66 | |
| 67 // Hide the compositor and drop the output surface if necessary. | |
| 68 SetVisibleInternal(false); | |
| 69 | |
| 70 window_ = gfx::kNullAcceleratedWidget; | |
| 71 } | |
| 72 | |
| 73 bool BlimpCompositor::OnTouchEvent(const ui::MotionEvent& motion_event) { | |
| 74 if (input_manager_) | |
| 75 return input_manager_->OnTouchEvent(motion_event); | |
| 76 return false; | |
| 77 } | |
| 78 | |
| 79 void BlimpCompositor::WillBeginMainFrame() {} | |
| 80 | |
| 81 void BlimpCompositor::DidBeginMainFrame() {} | |
| 82 | |
| 83 void BlimpCompositor::BeginMainFrame(const cc::BeginFrameArgs& args) {} | |
| 84 | |
| 85 void BlimpCompositor::BeginMainFrameNotExpectedSoon() {} | |
| 86 | |
| 87 void BlimpCompositor::UpdateLayerTreeHost() {} | |
| 88 | |
| 89 void BlimpCompositor::ApplyViewportDeltas( | |
| 90 const gfx::Vector2dF& inner_delta, | |
| 91 const gfx::Vector2dF& outer_delta, | |
| 92 const gfx::Vector2dF& elastic_overscroll_delta, | |
| 93 float page_scale, | |
| 94 float top_controls_delta) {} | |
| 95 | |
| 96 void BlimpCompositor::RequestNewOutputSurface() { | |
| 97 output_surface_request_pending_ = true; | |
| 98 HandlePendingOutputSurfaceRequest(); | |
| 99 } | |
| 100 | |
| 101 void BlimpCompositor::DidInitializeOutputSurface() { | |
| 102 } | |
| 103 | |
| 104 void BlimpCompositor::DidFailToInitializeOutputSurface() {} | |
| 105 | |
| 106 void BlimpCompositor::WillCommit() {} | |
| 107 | |
| 108 void BlimpCompositor::DidCommit() {} | |
| 109 | |
| 110 void BlimpCompositor::DidCommitAndDrawFrame() { | |
| 111 client_->DidCommitAndDrawFrame(); | |
| 112 } | |
| 113 | |
| 114 void BlimpCompositor::DidCompleteSwapBuffers() { | |
| 115 client_->DidCompleteSwapBuffers(); | |
| 116 } | |
| 117 | |
| 118 void BlimpCompositor::DidCompletePageScaleAnimation() {} | |
| 119 | |
| 120 void BlimpCompositor::SetProtoReceiver(ProtoReceiver* receiver) { | |
| 121 remote_proto_channel_receiver_ = receiver; | |
| 122 } | |
| 123 | |
| 124 void BlimpCompositor::SendCompositorProto( | |
| 125 const cc::proto::CompositorMessage& proto) { | |
| 126 client_->SendCompositorMessage(render_widget_id_, proto); | |
| 127 } | |
| 128 | |
| 129 void BlimpCompositor::OnCompositorMessageReceived( | |
| 130 std::unique_ptr<cc::proto::CompositorMessage> message) { | |
| 131 DCHECK(message->has_to_impl()); | |
| 132 const cc::proto::CompositorMessageToImpl& to_impl_proto = | |
| 133 message->to_impl(); | |
| 134 | |
| 135 DCHECK(to_impl_proto.has_message_type()); | |
| 136 switch (to_impl_proto.message_type()) { | |
| 137 case cc::proto::CompositorMessageToImpl::UNKNOWN: | |
| 138 NOTIMPLEMENTED() << "Ignoring message of UNKNOWN type"; | |
| 139 break; | |
| 140 case cc::proto::CompositorMessageToImpl::INITIALIZE_IMPL: | |
| 141 DCHECK(!host_); | |
| 142 DCHECK(to_impl_proto.has_initialize_impl_message()); | |
| 143 | |
| 144 // Create the remote client LayerTreeHost for the compositor. | |
| 145 CreateLayerTreeHost(to_impl_proto.initialize_impl_message()); | |
| 146 break; | |
| 147 case cc::proto::CompositorMessageToImpl::CLOSE_IMPL: | |
| 148 DCHECK(host_); | |
| 149 | |
| 150 // Destroy the remote client LayerTreeHost for the compositor. | |
| 151 DestroyLayerTreeHost(); | |
| 152 break; | |
| 153 default: | |
| 154 // We should have a receiver if we're getting compositor messages that | |
| 155 // are not INITIALIZE_IMPL or CLOSE_IMPL. | |
| 156 DCHECK(remote_proto_channel_receiver_); | |
| 157 remote_proto_channel_receiver_->OnProtoReceived(std::move(message)); | |
| 158 } | |
| 159 } | |
| 160 | |
| 161 void BlimpCompositor::SendWebGestureEvent( | |
| 162 const blink::WebGestureEvent& gesture_event) { | |
| 163 client_->SendWebGestureEvent(render_widget_id_, gesture_event); | |
| 164 } | |
| 165 | |
| 166 void BlimpCompositor::SetVisibleInternal(bool visible) { | |
| 167 if (!host_) | |
| 168 return; | |
| 169 | |
| 170 VLOG(1) << "Setting visibility to: " << visible | |
| 171 << " for render widget: " << render_widget_id_; | |
| 172 | |
| 173 if (visible && window_ != gfx::kNullAcceleratedWidget) { | |
| 174 // If we're supposed to be visible and we have a valid | |
| 175 // gfx::AcceleratedWidget make our compositor visible. If the compositor | |
| 176 // had an outstanding output surface request, trigger the request again so | |
| 177 // we build the output surface. | |
| 178 host_->SetVisible(true); | |
| 179 if (output_surface_request_pending_) | |
| 180 HandlePendingOutputSurfaceRequest(); | |
| 181 } else if (!visible) { | |
| 182 // If not visible, hide the compositor and have it drop it's output | |
| 183 // surface. | |
| 184 host_->SetVisible(false); | |
| 185 if (!host_->output_surface_lost()) { | |
| 186 host_->ReleaseOutputSurface(); | |
| 187 } | |
| 188 } | |
| 189 } | |
| 190 | |
| 191 void BlimpCompositor::CreateLayerTreeHost( | |
| 192 const cc::proto::InitializeImpl& initialize_message) { | |
| 193 DCHECK(!host_); | |
| 194 VLOG(1) << "Creating LayerTreeHost for render widget: " << render_widget_id_; | |
| 195 | |
| 196 // Create the LayerTreeHost | |
| 197 cc::LayerTreeHost::InitParams params; | |
| 198 params.client = this; | |
| 199 params.task_graph_runner = client_->GetTaskGraphRunner(); | |
| 200 params.gpu_memory_buffer_manager = client_->GetGpuMemoryBufferManager(); | |
| 201 params.main_task_runner = base::ThreadTaskRunnerHandle::Get(); | |
| 202 params.image_serialization_processor = | |
| 203 client_->GetImageSerializationProcessor(); | |
| 204 params.settings = client_->GetLayerTreeSettings(); | |
| 205 params.animation_host = cc::AnimationHost::CreateMainInstance(); | |
| 206 | |
| 207 scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner = | |
| 208 client_->GetCompositorTaskRunner(); | |
| 209 | |
| 210 host_ = | |
| 211 cc::LayerTreeHost::CreateRemoteClient(this /* remote_proto_channel */, | |
| 212 compositor_task_runner, ¶ms); | |
| 213 | |
| 214 // Now that we have a host, set the visiblity on it correctly. | |
| 215 SetVisibleInternal(host_should_be_visible_); | |
| 216 | |
| 217 DCHECK(!input_manager_); | |
| 218 input_manager_ = | |
| 219 BlimpInputManager::Create(this, | |
| 220 base::ThreadTaskRunnerHandle::Get(), | |
| 221 compositor_task_runner, | |
| 222 host_->GetInputHandler()); | |
| 223 } | |
| 224 | |
| 225 void BlimpCompositor::DestroyLayerTreeHost() { | |
| 226 DCHECK(host_); | |
| 227 VLOG(1) << "Destroying LayerTreeHost for render widget: " | |
| 228 << render_widget_id_; | |
| 229 // Tear down the output surface connection with the old LayerTreeHost | |
| 230 // instance. | |
| 231 SetVisibleInternal(false); | |
| 232 | |
| 233 // Destroy the old LayerTreeHost state. | |
| 234 host_.reset(); | |
| 235 | |
| 236 // Destroy the old input manager state. | |
| 237 // It is important to destroy the LayerTreeHost before destroying the input | |
| 238 // manager as it has a reference to the cc::InputHandlerClient owned by the | |
| 239 // BlimpInputManager. | |
| 240 input_manager_.reset(); | |
| 241 | |
| 242 // Reset other state. | |
| 243 output_surface_request_pending_ = false; | |
| 244 | |
| 245 // Make sure we don't have a receiver at this point. | |
| 246 DCHECK(!remote_proto_channel_receiver_); | |
| 247 } | |
| 248 | |
| 249 void BlimpCompositor::HandlePendingOutputSurfaceRequest() { | |
| 250 DCHECK(output_surface_request_pending_); | |
| 251 | |
| 252 // We might have had a request from a LayerTreeHost that was then | |
| 253 // hidden (and hidden means we don't have a native surface). | |
| 254 // Also make sure we only handle this once. | |
| 255 if (!host_->visible() || window_ == gfx::kNullAcceleratedWidget) | |
| 256 return; | |
| 257 | |
| 258 scoped_refptr<BlimpContextProvider> context_provider = | |
| 259 BlimpContextProvider::Create(window_, | |
| 260 client_->GetGpuMemoryBufferManager()); | |
| 261 | |
| 262 host_->SetOutputSurface( | |
| 263 base::WrapUnique(new BlimpOutputSurface(context_provider))); | |
| 264 output_surface_request_pending_ = false; | |
| 265 } | |
| 266 | |
| 267 } // namespace client | |
| 268 } // namespace blimp | |
| OLD | NEW |