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

Side by Side Diff: services/service_manager/tests/util.cc

Issue 2610173003: Add RegisterService, split out of Connect(). (Closed)
Patch Set: . Created 3 years, 11 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 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 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 "services/service_manager/tests/util.h" 5 #include "services/service_manager/tests/util.h"
6 6
7 #include "base/base_paths.h" 7 #include "base/base_paths.h"
8 #include "base/base_switches.h" 8 #include "base/base_switches.h"
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "base/command_line.h" 10 #include "base/command_line.h"
(...skipping 18 matching lines...) Expand all
29 namespace { 29 namespace {
30 30
31 void QuitLoop(base::RunLoop* loop) { 31 void QuitLoop(base::RunLoop* loop) {
32 loop->Quit(); 32 loop->Quit();
33 } 33 }
34 34
35 } // namespace 35 } // namespace
36 36
37 std::unique_ptr<Connection> LaunchAndConnectToProcess( 37 std::unique_ptr<Connection> LaunchAndConnectToProcess(
38 const std::string& target_exe_name, 38 const std::string& target_exe_name,
39 const Identity target, 39 const Identity& target,
40 service_manager::Connector* connector, 40 service_manager::Connector* connector,
41 base::Process* process) { 41 base::Process* process) {
42 base::FilePath target_path; 42 base::FilePath target_path;
43 CHECK(base::PathService::Get(base::DIR_EXE, &target_path)); 43 CHECK(base::PathService::Get(base::DIR_EXE, &target_path));
44 target_path = target_path.AppendASCII(target_exe_name); 44 target_path = target_path.AppendASCII(target_exe_name);
45 45
46 base::CommandLine child_command_line(target_path); 46 base::CommandLine child_command_line(target_path);
47 // Forward the wait-for-debugger flag but nothing else - we don't want to 47 // Forward the wait-for-debugger flag but nothing else - we don't want to
48 // stamp on the platform-channel flag. 48 // stamp on the platform-channel flag.
49 if (base::CommandLine::ForCurrentProcess()->HasSwitch( 49 if (base::CommandLine::ForCurrentProcess()->HasSwitch(
(...skipping 17 matching lines...) Expand all
67 // Allocate the pipe locally. 67 // Allocate the pipe locally.
68 std::string child_token = mojo::edk::GenerateRandomToken(); 68 std::string child_token = mojo::edk::GenerateRandomToken();
69 mojo::ScopedMessagePipeHandle pipe = 69 mojo::ScopedMessagePipeHandle pipe =
70 mojo::edk::CreateParentMessagePipe(primordial_pipe_token, child_token); 70 mojo::edk::CreateParentMessagePipe(primordial_pipe_token, child_token);
71 71
72 service_manager::mojom::ServicePtr client; 72 service_manager::mojom::ServicePtr client;
73 client.Bind(mojo::InterfacePtrInfo<service_manager::mojom::Service>( 73 client.Bind(mojo::InterfacePtrInfo<service_manager::mojom::Service>(
74 std::move(pipe), 0u)); 74 std::move(pipe), 0u));
75 service_manager::mojom::PIDReceiverPtr receiver; 75 service_manager::mojom::PIDReceiverPtr receiver;
76 76
77 service_manager::Connector::ConnectParams params(target); 77 connector->Start(target, std::move(client), MakeRequest(&receiver));
78 params.set_client_process_connection(std::move(client),
79 MakeRequest(&receiver));
80 std::unique_ptr<service_manager::Connection> connection = 78 std::unique_ptr<service_manager::Connection> connection =
81 connector->Connect(&params); 79 connector->Connect(target);
82 { 80 {
83 base::RunLoop loop; 81 base::RunLoop loop;
84 connection->AddConnectionCompletedClosure(base::Bind(&QuitLoop, &loop)); 82 connection->AddConnectionCompletedClosure(base::Bind(&QuitLoop, &loop));
85 base::MessageLoop::ScopedNestableTaskAllower allow( 83 base::MessageLoop::ScopedNestableTaskAllower allow(
86 base::MessageLoop::current()); 84 base::MessageLoop::current());
87 loop.Run(); 85 loop.Run();
88 } 86 }
89 87
90 base::LaunchOptions options; 88 base::LaunchOptions options;
91 #if defined(OS_WIN) 89 #if defined(OS_WIN)
92 options.handles_to_inherit = &handle_passing_info; 90 options.handles_to_inherit = &handle_passing_info;
93 #elif defined(OS_POSIX) 91 #elif defined(OS_POSIX)
94 options.fds_to_remap = &handle_passing_info; 92 options.fds_to_remap = &handle_passing_info;
95 #endif 93 #endif
96 *process = base::LaunchProcess(child_command_line, options); 94 *process = base::LaunchProcess(child_command_line, options);
97 DCHECK(process->IsValid()); 95 DCHECK(process->IsValid());
98 receiver->SetPID(process->Pid()); 96 receiver->SetPID(process->Pid());
99 mojo::edk::ChildProcessLaunched(process->Handle(), 97 mojo::edk::ChildProcessLaunched(process->Handle(),
100 platform_channel_pair.PassServerHandle(), 98 platform_channel_pair.PassServerHandle(),
101 child_token); 99 child_token);
102 return connection; 100 return connection;
103 } 101 }
104 102
105 } // namespace test 103 } // namespace test
106 } // namespace service_manager 104 } // namespace service_manager
OLDNEW
« no previous file with comments | « services/service_manager/tests/util.h ('k') | third_party/WebKit/Source/platform/ServiceConnector.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698