| 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/render_widget_feature.h" | |
| 6 | |
| 7 #include "base/numerics/safe_conversions.h" | |
| 8 #include "blimp/common/create_blimp_message.h" | |
| 9 #include "blimp/common/proto/blimp_message.pb.h" | |
| 10 #include "blimp/common/proto/compositor.pb.h" | |
| 11 #include "blimp/common/proto/input.pb.h" | |
| 12 #include "blimp/common/proto/render_widget.pb.h" | |
| 13 #include "cc/proto/compositor_message.pb.h" | |
| 14 #include "net/base/net_errors.h" | |
| 15 | |
| 16 namespace blimp { | |
| 17 namespace client { | |
| 18 | |
| 19 RenderWidgetFeature::RenderWidgetFeature() {} | |
| 20 | |
| 21 RenderWidgetFeature::~RenderWidgetFeature() {} | |
| 22 | |
| 23 void RenderWidgetFeature::set_outgoing_input_message_processor( | |
| 24 std::unique_ptr<BlimpMessageProcessor> processor) { | |
| 25 outgoing_input_message_processor_ = std::move(processor); | |
| 26 } | |
| 27 | |
| 28 void RenderWidgetFeature::set_outgoing_compositor_message_processor( | |
| 29 std::unique_ptr<BlimpMessageProcessor> processor) { | |
| 30 outgoing_compositor_message_processor_ = std::move(processor); | |
| 31 } | |
| 32 | |
| 33 void RenderWidgetFeature::SendWebGestureEvent( | |
| 34 const int tab_id, | |
| 35 const int render_widget_id, | |
| 36 const blink::WebGestureEvent& event) { | |
| 37 std::unique_ptr<BlimpMessage> blimp_message = | |
| 38 input_message_generator_.GenerateMessage(event); | |
| 39 | |
| 40 // Don't send unsupported WebGestureEvents. | |
| 41 if (!blimp_message) | |
| 42 return; | |
| 43 | |
| 44 blimp_message->set_target_tab_id(tab_id); | |
| 45 blimp_message->mutable_input()->set_render_widget_id(render_widget_id); | |
| 46 | |
| 47 outgoing_input_message_processor_->ProcessMessage(std::move(blimp_message), | |
| 48 net::CompletionCallback()); | |
| 49 } | |
| 50 | |
| 51 void RenderWidgetFeature::SendCompositorMessage( | |
| 52 const int tab_id, | |
| 53 const int render_widget_id, | |
| 54 const cc::proto::CompositorMessage& message) { | |
| 55 CompositorMessage* compositor_message; | |
| 56 std::unique_ptr<BlimpMessage> blimp_message = | |
| 57 CreateBlimpMessage(&compositor_message, tab_id); | |
| 58 | |
| 59 compositor_message->set_render_widget_id(render_widget_id); | |
| 60 compositor_message->mutable_payload()->resize( | |
| 61 base::checked_cast<size_t>(message.ByteSize())); | |
| 62 if (message.SerializeToString(compositor_message->mutable_payload())) { | |
| 63 outgoing_compositor_message_processor_->ProcessMessage( | |
| 64 std::move(blimp_message), net::CompletionCallback()); | |
| 65 } else { | |
| 66 LOG(ERROR) << "Unable to serialize compositor proto."; | |
| 67 } | |
| 68 } | |
| 69 | |
| 70 void RenderWidgetFeature::SetDelegate(const int tab_id, | |
| 71 RenderWidgetFeatureDelegate* delegate) { | |
| 72 DCHECK(!FindDelegate(tab_id)); | |
| 73 delegates_[tab_id] = delegate; | |
| 74 } | |
| 75 | |
| 76 void RenderWidgetFeature::RemoveDelegate(const int tab_id) { | |
| 77 DelegateMap::iterator it = delegates_.find(tab_id); | |
| 78 if (it != delegates_.end()) | |
| 79 delegates_.erase(it); | |
| 80 } | |
| 81 | |
| 82 void RenderWidgetFeature::ProcessMessage( | |
| 83 std::unique_ptr<BlimpMessage> message, | |
| 84 const net::CompletionCallback& callback) { | |
| 85 DCHECK(!callback.is_null()); | |
| 86 DCHECK(BlimpMessage::kRenderWidget == message->feature_case() || | |
| 87 BlimpMessage::kCompositor == message->feature_case()); | |
| 88 | |
| 89 int target_tab_id = message->target_tab_id(); | |
| 90 RenderWidgetFeatureDelegate* delegate = FindDelegate(target_tab_id); | |
| 91 DCHECK(delegate) << "RenderWidgetFeatureDelegate not found for " | |
| 92 << target_tab_id; | |
| 93 | |
| 94 switch (message->feature_case()) { | |
| 95 case BlimpMessage::kRenderWidget: | |
| 96 ProcessRenderWidgetMessage(delegate, message->render_widget()); | |
| 97 break; | |
| 98 case BlimpMessage::kCompositor: | |
| 99 ProcessCompositorMessage(delegate, message->compositor()); | |
| 100 break; | |
| 101 default: | |
| 102 NOTREACHED(); | |
| 103 break; | |
| 104 } | |
| 105 | |
| 106 callback.Run(net::OK); | |
| 107 } | |
| 108 | |
| 109 void RenderWidgetFeature::ProcessRenderWidgetMessage( | |
| 110 RenderWidgetFeatureDelegate* delegate, | |
| 111 const RenderWidgetMessage& message) { | |
| 112 int render_widget_id = message.render_widget_id(); | |
| 113 | |
| 114 switch (message.type()) { | |
| 115 case RenderWidgetMessage::CREATED: | |
| 116 delegate->OnRenderWidgetCreated(render_widget_id); | |
| 117 break; | |
| 118 case RenderWidgetMessage::INITIALIZE: | |
| 119 delegate->OnRenderWidgetInitialized(render_widget_id); | |
| 120 break; | |
| 121 case RenderWidgetMessage::DELETED: | |
| 122 delegate->OnRenderWidgetDeleted(render_widget_id); | |
| 123 break; | |
| 124 case RenderWidgetMessage::UNKNOWN: | |
| 125 NOTREACHED(); | |
| 126 break; | |
| 127 } | |
| 128 } | |
| 129 | |
| 130 void RenderWidgetFeature::ProcessCompositorMessage( | |
| 131 RenderWidgetFeatureDelegate* delegate, | |
| 132 const CompositorMessage& message) { | |
| 133 int render_widget_id = message.render_widget_id(); | |
| 134 | |
| 135 std::unique_ptr<cc::proto::CompositorMessage> payload( | |
| 136 new cc::proto::CompositorMessage); | |
| 137 if (payload->ParseFromString(message.payload())) { | |
| 138 delegate->OnCompositorMessageReceived(render_widget_id, | |
| 139 std::move(payload)); | |
| 140 } | |
| 141 } | |
| 142 | |
| 143 RenderWidgetFeature::RenderWidgetFeatureDelegate* | |
| 144 RenderWidgetFeature::FindDelegate(const int tab_id) { | |
| 145 DelegateMap::const_iterator it = delegates_.find(tab_id); | |
| 146 if (it != delegates_.end()) | |
| 147 return it->second; | |
| 148 return nullptr; | |
| 149 } | |
| 150 | |
| 151 } // namespace client | |
| 152 } // namespace blimp | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 2241623002:
blimp: Move compositing, input and render widget feature to client/core. (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master