Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(168)

Side by Side Diff: content/browser/service_worker/embedded_worker_test_helper.cc

Issue 2215133002: Change signature of OnConnect (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@cleanup
Patch Set: . Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW
« no previous file with comments | « content/browser/service_worker/embedded_worker_instance.cc ('k') | content/child/child_thread_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698