| Index: chrome/browser/media/router/mojo/media_router_mojo_impl_unittest.cc
|
| diff --git a/chrome/browser/media/router/media_router_mojo_impl_unittest.cc b/chrome/browser/media/router/mojo/media_router_mojo_impl_unittest.cc
|
| similarity index 94%
|
| rename from chrome/browser/media/router/media_router_mojo_impl_unittest.cc
|
| rename to chrome/browser/media/router/mojo/media_router_mojo_impl_unittest.cc
|
| index 469da5d189cb51d4cbe3b77abc6b4d31d63af604..6697b908884a86f287eb5a441c8256acf77bc07c 100644
|
| --- a/chrome/browser/media/router/media_router_mojo_impl_unittest.cc
|
| +++ b/chrome/browser/media/router/mojo/media_router_mojo_impl_unittest.cc
|
| @@ -18,10 +18,10 @@
|
| #include "base/thread_task_runner_handle.h"
|
| #include "chrome/browser/media/router/issue.h"
|
| #include "chrome/browser/media/router/media_route.h"
|
| -#include "chrome/browser/media/router/media_router_metrics.h"
|
| -#include "chrome/browser/media/router/media_router_mojo_test.h"
|
| -#include "chrome/browser/media/router/media_router_type_converters.h"
|
| #include "chrome/browser/media/router/mock_media_router.h"
|
| +#include "chrome/browser/media/router/mojo/media_router_mojo_metrics.h"
|
| +#include "chrome/browser/media/router/mojo/media_router_mojo_test.h"
|
| +#include "chrome/browser/media/router/mojo/media_router_type_converters.h"
|
| #include "chrome/browser/media/router/presentation_session_messages_observer.h"
|
| #include "chrome/browser/media/router/test_helper.h"
|
| #include "chrome/test/base/chrome_render_view_host_test_harness.h"
|
| @@ -570,9 +570,7 @@ TEST_F(MediaRouterMojoImplTest, ConnectRouteByIdOffTheRecordMismatchFails) {
|
| TEST_F(MediaRouterMojoImplTest, DetachRoute) {
|
| base::RunLoop run_loop;
|
| EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId)))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| router()->DetachRoute(kRouteId);
|
| run_loop.Run();
|
| }
|
| @@ -581,9 +579,7 @@ TEST_F(MediaRouterMojoImplTest, TerminateRoute) {
|
| base::RunLoop run_loop;
|
| EXPECT_CALL(mock_media_route_provider_,
|
| TerminateRoute(mojo::String(kRouteId)))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| router()->TerminateRoute(kRouteId);
|
| run_loop.Run();
|
| }
|
| @@ -604,9 +600,7 @@ TEST_F(MediaRouterMojoImplTest, HandleIssue) {
|
| base::RunLoop run_loop;
|
| EXPECT_CALL(issue_observer2,
|
| OnIssueUpdated(Pointee(EqualsIssue(expected_issue1))))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| media_router_proxy_->OnIssue(std::move(mojo_issue1));
|
| run_loop.Run();
|
|
|
| @@ -636,9 +630,7 @@ TEST_F(MediaRouterMojoImplTest, HandleIssue) {
|
| base::RunLoop run_loop2;
|
| EXPECT_CALL(issue_observer2,
|
| OnIssueUpdated(Pointee(EqualsIssue(expected_issue2))))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop2]() {
|
| - run_loop2.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop2]() { run_loop2.Quit(); }));
|
| media_router_proxy_->OnIssue(std::move(mojo_issue2));
|
| run_loop2.Run();
|
|
|
| @@ -721,9 +713,7 @@ TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaSinksObserver) {
|
| StopObservingMediaSinks(mojo::String(kSource)));
|
| EXPECT_CALL(mock_media_route_provider_,
|
| StopObservingMediaSinks(mojo::String(kSource2)))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop2]() {
|
| - run_loop2.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop2]() { run_loop2.Quit(); }));
|
| sinks_observer.reset();
|
| extra_sinks_observer.reset();
|
| unrelated_sinks_observer.reset();
|
| @@ -809,10 +799,12 @@ TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaRoutesObserver) {
|
| MediaSource media_source(kSource);
|
| MediaSource different_media_source(kSource2);
|
| EXPECT_CALL(mock_media_route_provider_,
|
| - StartObservingMediaRoutes(mojo::String(media_source.id()))).Times(2);
|
| - EXPECT_CALL(mock_media_route_provider_,
|
| - StartObservingMediaRoutes(
|
| - mojo::String(different_media_source.id()))).Times(1);
|
| + StartObservingMediaRoutes(mojo::String(media_source.id())))
|
| + .Times(2);
|
| + EXPECT_CALL(
|
| + mock_media_route_provider_,
|
| + StartObservingMediaRoutes(mojo::String(different_media_source.id())))
|
| + .Times(1);
|
|
|
| MediaRoutesObserver* observer_captured;
|
| EXPECT_CALL(mock_router, RegisterMediaRoutesObserver(_))
|
| @@ -821,10 +813,10 @@ TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaRoutesObserver) {
|
| MockMediaRoutesObserver routes_observer(&mock_router, media_source.id());
|
| EXPECT_EQ(observer_captured, &routes_observer);
|
| MockMediaRoutesObserver extra_routes_observer(&mock_router,
|
| - media_source.id());
|
| + media_source.id());
|
| EXPECT_EQ(observer_captured, &extra_routes_observer);
|
| - MockMediaRoutesObserver different_routes_observer(&mock_router,
|
| - different_media_source.id());
|
| + MockMediaRoutesObserver different_routes_observer(
|
| + &mock_router, different_media_source.id());
|
| EXPECT_EQ(observer_captured, &different_routes_observer);
|
| router()->RegisterMediaRoutesObserver(&routes_observer);
|
| router()->RegisterMediaRoutesObserver(&extra_routes_observer);
|
| @@ -861,15 +853,15 @@ TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaRoutesObserver) {
|
| mojo_routes[1]->is_local = false;
|
| mojo_routes[1]->off_the_record = true;
|
|
|
| - EXPECT_CALL(routes_observer,
|
| - OnRoutesUpdated(SequenceEquals(expected_routes),
|
| - expected_joinable_route_ids));
|
| + EXPECT_CALL(routes_observer, OnRoutesUpdated(SequenceEquals(expected_routes),
|
| + expected_joinable_route_ids));
|
| EXPECT_CALL(extra_routes_observer,
|
| OnRoutesUpdated(SequenceEquals(expected_routes),
|
| expected_joinable_route_ids));
|
| EXPECT_CALL(different_routes_observer,
|
| OnRoutesUpdated(SequenceEquals(expected_routes),
|
| - expected_joinable_route_ids)).Times(0);
|
| + expected_joinable_route_ids))
|
| + .Times(0);
|
| media_router_proxy_->OnRoutesUpdated(std::move(mojo_routes),
|
| media_source.id(),
|
| std::move(mojo_joinable_routes));
|
| @@ -884,11 +876,11 @@ TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaRoutesObserver) {
|
| router()->UnregisterMediaRoutesObserver(&extra_routes_observer);
|
| router()->UnregisterMediaRoutesObserver(&different_routes_observer);
|
| EXPECT_CALL(mock_media_route_provider_,
|
| - StopObservingMediaRoutes(
|
| - mojo::String(media_source.id()))).Times(1);
|
| - EXPECT_CALL(mock_media_route_provider_,
|
| - StopObservingMediaRoutes(
|
| - mojo::String(different_media_source.id())));
|
| + StopObservingMediaRoutes(mojo::String(media_source.id())))
|
| + .Times(1);
|
| + EXPECT_CALL(
|
| + mock_media_route_provider_,
|
| + StopObservingMediaRoutes(mojo::String(different_media_source.id())));
|
| ProcessEventLoop();
|
| }
|
|
|
| @@ -905,9 +897,7 @@ TEST_F(MediaRouterMojoImplTest, SendRouteMessage) {
|
| base::RunLoop run_loop;
|
| SendMessageCallbackHandler handler;
|
| EXPECT_CALL(handler, Invoke(true))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| router()->SendRouteMessage(kRouteId, kMessage,
|
| base::Bind(&SendMessageCallbackHandler::Invoke,
|
| base::Unretained(&handler)));
|
| @@ -932,9 +922,7 @@ TEST_F(MediaRouterMojoImplTest, SendRouteBinaryMessage) {
|
| base::RunLoop run_loop;
|
| SendMessageCallbackHandler handler;
|
| EXPECT_CALL(handler, Invoke(true))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| router()->SendRouteBinaryMessage(
|
| kRouteId, std::move(expected_binary_data),
|
| base::Bind(&SendMessageCallbackHandler::Invoke,
|
| @@ -969,9 +957,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesSingleObserver) {
|
| EXPECT_CALL(mock_media_route_provider_,
|
| ListenForRouteMessages(Eq(expected_route_id), _))
|
| .WillOnce(DoAll(SaveArg<1>(&mojo_callback),
|
| - InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - })));
|
| + InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); })));
|
|
|
| // |pass_ownership| param is "true" here because there is only one observer.
|
| ListenForMessagesCallbackHandler handler(std::move(expected_messages), true);
|
| @@ -995,9 +981,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesSingleObserver) {
|
| mojo_callback_2;
|
| EXPECT_CALL(mock_media_route_provider_, ListenForRouteMessages(_, _))
|
| .WillOnce(DoAll(SaveArg<1>(&mojo_callback_2),
|
| - InvokeWithoutArgs([&run_loop2]() {
|
| - run_loop2.Quit();
|
| - })));
|
| + InvokeWithoutArgs([&run_loop2]() { run_loop2.Quit(); })));
|
| run_loop2.Run();
|
|
|
| base::RunLoop run_loop3;
|
| @@ -1010,9 +994,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesSingleObserver) {
|
| observer.reset();
|
| mojo_callback_2.Run(std::move(mojo_messages_2), false);
|
| EXPECT_CALL(mock_media_route_provider_, StopListeningForRouteMessages(_))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop3]() {
|
| - run_loop3.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop3]() { run_loop3.Quit(); }));
|
| run_loop3.Run();
|
| }
|
|
|
| @@ -1043,9 +1025,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesMultipleObservers) {
|
| EXPECT_CALL(mock_media_route_provider_,
|
| ListenForRouteMessages(Eq(expected_route_id), _))
|
| .WillOnce(DoAll(SaveArg<1>(&mojo_callback),
|
| - InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - })));
|
| + InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); })));
|
|
|
| // |pass_ownership| param is "false" here because there are more than one
|
| // observers.
|
| @@ -1075,9 +1055,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesMultipleObservers) {
|
| mojo_callback_2;
|
| EXPECT_CALL(mock_media_route_provider_, ListenForRouteMessages(_, _))
|
| .WillOnce(DoAll(SaveArg<1>(&mojo_callback_2),
|
| - InvokeWithoutArgs([&run_loop2]() {
|
| - run_loop2.Quit();
|
| - })));
|
| + InvokeWithoutArgs([&run_loop2]() { run_loop2.Quit(); })));
|
| run_loop2.Run();
|
|
|
| base::RunLoop run_loop3;
|
| @@ -1091,9 +1069,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesMultipleObservers) {
|
| observer2.reset();
|
| mojo_callback_2.Run(std::move(mojo_messages_2), false);
|
| EXPECT_CALL(mock_media_route_provider_, StopListeningForRouteMessages(_))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop3]() {
|
| - run_loop3.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop3]() { run_loop3.Quit(); }));
|
| run_loop3.Run();
|
| }
|
|
|
| @@ -1104,9 +1080,7 @@ TEST_F(MediaRouterMojoImplTest, PresentationSessionMessagesError) {
|
| EXPECT_CALL(mock_media_route_provider_,
|
| ListenForRouteMessages(Eq(expected_route_id), _))
|
| .WillOnce(DoAll(SaveArg<1>(&mojo_callback),
|
| - InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - })));
|
| + InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); })));
|
|
|
| ListenForMessagesCallbackHandler handler(
|
| ScopedVector<content::PresentationSessionMessage>(), true);
|
| @@ -1195,9 +1169,8 @@ TEST_F(MediaRouterMojoImplTest, QueuedWhileAsleep) {
|
| EXPECT_CALL(mock_event_page_tracker_, WakeEventPage(extension_id(), _))
|
| .Times(2)
|
| .WillOnce(Return(true))
|
| - .WillOnce(DoAll(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }), Return(true)));
|
| + .WillOnce(DoAll(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }),
|
| + Return(true)));
|
| router()->DetachRoute(kRouteId);
|
| router()->DetachRoute(kRouteId2);
|
| run_loop.Run();
|
| @@ -1273,9 +1246,7 @@ class MediaRouterMojoExtensionTest : public ::testing::Test {
|
| base::Unretained(&provide_handler_)));
|
| }
|
|
|
| - void ProcessEventLoop() {
|
| - message_loop_.RunUntilIdle();
|
| - }
|
| + void ProcessEventLoop() { message_loop_.RunUntilIdle(); }
|
|
|
| void ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason reason,
|
| int expected_count) {
|
| @@ -1328,15 +1299,11 @@ TEST_F(MediaRouterMojoExtensionTest, DeferredBindingAndSuspension) {
|
| // Now that the |media_router| and |mojo_media_router| are fully initialized,
|
| // the queued DetachRoute() call should be executed.
|
| EXPECT_CALL(provide_handler_, Invoke(testing::Not("")))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| EXPECT_CALL(*process_manager_, IsEventPageSuspended(extension_->id()))
|
| .WillOnce(Return(false));
|
| EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId)))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop2]() {
|
| - run_loop2.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop2]() { run_loop2.Quit(); }));
|
| RegisterMediaRouteProvider();
|
| run_loop.Run();
|
| run_loop2.Run();
|
| @@ -1358,15 +1325,11 @@ TEST_F(MediaRouterMojoExtensionTest, DeferredBindingAndSuspension) {
|
| // RegisterMediaRouteProvider() is called.
|
| // The queued DetachRoute(kRouteId2) call should be executed.
|
| EXPECT_CALL(provide_handler_, Invoke(testing::Not("")))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop4]() {
|
| - run_loop4.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop4]() { run_loop4.Quit(); }));
|
| EXPECT_CALL(*process_manager_, IsEventPageSuspended(extension_->id()))
|
| .WillOnce(Return(false));
|
| EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId2)))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop5]() {
|
| - run_loop5.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop5]() { run_loop5.Quit(); }));
|
| BindMediaRouteProvider();
|
| RegisterMediaRouteProvider();
|
| run_loop4.Run();
|
| @@ -1470,16 +1433,14 @@ TEST_F(MediaRouterMojoExtensionTest, DropOldestPendingRequest) {
|
| // DetachRoute(kRouteId) here.
|
| BindMediaRouteProvider();
|
| EXPECT_CALL(provide_handler_, Invoke(testing::Not("")))
|
| - .WillOnce(InvokeWithoutArgs([&run_loop]() {
|
| - run_loop.Quit();
|
| - }));
|
| + .WillOnce(InvokeWithoutArgs([&run_loop]() { run_loop.Quit(); }));
|
| EXPECT_CALL(*process_manager_, IsEventPageSuspended(extension_->id()));
|
| EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId2)))
|
| .Times(kMaxPendingRequests)
|
| .WillRepeatedly(InvokeWithoutArgs([&run_loop2, &count]() {
|
| - if (++count == MediaRouterMojoImpl::kMaxPendingRequests)
|
| - run_loop2.Quit();
|
| - }));
|
| + if (++count == MediaRouterMojoImpl::kMaxPendingRequests)
|
| + run_loop2.Quit();
|
| + }));
|
| RegisterMediaRouteProvider();
|
| run_loop.Run();
|
| run_loop2.Run();
|
|
|