| Index: content/browser/service_worker/embedded_worker_instance_unittest.cc
|
| diff --git a/content/browser/service_worker/embedded_worker_instance_unittest.cc b/content/browser/service_worker/embedded_worker_instance_unittest.cc
|
| index cbe3047edec30ff4f0d9f9658d06940608f877a0..450fbeb3e1ab57d909f78b0c261d75f5f913a7b2 100644
|
| --- a/content/browser/service_worker/embedded_worker_instance_unittest.cc
|
| +++ b/content/browser/service_worker/embedded_worker_instance_unittest.cc
|
| @@ -44,30 +44,6 @@ void SaveStatusAndCall(ServiceWorkerStatusCode* out,
|
|
|
| } // namespace
|
|
|
| -class ProviderHostEndpoints : public mojom::ServiceWorkerProviderHost {
|
| - public:
|
| - ProviderHostEndpoints() : binding_(this) {}
|
| -
|
| - ~ProviderHostEndpoints() override {}
|
| -
|
| - mojom::ServiceWorkerProviderInfoForStartWorkerPtr CreateProviderInfoPtr() {
|
| - DCHECK(!binding_.is_bound());
|
| - DCHECK(!client_.is_bound());
|
| - // Just keep the endpoints.
|
| - mojom::ServiceWorkerProviderInfoForStartWorkerPtr provider_info =
|
| - mojom::ServiceWorkerProviderInfoForStartWorker::New();
|
| - binding_.Bind(mojo::MakeRequest(&provider_info->host_ptr_info));
|
| - provider_info->client_request = mojo::MakeRequest(&client_);
|
| - return provider_info;
|
| - }
|
| -
|
| - private:
|
| - mojom::ServiceWorkerProviderAssociatedPtr client_;
|
| - mojo::AssociatedBinding<mojom::ServiceWorkerProviderHost> binding_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ProviderHostEndpoints);
|
| -};
|
| -
|
| class EmbeddedWorkerInstanceTest : public testing::Test,
|
| public EmbeddedWorkerInstance::Listener {
|
| protected:
|
| @@ -106,7 +82,7 @@ class EmbeddedWorkerInstanceTest : public testing::Test,
|
| RecordEvent(DETACHED, old_status);
|
| }
|
|
|
| - bool OnMessageReceived(const IPC::Message&) override { return false; }
|
| + bool OnMessageReceived(const IPC::Message& message) override { return false; }
|
|
|
| void SetUp() override {
|
| helper_.reset(new EmbeddedWorkerTestHelper(base::FilePath()));
|
| @@ -122,7 +98,7 @@ class EmbeddedWorkerInstanceTest : public testing::Test,
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(id, pattern, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| run_loop.Run();
|
| return status;
|
| @@ -140,18 +116,6 @@ class EmbeddedWorkerInstanceTest : public testing::Test,
|
| return params;
|
| }
|
|
|
| - mojom::ServiceWorkerProviderInfoForStartWorkerPtr CreateProviderInfo(
|
| - int /* process_id */) {
|
| - provider_host_endpoints_.emplace_back(
|
| - base::MakeUnique<ProviderHostEndpoints>());
|
| - return provider_host_endpoints_.back()->CreateProviderInfoPtr();
|
| - }
|
| -
|
| - EmbeddedWorkerInstance::ProviderInfoGetter CreateProviderInfoGetter() {
|
| - return base::BindOnce(&EmbeddedWorkerInstanceTest::CreateProviderInfo,
|
| - base::Unretained(this));
|
| - }
|
| -
|
| mojom::ServiceWorkerEventDispatcherRequest CreateEventDispatcher() {
|
| dispatchers_.emplace_back();
|
| return mojo::MakeRequest(&dispatchers_.back());
|
| @@ -173,7 +137,6 @@ class EmbeddedWorkerInstanceTest : public testing::Test,
|
| }
|
|
|
| std::vector<mojom::ServiceWorkerEventDispatcherPtr> dispatchers_;
|
| - std::vector<std::unique_ptr<ProviderHostEndpoints>> provider_host_endpoints_;
|
|
|
| TestBrowserThreadBundle thread_bundle_;
|
| std::unique_ptr<EmbeddedWorkerTestHelper> helper_;
|
| @@ -190,16 +153,14 @@ class StalledInStartWorkerHelper : public EmbeddedWorkerTestHelper {
|
| StalledInStartWorkerHelper() : EmbeddedWorkerTestHelper(base::FilePath()) {}
|
| ~StalledInStartWorkerHelper() override {}
|
|
|
| - void OnStartWorker(
|
| - int embedded_worker_id,
|
| - int64_t service_worker_version_id,
|
| - const GURL& scope,
|
| - const GURL& script_url,
|
| - bool pause_after_download,
|
| - mojom::ServiceWorkerEventDispatcherRequest request,
|
| - mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo instance_host,
|
| - mojom::ServiceWorkerProviderInfoForStartWorkerPtr provider_info)
|
| - override {
|
| + void OnStartWorker(int embedded_worker_id,
|
| + int64_t service_worker_version_id,
|
| + const GURL& scope,
|
| + const GURL& script_url,
|
| + bool pause_after_download,
|
| + mojom::ServiceWorkerEventDispatcherRequest request,
|
| + mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo
|
| + instance_host) override {
|
| if (force_stall_in_start_) {
|
| // Prepare for OnStopWorker().
|
| instance_host_ptr_map_[embedded_worker_id].Bind(std::move(instance_host));
|
| @@ -208,8 +169,7 @@ class StalledInStartWorkerHelper : public EmbeddedWorkerTestHelper {
|
| }
|
| EmbeddedWorkerTestHelper::OnStartWorker(
|
| embedded_worker_id, service_worker_version_id, scope, script_url,
|
| - pause_after_download, std::move(request), std::move(instance_host),
|
| - std::move(provider_info));
|
| + pause_after_download, std::move(request), std::move(instance_host));
|
| }
|
|
|
| void OnStopWorker(int embedded_worker_id) override {
|
| @@ -254,7 +214,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StartAndStop) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(service_worker_version_id, pattern, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| EXPECT_EQ(EmbeddedWorkerStatus::STARTING, worker->status());
|
| run_loop.Run();
|
| @@ -311,7 +271,7 @@ TEST_F(EmbeddedWorkerInstanceTest, ForceNewProcess) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(service_worker_version_id, pattern, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| run_loop.Run();
|
| EXPECT_EQ(SERVICE_WORKER_OK, status);
|
| @@ -336,7 +296,7 @@ TEST_F(EmbeddedWorkerInstanceTest, ForceNewProcess) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(service_worker_version_id, pattern, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| EXPECT_EQ(EmbeddedWorkerStatus::STARTING, worker->status());
|
| run_loop.Run();
|
| @@ -417,7 +377,7 @@ TEST_F(EmbeddedWorkerInstanceTest, RemoveWorkerInSharedProcess) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id1, pattern, url);
|
| worker1->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| run_loop.Run();
|
| EXPECT_EQ(SERVICE_WORKER_OK, status);
|
| @@ -430,7 +390,7 @@ TEST_F(EmbeddedWorkerInstanceTest, RemoveWorkerInSharedProcess) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id2, pattern, url);
|
| worker2->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| run_loop.Run();
|
| EXPECT_EQ(SERVICE_WORKER_OK, status);
|
| @@ -468,7 +428,7 @@ TEST_F(EmbeddedWorkerInstanceTest, DetachDuringProcessAllocation) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, base::Bind(&base::DoNothing)));
|
| worker->Detach();
|
| base::RunLoop().RunUntilIdle();
|
| @@ -501,7 +461,7 @@ TEST_F(EmbeddedWorkerInstanceTest, DetachAfterSendingStartWorkerMessage) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, base::Bind(&base::DoNothing)));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| @@ -541,7 +501,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StopDuringProcessAllocation) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, base::Bind(&base::DoNothing)));
|
| worker->Stop();
|
| base::RunLoop().RunUntilIdle();
|
| @@ -564,7 +524,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StopDuringProcessAllocation) {
|
| std::unique_ptr<base::RunLoop> run_loop(new base::RunLoop);
|
| params = CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop->QuitClosure()));
|
| run_loop->Run();
|
|
|
| @@ -616,7 +576,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StopDuringPausedAfterDownload) {
|
| CreateStartParams(version_id, scope, url);
|
| params->pause_after_download = true;
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, base::Bind(&base::DoNothing)));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| @@ -646,7 +606,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StopAfterSendingStartWorkerMessage) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, base::Bind(&base::DoNothing)));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| @@ -679,7 +639,7 @@ TEST_F(EmbeddedWorkerInstanceTest, StopAfterSendingStartWorkerMessage) {
|
|
|
| params = CreateStartParams(version_id, scope, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop->QuitClosure()));
|
| run_loop->Run();
|
|
|
| @@ -710,7 +670,7 @@ TEST_F(EmbeddedWorkerInstanceTest, Detach) {
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, pattern, url);
|
| worker->Start(
|
| - std::move(params), CreateProviderInfoGetter(), CreateEventDispatcher(),
|
| + std::move(params), CreateEventDispatcher(),
|
| base::Bind(&SaveStatusAndCall, &status, run_loop.QuitClosure()));
|
| run_loop.Run();
|
|
|
| @@ -744,8 +704,7 @@ TEST_F(EmbeddedWorkerInstanceTest, FailToSendStartIPC) {
|
| // Attempt to start the worker.
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, pattern, url);
|
| - worker->Start(std::move(params), CreateProviderInfoGetter(),
|
| - CreateEventDispatcher(),
|
| + worker->Start(std::move(params), CreateEventDispatcher(),
|
| base::Bind(&ServiceWorkerUtils::NoOpStatusCallback));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| @@ -764,10 +723,11 @@ class FailEmbeddedWorkerInstanceClientImpl
|
| : EmbeddedWorkerTestHelper::MockEmbeddedWorkerInstanceClient(helper) {}
|
|
|
| private:
|
| - void StartWorker(const EmbeddedWorkerStartParams&,
|
| - mojom::ServiceWorkerEventDispatcherRequest,
|
| - mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo,
|
| - mojom::ServiceWorkerProviderInfoForStartWorkerPtr) override {
|
| + void StartWorker(
|
| + const EmbeddedWorkerStartParams& /* unused */,
|
| + mojom::ServiceWorkerEventDispatcherRequest /* unused */,
|
| + mojom::EmbeddedWorkerInstanceHostAssociatedPtrInfo /* unused */)
|
| + override {
|
| helper_->mock_instance_clients()->clear();
|
| }
|
| };
|
| @@ -792,8 +752,7 @@ TEST_F(EmbeddedWorkerInstanceTest, RemoveRemoteInterface) {
|
| // Attempt to start the worker.
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, pattern, url);
|
| - worker->Start(std::move(params), CreateProviderInfoGetter(),
|
| - CreateEventDispatcher(),
|
| + worker->Start(std::move(params), CreateEventDispatcher(),
|
| base::Bind(&ServiceWorkerUtils::NoOpStatusCallback));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| @@ -849,8 +808,7 @@ TEST_F(EmbeddedWorkerInstanceTest, AddMessageToConsole) {
|
| std::make_pair(blink::WebConsoleMessage::kLevelVerbose, "");
|
| std::unique_ptr<EmbeddedWorkerStartParams> params =
|
| CreateStartParams(version_id, pattern, url);
|
| - worker->Start(std::move(params), CreateProviderInfoGetter(),
|
| - CreateEventDispatcher(),
|
| + worker->Start(std::move(params), CreateEventDispatcher(),
|
| base::Bind(&ServiceWorkerUtils::NoOpStatusCallback));
|
| worker->AddMessageToConsole(test_message.first, test_message.second);
|
| base::RunLoop().RunUntilIdle();
|
|
|