Index: chrome/browser/media/router/media_router_mojo_impl_unittest.cc |
diff --git a/chrome/browser/media/router/media_router_mojo_impl_unittest.cc b/chrome/browser/media/router/media_router_mojo_impl_unittest.cc |
index 3321c6d2995883ec758b7386740dff5ae6d6e00c..eb2b547de27362365562f655009d56df6dbcad22 100644 |
--- a/chrome/browser/media/router/media_router_mojo_impl_unittest.cc |
+++ b/chrome/browser/media/router/media_router_mojo_impl_unittest.cc |
@@ -289,9 +289,16 @@ TEST_F(MediaRouterMojoImplTest, JoinRouteFails) { |
ProcessEventLoop(); |
} |
-TEST_F(MediaRouterMojoImplTest, CloseRoute) { |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId))); |
- router()->CloseRoute(kRouteId); |
+TEST_F(MediaRouterMojoImplTest, DetachRoute) { |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId))); |
+ router()->DetachRoute(kRouteId); |
+ ProcessEventLoop(); |
+} |
+ |
+TEST_F(MediaRouterMojoImplTest, TerminateRoute) { |
+ EXPECT_CALL(mock_media_route_provider_, |
+ TerminateRoute(mojo::String(kRouteId))); |
+ router()->TerminateRoute(kRouteId); |
ProcessEventLoop(); |
} |
@@ -839,14 +846,14 @@ TEST_F(MediaRouterMojoImplTest, QueuedWhileAsleep) { |
EXPECT_CALL(mock_event_page_tracker_, WakeEventPage(extension_id(), _)) |
.Times(2) |
.WillRepeatedly(Return(true)); |
- router()->CloseRoute(kRouteId); |
- router()->CloseRoute(kRouteId2); |
+ router()->DetachRoute(kRouteId); |
+ router()->DetachRoute(kRouteId2); |
ProcessEventLoop(); |
EXPECT_CALL(mock_event_page_tracker_, IsEventPageSuspended(extension_id())) |
.Times(1) |
.WillRepeatedly(Return(false)); |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId))); |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId2))); |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId))); |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId2))); |
ConnectProviderManagerService(); |
ProcessEventLoop(); |
} |
@@ -935,20 +942,20 @@ class MediaRouterMojoExtensionTest : public ::testing::Test { |
}; |
TEST_F(MediaRouterMojoExtensionTest, DeferredBindingAndSuspension) { |
- // CloseRoute is called before *any* extension has connected. |
+ // DetachRoute is called before *any* extension has connected. |
// It should be queued. |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
BindMediaRouteProvider(); |
// |mojo_media_router| signals its readiness to the MR by registering |
// itself via RegisterMediaRouteProvider(). |
// Now that the |media_router| and |mojo_media_router| are fully initialized, |
- // the queued CloseRoute() call should be executed. |
+ // the queued DetachRoute() call should be executed. |
EXPECT_CALL(provide_handler_, Invoke(testing::Not(""))); |
EXPECT_CALL(*process_manager_, IsEventPageSuspended(kExtensionId)) |
.WillOnce(Return(false)); |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId))); |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId))); |
RegisterMediaRouteProvider(); |
ProcessEventLoop(); |
@@ -958,33 +965,33 @@ TEST_F(MediaRouterMojoExtensionTest, DeferredBindingAndSuspension) { |
.WillOnce(Return(true)); |
EXPECT_CALL(*process_manager_, WakeEventPage(kExtensionId, _)) |
.WillOnce(testing::DoAll(media::RunCallback<1>(true), Return(true))); |
- media_router_->CloseRoute(kRouteId2); |
+ media_router_->DetachRoute(kRouteId2); |
ProcessEventLoop(); |
// RegisterMediaRouteProvider() is called. |
- // The queued CloseRoute(kRouteId2) call should be executed. |
+ // The queued DetachRoute(kRouteId2) call should be executed. |
EXPECT_CALL(provide_handler_, Invoke(testing::Not(""))); |
EXPECT_CALL(*process_manager_, IsEventPageSuspended(kExtensionId)) |
.WillOnce(Return(false)); |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId2))); |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId2))); |
BindMediaRouteProvider(); |
RegisterMediaRouteProvider(); |
ProcessEventLoop(); |
- ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::CLOSE_ROUTE, 1); |
+ ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::DETACH_ROUTE, 1); |
} |
TEST_F(MediaRouterMojoExtensionTest, AttemptedWakeupTooManyTimes) { |
BindMediaRouteProvider(); |
- // CloseRoute is called while extension is suspended. It should be queued. |
+ // DetachRoute is called while extension is suspended. It should be queued. |
// Schedule a component extension wakeup. |
EXPECT_CALL(*process_manager_, IsEventPageSuspended(kExtensionId)) |
.WillOnce(Return(true)); |
EXPECT_CALL(*process_manager_, WakeEventPage(kExtensionId, _)) |
.WillOnce(testing::DoAll(media::RunCallback<1>(true), Return(true))); |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
EXPECT_EQ(1u, media_router_->pending_requests_.size()); |
- ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::CLOSE_ROUTE, 1); |
+ ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::DETACH_ROUTE, 1); |
// Media route provider fails to connect to media router before extension is |
// suspended again, and |OnConnectionError| is invoked. Retry the wakeup. |
@@ -1007,14 +1014,14 @@ TEST_F(MediaRouterMojoExtensionTest, AttemptedWakeupTooManyTimes) { |
.WillOnce(Return(true)); |
EXPECT_CALL(*process_manager_, WakeEventPage(kExtensionId, _)) |
.WillOnce(testing::DoAll(media::RunCallback<1>(true), Return(true))); |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
EXPECT_EQ(1u, media_router_->pending_requests_.size()); |
} |
TEST_F(MediaRouterMojoExtensionTest, WakeupFailedDrainsQueue) { |
BindMediaRouteProvider(); |
- // CloseRoute is called while extension is suspended. It should be queued. |
+ // DetachRoute is called while extension is suspended. It should be queued. |
// Schedule a component extension wakeup. |
EXPECT_CALL(*process_manager_, IsEventPageSuspended(kExtensionId)) |
.WillOnce(Return(true)); |
@@ -1022,7 +1029,7 @@ TEST_F(MediaRouterMojoExtensionTest, WakeupFailedDrainsQueue) { |
EXPECT_CALL(*process_manager_, WakeEventPage(kExtensionId, _)) |
.WillOnce( |
testing::DoAll(SaveArg<1>(&extension_wakeup_callback), Return(true))); |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
EXPECT_EQ(1u, media_router_->pending_requests_.size()); |
// Extension wakeup callback returning false is an non-retryable error. |
@@ -1035,31 +1042,31 @@ TEST_F(MediaRouterMojoExtensionTest, WakeupFailedDrainsQueue) { |
.WillOnce(Return(true)); |
EXPECT_CALL(*process_manager_, WakeEventPage(kExtensionId, _)) |
.WillOnce(testing::DoAll(media::RunCallback<1>(true), Return(true))); |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
EXPECT_EQ(1u, media_router_->pending_requests_.size()); |
- ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::CLOSE_ROUTE, 1); |
+ ExpectWakeReasonBucketCount(MediaRouteProviderWakeReason::DETACH_ROUTE, 1); |
} |
TEST_F(MediaRouterMojoExtensionTest, DropOldestPendingRequest) { |
const size_t kMaxPendingRequests = MediaRouterMojoImpl::kMaxPendingRequests; |
// Request is queued. |
- media_router_->CloseRoute(kRouteId); |
+ media_router_->DetachRoute(kRouteId); |
EXPECT_EQ(1u, media_router_->pending_requests_.size()); |
for (size_t i = 0; i < kMaxPendingRequests; ++i) |
- media_router_->CloseRoute(kRouteId2); |
+ media_router_->DetachRoute(kRouteId2); |
// The request queue size should not exceed |kMaxPendingRequests|. |
EXPECT_EQ(kMaxPendingRequests, media_router_->pending_requests_.size()); |
// The oldest request should have been dropped, so we don't expect to see |
- // CloseRoute(kRouteId) here. |
+ // DetachRoute(kRouteId) here. |
BindMediaRouteProvider(); |
EXPECT_CALL(provide_handler_, Invoke(testing::Not(""))); |
EXPECT_CALL(*process_manager_, IsEventPageSuspended(kExtensionId)) |
.WillOnce(Return(false)); |
- EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId2))) |
+ EXPECT_CALL(mock_media_route_provider_, DetachRoute(mojo::String(kRouteId2))) |
.Times(kMaxPendingRequests); |
RegisterMediaRouteProvider(); |
ProcessEventLoop(); |