| 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 512 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 523 const PushEventPayload& payload) { | 523 const PushEventPayload& payload) { |
| 524 base::ThreadTaskRunnerHandle::Get()->PostTask( | 524 base::ThreadTaskRunnerHandle::Get()->PostTask( |
| 525 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), | 525 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, AsWeakPtr(), |
| 526 current_embedded_worker_id_, request_id, payload)); | 526 current_embedded_worker_id_, request_id, payload)); |
| 527 } | 527 } |
| 528 | 528 |
| 529 void EmbeddedWorkerTestHelper::OnSetupMojoStub( | 529 void EmbeddedWorkerTestHelper::OnSetupMojoStub( |
| 530 int thread_id, | 530 int thread_id, |
| 531 service_manager::mojom::InterfaceProviderRequest request, | 531 service_manager::mojom::InterfaceProviderRequest request, |
| 532 service_manager::mojom::InterfaceProviderPtr remote_interfaces) { | 532 service_manager::mojom::InterfaceProviderPtr remote_interfaces) { |
| 533 std::unique_ptr<service_manager::InterfaceRegistry> local( | 533 auto local = base::MakeUnique<service_manager::InterfaceRegistry>( |
| 534 new service_manager::InterfaceRegistry); | 534 service_manager::Identity(), service_manager::InterfaceProviderSpec()); |
| 535 local->Bind(std::move(request)); | 535 local->Bind(std::move(request), service_manager::Identity(), |
| 536 service_manager::InterfaceProviderSpec()); |
| 536 | 537 |
| 537 std::unique_ptr<service_manager::InterfaceProvider> remote( | 538 std::unique_ptr<service_manager::InterfaceProvider> remote( |
| 538 new service_manager::InterfaceProvider); | 539 new service_manager::InterfaceProvider); |
| 539 remote->Bind(std::move(remote_interfaces)); | 540 remote->Bind(std::move(remote_interfaces)); |
| 540 | 541 |
| 541 OnSetupMojo(thread_id, local.get()); | 542 OnSetupMojo(thread_id, local.get()); |
| 542 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); | 543 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); |
| 543 thread_id_service_registry_map_[thread_id] = std::move(pair); | 544 thread_id_service_registry_map_[thread_id] = std::move(pair); |
| 544 } | 545 } |
| 545 | 546 |
| 546 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { | 547 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { |
| 547 DCHECK(context()); | 548 DCHECK(context()); |
| 548 return context()->embedded_worker_registry(); | 549 return context()->embedded_worker_registry(); |
| 549 } | 550 } |
| 550 | 551 |
| 551 MessagePortMessageFilter* | 552 MessagePortMessageFilter* |
| 552 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 553 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
| 553 scoped_refptr<MessagePortMessageFilter> filter( | 554 scoped_refptr<MessagePortMessageFilter> filter( |
| 554 new MockMessagePortMessageFilter); | 555 new MockMessagePortMessageFilter); |
| 555 message_port_message_filters_.push_back(filter); | 556 message_port_message_filters_.push_back(filter); |
| 556 return filter.get(); | 557 return filter.get(); |
| 557 } | 558 } |
| 558 | 559 |
| 559 std::unique_ptr<service_manager::InterfaceRegistry> | 560 std::unique_ptr<service_manager::InterfaceRegistry> |
| 560 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { | 561 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { |
| 561 std::unique_ptr<service_manager::InterfaceRegistry> registry( | 562 auto registry = base::MakeUnique<service_manager::InterfaceRegistry>( |
| 562 new service_manager::InterfaceRegistry); | 563 service_manager::Identity(), service_manager::InterfaceProviderSpec()); |
| 563 registry->AddInterface( | 564 registry->AddInterface( |
| 564 base::Bind(&MockEmbeddedWorkerSetup::Create, AsWeakPtr())); | 565 base::Bind(&MockEmbeddedWorkerSetup::Create, AsWeakPtr())); |
| 565 registry->AddInterface( | 566 registry->AddInterface( |
| 566 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); | 567 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); |
| 567 | 568 |
| 568 service_manager::mojom::InterfaceProviderPtr interfaces; | 569 service_manager::mojom::InterfaceProviderPtr interfaces; |
| 569 registry->Bind(mojo::GetProxy(&interfaces)); | 570 registry->Bind(mojo::GetProxy(&interfaces), service_manager::Identity(), |
| 571 service_manager::InterfaceProviderSpec()); |
| 570 | 572 |
| 571 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 573 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
| 572 new service_manager::InterfaceProvider); | 574 new service_manager::InterfaceProvider); |
| 573 remote_interfaces->Bind(std::move(interfaces)); | 575 remote_interfaces->Bind(std::move(interfaces)); |
| 574 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 576 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
| 575 return registry; | 577 return registry; |
| 576 } | 578 } |
| 577 | 579 |
| 578 } // namespace content | 580 } // namespace content |
| OLD | NEW |