OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/standalone/context.h" | 5 #include "services/service_manager/standalone/context.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <utility> | 10 #include <utility> |
(...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
121 tracer_.Start( | 121 tracer_.Start( |
122 command_line.GetSwitchValueASCII(::switches::kTraceStartup), | 122 command_line.GetSwitchValueASCII(::switches::kTraceStartup), |
123 command_line.GetSwitchValueASCII(::switches::kTraceStartupDuration), | 123 command_line.GetSwitchValueASCII(::switches::kTraceStartupDuration), |
124 "mojo_runner.trace"); | 124 "mojo_runner.trace"); |
125 } | 125 } |
126 | 126 |
127 if (!init_params || init_params->init_edk) | 127 if (!init_params || init_params->init_edk) |
128 EnsureEmbedderIsInitialized(); | 128 EnsureEmbedderIsInitialized(); |
129 | 129 |
130 service_manager_runner_ = base::ThreadTaskRunnerHandle::Get(); | 130 service_manager_runner_ = base::ThreadTaskRunnerHandle::Get(); |
| 131 base::SequencedWorkerPool::EnableForProcess(); |
131 blocking_pool_ = | 132 blocking_pool_ = |
132 new base::SequencedWorkerPool(kMaxBlockingPoolThreads, "blocking_pool", | 133 new base::SequencedWorkerPool(kMaxBlockingPoolThreads, "blocking_pool", |
133 base::TaskPriority::USER_VISIBLE); | 134 base::TaskPriority::USER_VISIBLE); |
134 | 135 |
135 init_edk_ = !init_params || init_params->init_edk; | 136 init_edk_ = !init_params || init_params->init_edk; |
136 if (init_edk_) { | 137 if (init_edk_) { |
137 mojo::edk::InitIPCSupport(this, io_thread_->task_runner().get()); | 138 mojo::edk::InitIPCSupport(this, io_thread_->task_runner().get()); |
138 #if defined(OS_MACOSX) | 139 #if defined(OS_MACOSX) |
139 mojo::edk::SetMachPortProvider(MachBroker::GetInstance()->port_provider()); | 140 mojo::edk::SetMachPortProvider(MachBroker::GetInstance()->port_provider()); |
140 #endif | 141 #endif |
(...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
259 mojom::InterfaceProviderPtr local_interfaces; | 260 mojom::InterfaceProviderPtr local_interfaces; |
260 | 261 |
261 std::unique_ptr<ConnectParams> params(new ConnectParams); | 262 std::unique_ptr<ConnectParams> params(new ConnectParams); |
262 params->set_source(CreateServiceManagerIdentity()); | 263 params->set_source(CreateServiceManagerIdentity()); |
263 params->set_target(Identity(name, mojom::kRootUserID)); | 264 params->set_target(Identity(name, mojom::kRootUserID)); |
264 params->set_remote_interfaces(mojo::GetProxy(&remote_interfaces)); | 265 params->set_remote_interfaces(mojo::GetProxy(&remote_interfaces)); |
265 service_manager_->Connect(std::move(params)); | 266 service_manager_->Connect(std::move(params)); |
266 } | 267 } |
267 | 268 |
268 } // namespace service_manager | 269 } // namespace service_manager |
OLD | NEW |