Chromium Code Reviews| 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 312 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 323 void MediaRouterMojoImpl::DetachRoute(const MediaRoute::Id& route_id) { | 323 void MediaRouterMojoImpl::DetachRoute(const MediaRoute::Id& route_id) { |
| 324 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 324 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 325 | 325 |
| 326 SetWakeReason(MediaRouteProviderWakeReason::DETACH_ROUTE); | 326 SetWakeReason(MediaRouteProviderWakeReason::DETACH_ROUTE); |
| 327 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoDetachRoute, | 327 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoDetachRoute, |
| 328 base::Unretained(this), route_id)); | 328 base::Unretained(this), route_id)); |
| 329 } | 329 } |
| 330 | 330 |
| 331 void MediaRouterMojoImpl::SendRouteMessage( | 331 void MediaRouterMojoImpl::SendRouteMessage( |
| 332 const MediaRoute::Id& route_id, | 332 const MediaRoute::Id& route_id, |
| 333 const std::string& message, | 333 std::string message, |
| 334 const SendRouteMessageCallback& callback) { | 334 const SendRouteMessageCallback& callback) { |
| 335 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 335 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 336 | 336 |
| 337 SetWakeReason(MediaRouteProviderWakeReason::SEND_SESSION_MESSAGE); | 337 SetWakeReason(MediaRouteProviderWakeReason::SEND_SESSION_MESSAGE); |
| 338 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoSendSessionMessage, | 338 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoSendSessionMessage, |
| 339 base::Unretained(this), route_id, message, callback)); | 339 base::Unretained(this), route_id, std::move(message), |
|
dcheng
2017/02/28 06:45:26
Ah... I guess this is where move semantics might b
mark a. foltz
2017/02/28 18:35:20
Done.
| |
| 340 callback)); | |
| 340 } | 341 } |
| 341 | 342 |
| 342 void MediaRouterMojoImpl::SendRouteBinaryMessage( | 343 void MediaRouterMojoImpl::SendRouteBinaryMessage( |
| 343 const MediaRoute::Id& route_id, | 344 const MediaRoute::Id& route_id, |
| 344 std::unique_ptr<std::vector<uint8_t>> data, | 345 std::vector<uint8_t> data, |
| 345 const SendRouteMessageCallback& callback) { | 346 const SendRouteMessageCallback& callback) { |
| 346 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 347 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 347 | 348 |
| 348 SetWakeReason(MediaRouteProviderWakeReason::SEND_SESSION_BINARY_MESSAGE); | 349 SetWakeReason(MediaRouteProviderWakeReason::SEND_SESSION_BINARY_MESSAGE); |
| 349 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoSendSessionBinaryMessage, | 350 RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoSendSessionBinaryMessage, |
| 350 base::Unretained(this), route_id, | 351 base::Unretained(this), route_id, std::move(data), |
| 351 base::Passed(std::move(data)), callback)); | 352 callback)); |
| 352 } | 353 } |
| 353 | 354 |
| 354 void MediaRouterMojoImpl::AddIssue(const IssueInfo& issue_info) { | 355 void MediaRouterMojoImpl::AddIssue(const IssueInfo& issue_info) { |
| 355 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 356 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 356 issue_manager_.AddIssue(issue_info); | 357 issue_manager_.AddIssue(issue_info); |
| 357 } | 358 } |
| 358 | 359 |
| 359 void MediaRouterMojoImpl::ClearIssue(const Issue::Id& issue_id) { | 360 void MediaRouterMojoImpl::ClearIssue(const Issue::Id& issue_id) { |
| 360 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 361 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 361 issue_manager_.ClearIssue(issue_id); | 362 issue_manager_.ClearIssue(issue_id); |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 610 base::Unretained(this), route_id)); | 611 base::Unretained(this), route_id)); |
| 611 } | 612 } |
| 612 | 613 |
| 613 void MediaRouterMojoImpl::DoDetachRoute(const MediaRoute::Id& route_id) { | 614 void MediaRouterMojoImpl::DoDetachRoute(const MediaRoute::Id& route_id) { |
| 614 DVLOG_WITH_INSTANCE(1) << "DoDetachRoute " << route_id; | 615 DVLOG_WITH_INSTANCE(1) << "DoDetachRoute " << route_id; |
| 615 media_route_provider_->DetachRoute(route_id); | 616 media_route_provider_->DetachRoute(route_id); |
| 616 } | 617 } |
| 617 | 618 |
| 618 void MediaRouterMojoImpl::DoSendSessionMessage( | 619 void MediaRouterMojoImpl::DoSendSessionMessage( |
| 619 const MediaRoute::Id& route_id, | 620 const MediaRoute::Id& route_id, |
| 620 const std::string& message, | 621 std::string message, |
| 621 const SendRouteMessageCallback& callback) { | 622 const SendRouteMessageCallback& callback) { |
| 622 DVLOG_WITH_INSTANCE(1) << "SendRouteMessage " << route_id; | 623 DVLOG_WITH_INSTANCE(1) << "SendRouteMessage " << route_id; |
| 623 media_route_provider_->SendRouteMessage(route_id, message, callback); | 624 media_route_provider_->SendRouteMessage(route_id, std::move(message), |
| 625 callback); | |
| 624 } | 626 } |
| 625 | 627 |
| 626 void MediaRouterMojoImpl::DoSendSessionBinaryMessage( | 628 void MediaRouterMojoImpl::DoSendSessionBinaryMessage( |
| 627 const MediaRoute::Id& route_id, | 629 const MediaRoute::Id& route_id, |
| 628 std::unique_ptr<std::vector<uint8_t>> data, | 630 std::vector<uint8_t> data, |
| 629 const SendRouteMessageCallback& callback) { | 631 const SendRouteMessageCallback& callback) { |
| 630 DVLOG_WITH_INSTANCE(1) << "SendRouteBinaryMessage " << route_id; | 632 DVLOG_WITH_INSTANCE(1) << "SendRouteBinaryMessage " << route_id; |
| 631 media_route_provider_->SendRouteBinaryMessage(route_id, *data, callback); | 633 media_route_provider_->SendRouteBinaryMessage(route_id, std::move(data), |
| 634 callback); | |
| 632 } | 635 } |
| 633 | 636 |
| 634 void MediaRouterMojoImpl::DoStartListeningForRouteMessages( | 637 void MediaRouterMojoImpl::DoStartListeningForRouteMessages( |
| 635 const MediaRoute::Id& route_id) { | 638 const MediaRoute::Id& route_id) { |
| 636 DVLOG_WITH_INSTANCE(1) << "DoStartListeningForRouteMessages"; | 639 DVLOG_WITH_INSTANCE(1) << "DoStartListeningForRouteMessages"; |
| 637 media_route_provider_->StartListeningForRouteMessages(route_id); | 640 media_route_provider_->StartListeningForRouteMessages(route_id); |
| 638 } | 641 } |
| 639 | 642 |
| 640 void MediaRouterMojoImpl::DoStopListeningForRouteMessages( | 643 void MediaRouterMojoImpl::DoStopListeningForRouteMessages( |
| 641 const MediaRoute::Id& route_id) { | 644 const MediaRoute::Id& route_id) { |
| (...skipping 287 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 929 base::Unretained(this), source_id)); | 932 base::Unretained(this), source_id)); |
| 930 } | 933 } |
| 931 | 934 |
| 932 void MediaRouterMojoImpl::DoUpdateMediaSinks( | 935 void MediaRouterMojoImpl::DoUpdateMediaSinks( |
| 933 const MediaSource::Id& source_id) { | 936 const MediaSource::Id& source_id) { |
| 934 DVLOG_WITH_INSTANCE(1) << "DoUpdateMediaSinks" << source_id; | 937 DVLOG_WITH_INSTANCE(1) << "DoUpdateMediaSinks" << source_id; |
| 935 media_route_provider_->UpdateMediaSinks(source_id); | 938 media_route_provider_->UpdateMediaSinks(source_id); |
| 936 } | 939 } |
| 937 | 940 |
| 938 } // namespace media_router | 941 } // namespace media_router |
| OLD | NEW |