Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(404)

Unified Diff: content/browser/service_worker/embedded_worker_test_helper.cc

Issue 2099063002: Migrate RenderProcessHost, ChildThread to InterfaceRegistry/Provider (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: . Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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(
« no previous file with comments | « content/browser/service_worker/embedded_worker_test_helper.h ('k') | content/browser/utility_process_host_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698