| 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 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 95 new MockServiceWorkerDatabaseTaskManager( | 95 new MockServiceWorkerDatabaseTaskManager( |
| 96 base::ThreadTaskRunnerHandle::Get())); | 96 base::ThreadTaskRunnerHandle::Get())); |
| 97 wrapper_->InitInternal(user_data_directory, std::move(database_task_manager), | 97 wrapper_->InitInternal(user_data_directory, std::move(database_task_manager), |
| 98 base::ThreadTaskRunnerHandle::Get(), nullptr, nullptr); | 98 base::ThreadTaskRunnerHandle::Get(), nullptr, nullptr); |
| 99 wrapper_->process_manager()->SetProcessIdForTest(mock_render_process_id()); | 99 wrapper_->process_manager()->SetProcessIdForTest(mock_render_process_id()); |
| 100 wrapper_->process_manager()->SetNewProcessIdForTest(new_render_process_id()); | 100 wrapper_->process_manager()->SetNewProcessIdForTest(new_render_process_id()); |
| 101 registry()->AddChildProcessSender(mock_render_process_id_, this, | 101 registry()->AddChildProcessSender(mock_render_process_id_, this, |
| 102 NewMessagePortMessageFilter()); | 102 NewMessagePortMessageFilter()); |
| 103 | 103 |
| 104 // Setup process level interface registry. | 104 // Setup process level interface registry. |
| 105 render_process_interface_registry_.reset( | 105 render_process_interface_registry_.reset(new shell::InterfaceRegistry); |
| 106 new shell::InterfaceRegistry(nullptr)); | |
| 107 render_process_interface_registry_->AddInterface( | 106 render_process_interface_registry_->AddInterface( |
| 108 base::Bind(&MockEmbeddedWorkerSetup::Create, weak_factory_.GetWeakPtr())); | 107 base::Bind(&MockEmbeddedWorkerSetup::Create, weak_factory_.GetWeakPtr())); |
| 109 shell::mojom::InterfaceProviderPtr interfaces; | 108 shell::mojom::InterfaceProviderPtr interfaces; |
| 110 render_process_interface_registry_->Bind(mojo::GetProxy(&interfaces)); | 109 render_process_interface_registry_->Bind(mojo::GetProxy(&interfaces)); |
| 111 | 110 |
| 112 std::unique_ptr<shell::InterfaceProvider> host_remote_interfaces( | 111 std::unique_ptr<shell::InterfaceProvider> host_remote_interfaces( |
| 113 new shell::InterfaceProvider); | 112 new shell::InterfaceProvider); |
| 114 host_remote_interfaces->Bind(std::move(interfaces)); | 113 host_remote_interfaces->Bind(std::move(interfaces)); |
| 115 render_process_host_->SetRemoteInterfaces(std::move(host_remote_interfaces)); | 114 render_process_host_->SetRemoteInterfaces(std::move(host_remote_interfaces)); |
| 116 } | 115 } |
| (...skipping 296 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 413 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, | 412 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, |
| 414 weak_factory_.GetWeakPtr(), | 413 weak_factory_.GetWeakPtr(), |
| 415 current_embedded_worker_id_, request_id, payload)); | 414 current_embedded_worker_id_, request_id, payload)); |
| 416 } | 415 } |
| 417 | 416 |
| 418 void EmbeddedWorkerTestHelper::OnSetupMojoStub( | 417 void EmbeddedWorkerTestHelper::OnSetupMojoStub( |
| 419 int thread_id, | 418 int thread_id, |
| 420 shell::mojom::InterfaceProviderRequest request, | 419 shell::mojom::InterfaceProviderRequest request, |
| 421 shell::mojom::InterfaceProviderPtr remote_interfaces) { | 420 shell::mojom::InterfaceProviderPtr remote_interfaces) { |
| 422 std::unique_ptr<shell::InterfaceRegistry> local( | 421 std::unique_ptr<shell::InterfaceRegistry> local( |
| 423 new shell::InterfaceRegistry(nullptr)); | 422 new shell::InterfaceRegistry); |
| 424 local->Bind(std::move(request)); | 423 local->Bind(std::move(request)); |
| 425 | 424 |
| 426 std::unique_ptr<shell::InterfaceProvider> remote( | 425 std::unique_ptr<shell::InterfaceProvider> remote( |
| 427 new shell::InterfaceProvider); | 426 new shell::InterfaceProvider); |
| 428 remote->Bind(std::move(remote_interfaces)); | 427 remote->Bind(std::move(remote_interfaces)); |
| 429 | 428 |
| 430 OnSetupMojo(local.get()); | 429 OnSetupMojo(local.get()); |
| 431 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); | 430 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); |
| 432 thread_id_service_registry_map_[thread_id] = std::move(pair); | 431 thread_id_service_registry_map_[thread_id] = std::move(pair); |
| 433 } | 432 } |
| 434 | 433 |
| 435 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { | 434 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { |
| 436 DCHECK(context()); | 435 DCHECK(context()); |
| 437 return context()->embedded_worker_registry(); | 436 return context()->embedded_worker_registry(); |
| 438 } | 437 } |
| 439 | 438 |
| 440 MessagePortMessageFilter* | 439 MessagePortMessageFilter* |
| 441 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 440 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
| 442 scoped_refptr<MessagePortMessageFilter> filter( | 441 scoped_refptr<MessagePortMessageFilter> filter( |
| 443 new MockMessagePortMessageFilter); | 442 new MockMessagePortMessageFilter); |
| 444 message_port_message_filters_.push_back(filter); | 443 message_port_message_filters_.push_back(filter); |
| 445 return filter.get(); | 444 return filter.get(); |
| 446 } | 445 } |
| 447 | 446 |
| 448 } // namespace content | 447 } // namespace content |
| OLD | NEW |