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 auto local = base::MakeUnique<service_manager::InterfaceRegistry>( | 533 auto local = base::MakeUnique<service_manager::InterfaceRegistry>(); |
534 service_manager::Identity(), service_manager::InterfaceProviderSpec()); | |
535 local->Bind(std::move(request), service_manager::Identity(), | 534 local->Bind(std::move(request), service_manager::Identity(), |
| 535 service_manager::InterfaceProviderSpec(), |
| 536 service_manager::Identity(), |
536 service_manager::InterfaceProviderSpec()); | 537 service_manager::InterfaceProviderSpec()); |
537 | 538 |
538 std::unique_ptr<service_manager::InterfaceProvider> remote( | 539 std::unique_ptr<service_manager::InterfaceProvider> remote( |
539 new service_manager::InterfaceProvider); | 540 new service_manager::InterfaceProvider); |
540 remote->Bind(std::move(remote_interfaces)); | 541 remote->Bind(std::move(remote_interfaces)); |
541 | 542 |
542 OnSetupMojo(thread_id, local.get()); | 543 OnSetupMojo(thread_id, local.get()); |
543 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); | 544 InterfaceRegistryAndProvider pair(std::move(local), std::move(remote)); |
544 thread_id_service_registry_map_[thread_id] = std::move(pair); | 545 thread_id_service_registry_map_[thread_id] = std::move(pair); |
545 } | 546 } |
546 | 547 |
547 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { | 548 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { |
548 DCHECK(context()); | 549 DCHECK(context()); |
549 return context()->embedded_worker_registry(); | 550 return context()->embedded_worker_registry(); |
550 } | 551 } |
551 | 552 |
552 MessagePortMessageFilter* | 553 MessagePortMessageFilter* |
553 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 554 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
554 scoped_refptr<MessagePortMessageFilter> filter( | 555 scoped_refptr<MessagePortMessageFilter> filter( |
555 new MockMessagePortMessageFilter); | 556 new MockMessagePortMessageFilter); |
556 message_port_message_filters_.push_back(filter); | 557 message_port_message_filters_.push_back(filter); |
557 return filter.get(); | 558 return filter.get(); |
558 } | 559 } |
559 | 560 |
560 std::unique_ptr<service_manager::InterfaceRegistry> | 561 std::unique_ptr<service_manager::InterfaceRegistry> |
561 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { | 562 EmbeddedWorkerTestHelper::CreateInterfaceRegistry(MockRenderProcessHost* rph) { |
562 auto registry = base::MakeUnique<service_manager::InterfaceRegistry>( | 563 auto registry = base::MakeUnique<service_manager::InterfaceRegistry>(); |
563 service_manager::Identity(), service_manager::InterfaceProviderSpec()); | |
564 registry->AddInterface( | 564 registry->AddInterface( |
565 base::Bind(&MockEmbeddedWorkerSetup::Create, AsWeakPtr())); | 565 base::Bind(&MockEmbeddedWorkerSetup::Create, AsWeakPtr())); |
566 registry->AddInterface( | 566 registry->AddInterface( |
567 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); | 567 base::Bind(&MockEmbeddedWorkerInstanceClient::Bind, AsWeakPtr())); |
568 | 568 |
569 service_manager::mojom::InterfaceProviderPtr interfaces; | 569 service_manager::mojom::InterfaceProviderPtr interfaces; |
570 registry->Bind(mojo::GetProxy(&interfaces), service_manager::Identity(), | 570 registry->Bind(mojo::GetProxy(&interfaces), service_manager::Identity(), |
| 571 service_manager::InterfaceProviderSpec(), |
| 572 service_manager::Identity(), |
571 service_manager::InterfaceProviderSpec()); | 573 service_manager::InterfaceProviderSpec()); |
572 | 574 |
573 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 575 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
574 new service_manager::InterfaceProvider); | 576 new service_manager::InterfaceProvider); |
575 remote_interfaces->Bind(std::move(interfaces)); | 577 remote_interfaces->Bind(std::move(interfaces)); |
576 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 578 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
577 return registry; | 579 return registry; |
578 } | 580 } |
579 | 581 |
580 } // namespace content | 582 } // namespace content |
OLD | NEW |