Index: content/browser/service_worker/embedded_worker_test_helper.cc |
diff --git a/content/browser/service_worker/embedded_worker_test_helper.cc b/content/browser/service_worker/embedded_worker_test_helper.cc |
index 6e22d4c4eca93228cd85e9686107d6cf24707e93..68d26f874abad9d5ae6c1426f5bb981d483e3747 100644 |
--- a/content/browser/service_worker/embedded_worker_test_helper.cc |
+++ b/content/browser/service_worker/embedded_worker_test_helper.cc |
@@ -26,6 +26,8 @@ |
#include "content/public/test/test_browser_context.h" |
#include "mojo/public/cpp/bindings/interface_request.h" |
#include "mojo/public/cpp/bindings/strong_binding.h" |
+#include "services/shell/public/cpp/interface_provider.h" |
+#include "services/shell/public/cpp/interface_registry.h" |
#include "testing/gtest/include/gtest/gtest.h" |
namespace content { |
@@ -99,15 +101,21 @@ EmbeddedWorkerTestHelper::EmbeddedWorkerTestHelper( |
registry()->AddChildProcessSender(mock_render_process_id_, this, |
NewMessagePortMessageFilter()); |
- // Setup process level mojo service registry pair. |
- std::unique_ptr<ServiceRegistryImpl> host_service_registry( |
- new ServiceRegistryImpl); |
- render_process_service_registry_.ServiceRegistry::AddService( |
+ // Setup process level interface registry. |
+ render_process_interface_registry_.reset( |
+ new shell::InterfaceRegistry(nullptr)); |
+ render_process_interface_registry_->AddInterface( |
base::Bind(&MockEmbeddedWorkerSetup::Create, weak_factory_.GetWeakPtr())); |
- shell::mojom::InterfaceProviderPtr services; |
- render_process_service_registry_.Bind( |
- host_service_registry->TakeRemoteRequest()); |
- render_process_host_->SetServiceRegistry(std::move(host_service_registry)); |
+ shell::mojom::InterfaceProviderPtr interfaces; |
+ render_process_interface_registry_->Bind(mojo::GetProxy(&interfaces)); |
+ |
+ std::unique_ptr<shell::InterfaceProvider> host_remote_interfaces( |
+ new shell::InterfaceProvider); |
+ host_remote_interfaces->Bind(std::move(interfaces)); |
+ std::unique_ptr<shell::InterfaceRegistry> host_registry( |
+ new shell::InterfaceRegistry(nullptr)); |
+ render_process_host_->SetInterfaceRegistry(std::move(host_registry)); |
+ render_process_host_->SetRemoteInterfaces(std::move(host_remote_interfaces)); |
} |
EmbeddedWorkerTestHelper::~EmbeddedWorkerTestHelper() { |
@@ -115,13 +123,12 @@ EmbeddedWorkerTestHelper::~EmbeddedWorkerTestHelper() { |
wrapper_->Shutdown(); |
} |
-void EmbeddedWorkerTestHelper::SimulateAddProcessToPattern( |
- const GURL& pattern, |
- int process_id) { |
+void EmbeddedWorkerTestHelper::SimulateAddProcessToPattern(const GURL& pattern, |
+ int process_id) { |
registry()->AddChildProcessSender(process_id, this, |
NewMessagePortMessageFilter()); |
- wrapper_->process_manager()->AddProcessReferenceToPattern( |
- pattern, process_id); |
+ wrapper_->process_manager()->AddProcessReferenceToPattern(pattern, |
+ process_id); |
} |
bool EmbeddedWorkerTestHelper::Send(IPC::Message* message) { |
@@ -183,10 +190,9 @@ void EmbeddedWorkerTestHelper::OnStopWorker(int embedded_worker_id) { |
SimulateWorkerStopped(embedded_worker_id); |
} |
-bool EmbeddedWorkerTestHelper::OnMessageToWorker( |
- int thread_id, |
- int embedded_worker_id, |
- const IPC::Message& message) { |
+bool EmbeddedWorkerTestHelper::OnMessageToWorker(int thread_id, |
+ int embedded_worker_id, |
+ const IPC::Message& message) { |
bool handled = true; |
current_embedded_worker_id_ = embedded_worker_id; |
IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) |
@@ -207,10 +213,9 @@ void EmbeddedWorkerTestHelper::OnSetupMojo(ServiceRegistry* service_registry) {} |
void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id, |
int request_id) { |
- SimulateSend( |
- new ServiceWorkerHostMsg_ActivateEventFinished( |
- embedded_worker_id, request_id, |
- blink::WebServiceWorkerEventResultCompleted)); |
+ SimulateSend(new ServiceWorkerHostMsg_ActivateEventFinished( |
+ embedded_worker_id, request_id, |
+ blink::WebServiceWorkerEventResultCompleted)); |
} |
void EmbeddedWorkerTestHelper::OnExtendableMessageEvent(int embedded_worker_id, |
@@ -303,24 +308,19 @@ void EmbeddedWorkerTestHelper::SimulateWorkerScriptEvaluated( |
success); |
} |
-void EmbeddedWorkerTestHelper::SimulateWorkerStarted( |
- int embedded_worker_id) { |
+void EmbeddedWorkerTestHelper::SimulateWorkerStarted(int embedded_worker_id) { |
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
ASSERT_TRUE(worker != NULL); |
- registry()->OnWorkerStarted( |
- worker->process_id(), |
- embedded_worker_id); |
+ registry()->OnWorkerStarted(worker->process_id(), embedded_worker_id); |
} |
-void EmbeddedWorkerTestHelper::SimulateWorkerStopped( |
- int embedded_worker_id) { |
+void EmbeddedWorkerTestHelper::SimulateWorkerStopped(int embedded_worker_id) { |
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
if (worker != NULL) |
registry()->OnWorkerStopped(worker->process_id(), embedded_worker_id); |
} |
-void EmbeddedWorkerTestHelper::SimulateSend( |
- IPC::Message* message) { |
+void EmbeddedWorkerTestHelper::SimulateSend(IPC::Message* message) { |
registry()->OnMessageReceived(*message, mock_render_process_id_); |
delete message; |
} |
@@ -352,10 +352,8 @@ void EmbeddedWorkerTestHelper::OnStopWorkerStub(int embedded_worker_id) { |
EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
ASSERT_TRUE(worker != NULL); |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&EmbeddedWorkerTestHelper::OnStopWorker, |
- weak_factory_.GetWeakPtr(), |
- embedded_worker_id)); |
+ FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnStopWorker, |
+ weak_factory_.GetWeakPtr(), embedded_worker_id)); |
} |
void EmbeddedWorkerTestHelper::OnMessageToWorkerStub( |
@@ -369,10 +367,7 @@ void EmbeddedWorkerTestHelper::OnMessageToWorkerStub( |
FROM_HERE, |
base::Bind( |
base::IgnoreResult(&EmbeddedWorkerTestHelper::OnMessageToWorker), |
- weak_factory_.GetWeakPtr(), |
- thread_id, |
- embedded_worker_id, |
- message)); |
+ weak_factory_.GetWeakPtr(), thread_id, embedded_worker_id, message)); |
} |
void EmbeddedWorkerTestHelper::OnActivateEventStub(int request_id) { |
@@ -393,23 +388,18 @@ void EmbeddedWorkerTestHelper::OnExtendableMessageEventStub( |
void EmbeddedWorkerTestHelper::OnInstallEventStub(int request_id) { |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&EmbeddedWorkerTestHelper::OnInstallEvent, |
- weak_factory_.GetWeakPtr(), |
- current_embedded_worker_id_, |
- request_id)); |
+ FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnInstallEvent, |
+ weak_factory_.GetWeakPtr(), |
+ current_embedded_worker_id_, request_id)); |
} |
void EmbeddedWorkerTestHelper::OnFetchEventStub( |
int request_id, |
const ServiceWorkerFetchRequest& request) { |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, |
- base::Bind(&EmbeddedWorkerTestHelper::OnFetchEvent, |
- weak_factory_.GetWeakPtr(), |
- current_embedded_worker_id_, |
- request_id, |
- request)); |
+ FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnFetchEvent, |
+ weak_factory_.GetWeakPtr(), |
+ current_embedded_worker_id_, request_id, request)); |
} |
void EmbeddedWorkerTestHelper::OnPushEventStub( |