OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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 "chrome/browser/media/router/browser_presentation_connection_proxy.h" | 5 #include "chrome/browser/media/router/browser_presentation_connection_proxy.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
10 | 10 |
11 #include "chrome/browser/media/router/media_router.h" | 11 #include "chrome/browser/media/router/media_router.h" |
12 #include "chrome/common/media_router/route_message.h" | |
13 | 12 |
14 namespace media_router { | 13 namespace media_router { |
15 | 14 |
16 namespace { | 15 namespace { |
17 | 16 |
18 void OnMessageReceivedByRenderer(bool success) { | 17 void OnMessageReceivedByRenderer(bool success) { |
19 DLOG_IF(ERROR, !success) | 18 DLOG_IF(ERROR, !success) |
20 << "Renderer PresentationConnection failed to process message!"; | 19 << "Renderer PresentationConnection failed to process message!"; |
21 } | 20 } |
22 | 21 |
(...skipping 28 matching lines...) Expand all Loading... |
51 route_id_, | 50 route_id_, |
52 base::MakeUnique<std::vector<uint8_t>>(std::move(message.data.value())), | 51 base::MakeUnique<std::vector<uint8_t>>(std::move(message.data.value())), |
53 std::move(on_message_callback)); | 52 std::move(on_message_callback)); |
54 } else { | 53 } else { |
55 router_->SendRouteMessage(route_id_, message.message.value(), | 54 router_->SendRouteMessage(route_id_, message.message.value(), |
56 std::move(on_message_callback)); | 55 std::move(on_message_callback)); |
57 } | 56 } |
58 } | 57 } |
59 | 58 |
60 void BrowserPresentationConnectionProxy::OnMessagesReceived( | 59 void BrowserPresentationConnectionProxy::OnMessagesReceived( |
61 const std::vector<RouteMessage>& messages) { | 60 const std::vector<content::PresentationConnectionMessage>& messages) { |
62 DVLOG(2) << __func__ << ", number of messages : " << messages.size(); | 61 DVLOG(2) << __func__ << ", number of messages : " << messages.size(); |
63 // TODO(mfoltz): Remove RouteMessage and replace with move-only | |
64 // PresentationConnectionMessage. | |
65 std::vector<content::PresentationConnectionMessage> presentation_messages; | |
66 for (const RouteMessage& message : messages) { | |
67 if (message.type == RouteMessage::TEXT && message.text) { | |
68 presentation_messages.emplace_back(message.text.value()); | |
69 } else if (message.type == RouteMessage::BINARY && message.binary) { | |
70 presentation_messages.emplace_back(message.binary.value()); | |
71 } else { | |
72 NOTREACHED() << "Unknown route message type"; | |
73 } | |
74 } | |
75 | |
76 // TODO(imcheng): It would be slightly more efficient to send messages in | 62 // TODO(imcheng): It would be slightly more efficient to send messages in |
77 // a single batch. | 63 // a single batch. |
78 for (auto& message : presentation_messages) { | 64 for (const auto& message : messages) { |
79 target_connection_ptr_->OnMessage(std::move(message), | 65 target_connection_ptr_->OnMessage(message, |
80 base::Bind(&OnMessageReceivedByRenderer)); | 66 base::Bind(&OnMessageReceivedByRenderer)); |
81 } | 67 } |
82 } | 68 } |
83 } // namespace media_router | 69 } // namespace media_router |
OLD | NEW |