OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "content/browser/service_worker/service_worker_version.h" | 5 #include "content/browser/service_worker/service_worker_version.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 #include <tuple> | 8 #include <tuple> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 252 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
263 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerVersionTest); | 263 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerVersionTest); |
264 }; | 264 }; |
265 | 265 |
266 class MessageReceiverDisallowStart : public MessageReceiver { | 266 class MessageReceiverDisallowStart : public MessageReceiver { |
267 public: | 267 public: |
268 MessageReceiverDisallowStart() : MessageReceiver() {} | 268 MessageReceiverDisallowStart() : MessageReceiver() {} |
269 ~MessageReceiverDisallowStart() override {} | 269 ~MessageReceiverDisallowStart() override {} |
270 | 270 |
271 enum class StartMode { STALL, FAIL, SUCCEED }; | 271 enum class StartMode { STALL, FAIL, SUCCEED }; |
272 | 272 |
273 void OnStartWorker( | 273 void OnStartWorker(int embedded_worker_id, |
274 int embedded_worker_id, | 274 int64_t service_worker_version_id, |
275 int64_t service_worker_version_id, | 275 const GURL& scope, |
276 const GURL& scope, | 276 const GURL& script_url, |
277 const GURL& script_url, | 277 bool pause_after_download, |
278 bool pause_after_download, | 278 mojom::ServiceWorkerEventDispatcherRequest request, |
279 mojom::ServiceWorkerEventDispatcherRequest request, | 279 mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo |
280 mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo instance_host, | 280 instance_host) override { |
281 mojom::ServiceWorkerProviderInfoForStartWorkerPtr provider_info) | |
282 override { | |
283 switch (mode_) { | 281 switch (mode_) { |
284 case StartMode::STALL: | 282 case StartMode::STALL: |
285 // Prepare for OnStopWorker(). | 283 // Prepare for OnStopWorker(). |
286 instance_host_ptr_map_[embedded_worker_id].Bind( | 284 instance_host_ptr_map_[embedded_worker_id].Bind( |
287 std::move(instance_host)); | 285 std::move(instance_host)); |
288 // Just keep the connection alive. | 286 // Just keep the connection alive. |
289 event_dispatcher_request_map_[embedded_worker_id] = std::move(request); | 287 event_dispatcher_request_map_[embedded_worker_id] = std::move(request); |
290 break; | 288 break; |
291 case StartMode::FAIL: | 289 case StartMode::FAIL: |
292 ASSERT_EQ(current_mock_instance_index_ + 1, | 290 ASSERT_EQ(current_mock_instance_index_ + 1, |
293 mock_instance_clients()->size()); | 291 mock_instance_clients()->size()); |
294 // Remove the connection by peer | 292 // Remove the connection by peer |
295 mock_instance_clients()->at(current_mock_instance_index_).reset(); | 293 mock_instance_clients()->at(current_mock_instance_index_).reset(); |
296 std::move(request); | 294 std::move(request); |
297 break; | 295 break; |
298 case StartMode::SUCCEED: | 296 case StartMode::SUCCEED: |
299 MessageReceiver::OnStartWorker( | 297 MessageReceiver::OnStartWorker( |
300 embedded_worker_id, service_worker_version_id, scope, script_url, | 298 embedded_worker_id, service_worker_version_id, scope, script_url, |
301 pause_after_download, std::move(request), std::move(instance_host), | 299 pause_after_download, std::move(request), std::move(instance_host)); |
302 std::move(provider_info)); | |
303 break; | 300 break; |
304 } | 301 } |
305 current_mock_instance_index_++; | 302 current_mock_instance_index_++; |
306 } | 303 } |
307 | 304 |
308 void OnStopWorker(int embedded_worker_id) override { | 305 void OnStopWorker(int embedded_worker_id) override { |
309 if (instance_host_ptr_map_[embedded_worker_id]) { | 306 if (instance_host_ptr_map_[embedded_worker_id]) { |
310 instance_host_ptr_map_[embedded_worker_id]->OnStopped(); | 307 instance_host_ptr_map_[embedded_worker_id]->OnStopped(); |
311 base::RunLoop().RunUntilIdle(); | 308 base::RunLoop().RunUntilIdle(); |
312 return; | 309 return; |
(...skipping 387 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
700 version_->AddListener(&listener); | 697 version_->AddListener(&listener); |
701 | 698 |
702 ServiceWorkerStatusCode status = SERVICE_WORKER_ERROR_FAILED; | 699 ServiceWorkerStatusCode status = SERVICE_WORKER_ERROR_FAILED; |
703 version_->StartWorker(ServiceWorkerMetrics::EventType::UNKNOWN, | 700 version_->StartWorker(ServiceWorkerMetrics::EventType::UNKNOWN, |
704 CreateReceiverOnCurrentThread(&status)); | 701 CreateReceiverOnCurrentThread(&status)); |
705 base::RunLoop().RunUntilIdle(); | 702 base::RunLoop().RunUntilIdle(); |
706 EXPECT_EQ(SERVICE_WORKER_OK, status); | 703 EXPECT_EQ(SERVICE_WORKER_OK, status); |
707 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, version_->running_status()); | 704 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, version_->running_status()); |
708 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, listener.last_status); | 705 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, listener.last_status); |
709 | 706 |
710 // Destruct |version_| by releasing all references, including the provider | |
711 // host's. | |
712 helper_->context()->RemoveProviderHost( | |
713 version_->provider_host()->process_id(), | |
714 version_->provider_host()->provider_id()); | |
715 version_ = nullptr; | 707 version_ = nullptr; |
716 EXPECT_EQ(EmbeddedWorkerStatus::STOPPING, listener.last_status); | 708 EXPECT_EQ(EmbeddedWorkerStatus::STOPPING, listener.last_status); |
717 } | 709 } |
718 | 710 |
719 // Test that update isn't triggered for a non-stale worker. | 711 // Test that update isn't triggered for a non-stale worker. |
720 TEST_F(ServiceWorkerVersionTest, StaleUpdate_FreshWorker) { | 712 TEST_F(ServiceWorkerVersionTest, StaleUpdate_FreshWorker) { |
721 version_->SetStatus(ServiceWorkerVersion::ACTIVATED); | 713 version_->SetStatus(ServiceWorkerVersion::ACTIVATED); |
722 registration_->SetActiveVersion(version_); | 714 registration_->SetActiveVersion(version_); |
723 registration_->set_last_update_check(base::Time::Now()); | 715 registration_->set_last_update_check(base::Time::Now()); |
724 SimulateDispatchEvent(ServiceWorkerMetrics::EventType::PUSH); | 716 SimulateDispatchEvent(ServiceWorkerMetrics::EventType::PUSH); |
(...skipping 725 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1450 // OnStarted. | 1442 // OnStarted. |
1451 version_->StopWorker(CreateReceiverOnCurrentThread(&status2)); | 1443 version_->StopWorker(CreateReceiverOnCurrentThread(&status2)); |
1452 base::RunLoop().RunUntilIdle(); | 1444 base::RunLoop().RunUntilIdle(); |
1453 | 1445 |
1454 EXPECT_EQ(SERVICE_WORKER_OK, status1); | 1446 EXPECT_EQ(SERVICE_WORKER_OK, status1); |
1455 EXPECT_EQ(SERVICE_WORKER_OK, status2); | 1447 EXPECT_EQ(SERVICE_WORKER_OK, status2); |
1456 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, version_->running_status()); | 1448 EXPECT_EQ(EmbeddedWorkerStatus::RUNNING, version_->running_status()); |
1457 } | 1449 } |
1458 | 1450 |
1459 } // namespace content | 1451 } // namespace content |
OLD | NEW |