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 |