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/embedded_worker_test_helper.h" | 5 #include "content/browser/service_worker/embedded_worker_test_helper.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <string> | 8 #include <string> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
93 new MockServiceWorkerDatabaseTaskManager( | 93 new MockServiceWorkerDatabaseTaskManager( |
94 base::ThreadTaskRunnerHandle::Get())); | 94 base::ThreadTaskRunnerHandle::Get())); |
95 wrapper_->InitInternal(user_data_directory, std::move(database_task_manager), | 95 wrapper_->InitInternal(user_data_directory, std::move(database_task_manager), |
96 base::ThreadTaskRunnerHandle::Get(), nullptr, nullptr); | 96 base::ThreadTaskRunnerHandle::Get(), nullptr, nullptr); |
97 wrapper_->process_manager()->SetProcessIdForTest(mock_render_process_id()); | 97 wrapper_->process_manager()->SetProcessIdForTest(mock_render_process_id()); |
98 wrapper_->process_manager()->SetNewProcessIdForTest(new_render_process_id()); | 98 wrapper_->process_manager()->SetNewProcessIdForTest(new_render_process_id()); |
99 registry()->AddChildProcessSender(mock_render_process_id_, this, | 99 registry()->AddChildProcessSender(mock_render_process_id_, this, |
100 NewMessagePortMessageFilter()); | 100 NewMessagePortMessageFilter()); |
101 | 101 |
102 // Setup process level mojo service registry pair. | 102 // Setup process level mojo service registry pair. |
103 std::unique_ptr<ServiceRegistryImpl> host_service_registry( | 103 render_process_interface_registry_.reset( |
104 new ServiceRegistryImpl); | 104 new shell::InterfaceRegistry(nullptr)); |
105 render_process_service_registry_.ServiceRegistry::AddService( | 105 render_process_interface_registry_->AddInterface( |
106 base::Bind(&MockEmbeddedWorkerSetup::Create, weak_factory_.GetWeakPtr())); | 106 base::Bind(&MockEmbeddedWorkerSetup::Create, weak_factory_.GetWeakPtr())); |
107 shell::mojom::InterfaceProviderPtr services; | 107 shell::mojom::InterfaceProviderPtr interfaces; |
108 render_process_service_registry_.Bind( | 108 render_process_interface_registry_->Bind(mojo::GetProxy(&interfaces)); |
109 host_service_registry->TakeRemoteRequest()); | 109 |
110 render_process_host_->SetServiceRegistry(std::move(host_service_registry)); | 110 std::unique_ptr<shell::InterfaceProvider> host_remote_interfaces( |
| 111 new shell::InterfaceProvider); |
| 112 host_remote_interfaces->Bind(std::move(interfaces)); |
| 113 std::unique_ptr<shell::InterfaceRegistry> host_registry( |
| 114 new shell::InterfaceRegistry(nullptr)); |
| 115 render_process_host_->SetInterfaceRegistry(std::move(host_registry)); |
| 116 render_process_host_->SetRemoteInterfaces(std::move(host_remote_interfaces)); |
111 } | 117 } |
112 | 118 |
113 EmbeddedWorkerTestHelper::~EmbeddedWorkerTestHelper() { | 119 EmbeddedWorkerTestHelper::~EmbeddedWorkerTestHelper() { |
114 if (wrapper_.get()) | 120 if (wrapper_.get()) |
115 wrapper_->Shutdown(); | 121 wrapper_->Shutdown(); |
116 } | 122 } |
117 | 123 |
118 void EmbeddedWorkerTestHelper::SimulateAddProcessToPattern( | 124 void EmbeddedWorkerTestHelper::SimulateAddProcessToPattern( |
119 const GURL& pattern, | 125 const GURL& pattern, |
120 int process_id) { | 126 int process_id) { |
(...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
443 | 449 |
444 MessagePortMessageFilter* | 450 MessagePortMessageFilter* |
445 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 451 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
446 scoped_refptr<MessagePortMessageFilter> filter( | 452 scoped_refptr<MessagePortMessageFilter> filter( |
447 new MockMessagePortMessageFilter); | 453 new MockMessagePortMessageFilter); |
448 message_port_message_filters_.push_back(filter); | 454 message_port_message_filters_.push_back(filter); |
449 return filter.get(); | 455 return filter.get(); |
450 } | 456 } |
451 | 457 |
452 } // namespace content | 458 } // namespace content |
OLD | NEW |