| 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 |