Index: content/browser/service_worker/service_worker_job_unittest.cc |
diff --git a/content/browser/service_worker/service_worker_job_unittest.cc b/content/browser/service_worker/service_worker_job_unittest.cc |
index 0cbe471ff32e2fafb6306c3d7753174092f05b6f..e97dccc352b040e758f198305acf15c030f027f0 100644 |
--- a/content/browser/service_worker/service_worker_job_unittest.cc |
+++ b/content/browser/service_worker/service_worker_job_unittest.cc |
@@ -17,7 +17,6 @@ |
#include "content/browser/service_worker/service_worker_registration.h" |
#include "content/browser/service_worker/service_worker_registration_status.h" |
#include "content/browser/service_worker/service_worker_test_utils.h" |
-#include "content/common/service_worker/embedded_worker_messages.h" |
#include "content/common/service_worker/service_worker_messages.h" |
#include "content/public/test/test_browser_thread_bundle.h" |
#include "ipc/ipc_test_sink.h" |
@@ -362,8 +361,7 @@ |
void OnStartWorker(int embedded_worker_id, |
int64_t service_worker_version_id, |
const GURL& scope, |
- const GURL& script_url, |
- bool pause_after_download) override { |
+ const GURL& script_url) override { |
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
registry()->OnWorkerStopped(worker->process_id(), embedded_worker_id); |
} |
@@ -826,8 +824,7 @@ |
void OnStartWorker(int embedded_worker_id, |
int64_t version_id, |
const GURL& scope, |
- const GURL& script, |
- bool pause_after_download) override { |
+ const GURL& script) override { |
const std::string kMockScriptBody = "mock_script"; |
const uint64_t kMockScriptSize = 19284; |
ServiceWorkerVersion* version = context()->GetLiveVersion(version_id); |
@@ -841,7 +838,6 @@ |
if (force_bypass_cache_for_scripts()) |
version->set_force_bypass_cache_for_scripts(true); |
- |
if (!is_update) { |
// Spoof caching the script for the initial version. |
int64_t resource_id = storage()->NewResourceId(); |
@@ -863,15 +859,15 @@ |
version->script_cache_map()->NotifyFinishedCaching( |
script, kMockScriptSize, net::URLRequestStatus(), std::string()); |
} |
- |
- EmbeddedWorkerTestHelper::OnStartWorker( |
- embedded_worker_id, version_id, scope, script, pause_after_download); |
- } |
- |
- void OnResumeAfterDownload(int embedded_worker_id) override { |
if (!force_start_worker_failure_) { |
- EmbeddedWorkerTestHelper::OnResumeAfterDownload(embedded_worker_id); |
+ EmbeddedWorkerTestHelper::OnStartWorker(embedded_worker_id, version_id, |
+ scope, script); |
} else { |
+ (embedded_worker_id_service_worker_version_id_map())[embedded_worker_id] = |
+ version_id; |
+ SimulateWorkerReadyForInspection(embedded_worker_id); |
+ SimulateWorkerScriptCached(embedded_worker_id); |
+ SimulateWorkerScriptLoaded(embedded_worker_id); |
SimulateWorkerThreadStarted(GetNextThreadId(), embedded_worker_id); |
SimulateWorkerScriptEvaluated(embedded_worker_id, false); |
} |
@@ -924,8 +920,7 @@ |
void OnStartWorker(int embedded_worker_id, |
int64_t version_id, |
const GURL& scope, |
- const GURL& script, |
- bool pause_after_download) override { |
+ const GURL& script) override { |
ServiceWorkerVersion* version = context()->GetLiveVersion(version_id); |
ServiceWorkerRegistration* registration = |
context()->GetLiveRegistration(version->registration_id()); |
@@ -938,7 +933,7 @@ |
make_scoped_refptr(registration->active_version())); |
} |
UpdateJobTestHelper::OnStartWorker(embedded_worker_id, version_id, scope, |
- script, pause_after_download); |
+ script); |
} |
void OnRegistrationFailed(ServiceWorkerRegistration* registration) override { |
@@ -1538,39 +1533,4 @@ |
FindRegistrationForPattern(pattern, SERVICE_WORKER_OK); |
} |
-TEST_F(ServiceWorkerJobTest, Update_PauseAfterDownload) { |
- UpdateJobTestHelper* update_helper = new UpdateJobTestHelper; |
- helper_.reset(update_helper); |
- IPC::TestSink* sink = update_helper->ipc_sink(); |
- |
- // The initial version should not pause after download. |
- scoped_refptr<ServiceWorkerRegistration> registration = |
- update_helper->SetupInitialRegistration(kNewVersionOrigin); |
- { |
- const IPC::Message* start_msg = |
- sink->GetUniqueMessageMatching(EmbeddedWorkerMsg_StartWorker::ID); |
- ASSERT_TRUE(start_msg); |
- EmbeddedWorkerMsg_StartWorker::Param param; |
- EmbeddedWorkerMsg_StartWorker::Read(start_msg, ¶m); |
- EmbeddedWorkerMsg_StartWorker_Params start_params = base::get<0>(param); |
- EXPECT_FALSE(start_params.pause_after_download); |
- sink->ClearMessages(); |
- } |
- |
- // The updated version should pause after download. |
- registration->AddListener(update_helper); |
- registration->active_version()->StartUpdate(); |
- base::RunLoop().RunUntilIdle(); |
- { |
- const IPC::Message* start_msg = |
- sink->GetUniqueMessageMatching(EmbeddedWorkerMsg_StartWorker::ID); |
- ASSERT_TRUE(start_msg); |
- EmbeddedWorkerMsg_StartWorker::Param param; |
- EmbeddedWorkerMsg_StartWorker::Read(start_msg, ¶m); |
- EmbeddedWorkerMsg_StartWorker_Params start_params = base::get<0>(param); |
- EXPECT_TRUE(start_params.pause_after_download); |
- sink->ClearMessages(); |
- } |
-} |
- |
} // namespace content |