| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 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/mojo/media_router_mojo_impl.h" | 5 #include "chrome/browser/media/router/mojo/media_router_mojo_impl.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 | 8 |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 output->data.reset(new std::vector<uint8_t>); | 60 output->data.reset(new std::vector<uint8_t>); |
| 61 input->data.Swap(output->data.get()); | 61 input->data.Swap(output->data.get()); |
| 62 return output; | 62 return output; |
| 63 } | 63 } |
| 64 } | 64 } |
| 65 | 65 |
| 66 NOTREACHED() << "Invalid route message type " << input->type; | 66 NOTREACHED() << "Invalid route message type " << input->type; |
| 67 return output; | 67 return output; |
| 68 } | 68 } |
| 69 | 69 |
| 70 void ForwardSinkSearchCallback(const MediaSinkSearchResponseCallback& callback, |
| 71 mojo::String sink_id) { |
| 72 callback.Run(sink_id); |
| 73 } |
| 74 |
| 70 } // namespace | 75 } // namespace |
| 71 | 76 |
| 72 MediaRouterMojoImpl::MediaRoutesQuery::MediaRoutesQuery() = default; | 77 MediaRouterMojoImpl::MediaRoutesQuery::MediaRoutesQuery() = default; |
| 73 | 78 |
| 74 MediaRouterMojoImpl::MediaRoutesQuery::~MediaRoutesQuery() = default; | 79 MediaRouterMojoImpl::MediaRoutesQuery::~MediaRoutesQuery() = default; |
| 75 | 80 |
| 76 MediaRouterMojoImpl::MediaSinksQuery::MediaSinksQuery() = default; | 81 MediaRouterMojoImpl::MediaSinksQuery::MediaSinksQuery() = default; |
| 77 | 82 |
| 78 MediaRouterMojoImpl::MediaSinksQuery::~MediaSinksQuery() = default; | 83 MediaRouterMojoImpl::MediaSinksQuery::~MediaSinksQuery() = default; |
| 79 | 84 |
| (...skipping 183 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 263 FOR_EACH_OBSERVER( | 268 FOR_EACH_OBSERVER( |
| 264 MediaRoutesObserver, it->second->observers, | 269 MediaRoutesObserver, it->second->observers, |
| 265 OnRoutesUpdated(routes_converted, joinable_routes_converted)); | 270 OnRoutesUpdated(routes_converted, joinable_routes_converted)); |
| 266 } | 271 } |
| 267 | 272 |
| 268 void MediaRouterMojoImpl::RouteResponseReceived( | 273 void MediaRouterMojoImpl::RouteResponseReceived( |
| 269 const std::string& presentation_id, | 274 const std::string& presentation_id, |
| 270 bool off_the_record, | 275 bool off_the_record, |
| 271 const std::vector<MediaRouteResponseCallback>& callbacks, | 276 const std::vector<MediaRouteResponseCallback>& callbacks, |
| 272 interfaces::MediaRoutePtr media_route, | 277 interfaces::MediaRoutePtr media_route, |
| 273 const mojo::String& error_text, | 278 mojo::String error_text, |
| 274 interfaces::RouteRequestResultCode result_code) { | 279 interfaces::RouteRequestResultCode result_code) { |
| 275 std::unique_ptr<RouteRequestResult> result; | 280 std::unique_ptr<RouteRequestResult> result; |
| 276 if (media_route.is_null()) { | 281 if (media_route.is_null()) { |
| 277 // An error occurred. | 282 // An error occurred. |
| 278 DCHECK(!error_text.is_null()); | 283 DCHECK(!error_text.is_null()); |
| 279 std::string error = | 284 std::string error = |
| 280 !error_text.get().empty() ? error_text.get() : "Unknown error."; | 285 !error_text.get().empty() ? error_text.get() : "Unknown error."; |
| 281 result = RouteRequestResult::FromError( | 286 result = RouteRequestResult::FromError( |
| 282 error, mojo::RouteRequestResultCodeFromMojo(result_code)); | 287 error, mojo::RouteRequestResultCodeFromMojo(result_code)); |
| 283 } else if (media_route->off_the_record != off_the_record) { | 288 } else if (media_route->off_the_record != off_the_record) { |
| (...skipping 446 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 730 const MediaSink::Id& sink_id, | 735 const MediaSink::Id& sink_id, |
| 731 const MediaSource::Id& source_id, | 736 const MediaSource::Id& source_id, |
| 732 const std::string& search_input, | 737 const std::string& search_input, |
| 733 const std::string& domain, | 738 const std::string& domain, |
| 734 const MediaSinkSearchResponseCallback& sink_callback) { | 739 const MediaSinkSearchResponseCallback& sink_callback) { |
| 735 DVLOG_WITH_INSTANCE(1) << "SearchSinks"; | 740 DVLOG_WITH_INSTANCE(1) << "SearchSinks"; |
| 736 auto sink_search_criteria = interfaces::SinkSearchCriteria::New(); | 741 auto sink_search_criteria = interfaces::SinkSearchCriteria::New(); |
| 737 sink_search_criteria->input = search_input; | 742 sink_search_criteria->input = search_input; |
| 738 sink_search_criteria->domain = domain; | 743 sink_search_criteria->domain = domain; |
| 739 media_route_provider_->SearchSinks( | 744 media_route_provider_->SearchSinks( |
| 740 sink_id, source_id, std::move(sink_search_criteria), sink_callback); | 745 sink_id, source_id, std::move(sink_search_criteria), |
| 746 base::Bind(&ForwardSinkSearchCallback, sink_callback)); |
| 741 } | 747 } |
| 742 | 748 |
| 743 void MediaRouterMojoImpl::OnRouteMessagesReceived( | 749 void MediaRouterMojoImpl::OnRouteMessagesReceived( |
| 744 const MediaRoute::Id& route_id, | 750 const MediaRoute::Id& route_id, |
| 745 mojo::Array<interfaces::RouteMessagePtr> messages, | 751 mojo::Array<interfaces::RouteMessagePtr> messages, |
| 746 bool error) { | 752 bool error) { |
| 747 DVLOG(1) << "OnRouteMessagesReceived"; | 753 DVLOG(1) << "OnRouteMessagesReceived"; |
| 748 | 754 |
| 749 // If |messages| is null, then no more messages will come from this route. | 755 // If |messages| is null, then no more messages will come from this route. |
| 750 // We can stop listening. | 756 // We can stop listening. |
| (...skipping 280 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1031 base::Unretained(this), source_id)); | 1037 base::Unretained(this), source_id)); |
| 1032 } | 1038 } |
| 1033 | 1039 |
| 1034 void MediaRouterMojoImpl::DoUpdateMediaSinks( | 1040 void MediaRouterMojoImpl::DoUpdateMediaSinks( |
| 1035 const MediaSource::Id& source_id) { | 1041 const MediaSource::Id& source_id) { |
| 1036 DVLOG_WITH_INSTANCE(1) << "DoUpdateMediaSinks" << source_id; | 1042 DVLOG_WITH_INSTANCE(1) << "DoUpdateMediaSinks" << source_id; |
| 1037 media_route_provider_->UpdateMediaSinks(source_id); | 1043 media_route_provider_->UpdateMediaSinks(source_id); |
| 1038 } | 1044 } |
| 1039 | 1045 |
| 1040 } // namespace media_router | 1046 } // namespace media_router |
| OLD | NEW |