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

Side by Side Diff: mojo/runner/child_process.cc

Issue 1118473002: [mojo] Replace MessageLoopProxy usage with ThreadTaskRunnerHandle (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fixing build break Created 5 years, 7 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
« no previous file with comments | « mojo/common/handle_watcher.cc ('k') | mojo/runner/in_process_native_runner.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 "mojo/runner/child_process.h" 5 #include "mojo/runner/child_process.h"
6 6
7 #include "base/base_switches.h" 7 #include "base/base_switches.h"
8 #include "base/bind.h" 8 #include "base/bind.h"
9 #include "base/callback_helpers.h" 9 #include "base/callback_helpers.h"
10 #include "base/command_line.h" 10 #include "base/command_line.h"
11 #include "base/debug/debugger.h" 11 #include "base/debug/debugger.h"
12 #include "base/files/file_path.h" 12 #include "base/files/file_path.h"
13 #include "base/location.h" 13 #include "base/location.h"
14 #include "base/logging.h" 14 #include "base/logging.h"
15 #include "base/macros.h" 15 #include "base/macros.h"
16 #include "base/memory/ref_counted.h" 16 #include "base/memory/ref_counted.h"
17 #include "base/memory/scoped_ptr.h" 17 #include "base/memory/scoped_ptr.h"
18 #include "base/message_loop/message_loop.h" 18 #include "base/message_loop/message_loop.h"
19 #include "base/single_thread_task_runner.h" 19 #include "base/single_thread_task_runner.h"
20 #include "base/synchronization/waitable_event.h" 20 #include "base/synchronization/waitable_event.h"
21 #include "base/thread_task_runner_handle.h"
21 #include "base/threading/thread.h" 22 #include "base/threading/thread.h"
22 #include "base/threading/thread_checker.h" 23 #include "base/threading/thread_checker.h"
23 #include "mojo/common/message_pump_mojo.h" 24 #include "mojo/common/message_pump_mojo.h"
24 #include "mojo/edk/embedder/embedder.h" 25 #include "mojo/edk/embedder/embedder.h"
25 #include "mojo/edk/embedder/platform_channel_pair.h" 26 #include "mojo/edk/embedder/platform_channel_pair.h"
26 #include "mojo/edk/embedder/process_delegate.h" 27 #include "mojo/edk/embedder/process_delegate.h"
27 #include "mojo/edk/embedder/scoped_platform_handle.h" 28 #include "mojo/edk/embedder/scoped_platform_handle.h"
28 #include "mojo/edk/embedder/simple_platform_support.h" 29 #include "mojo/edk/embedder/simple_platform_support.h"
29 #include "mojo/public/cpp/system/core.h" 30 #include "mojo/public/cpp/system/core.h"
30 #include "mojo/runner/child_process.mojom.h" 31 #include "mojo/runner/child_process.mojom.h"
(...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after
184 const Blocker::Unblocker& unblocker) { 185 const Blocker::Unblocker& unblocker) {
185 DCHECK(app_context); 186 DCHECK(app_context);
186 DCHECK(platform_channel.is_valid()); 187 DCHECK(platform_channel.is_valid());
187 188
188 DCHECK(!app_context->controller()); 189 DCHECK(!app_context->controller());
189 190
190 scoped_ptr<ChildControllerImpl> impl( 191 scoped_ptr<ChildControllerImpl> impl(
191 new ChildControllerImpl(app_context, unblocker)); 192 new ChildControllerImpl(app_context, unblocker));
192 193
193 ScopedMessagePipeHandle host_message_pipe(embedder::CreateChannel( 194 ScopedMessagePipeHandle host_message_pipe(embedder::CreateChannel(
194 platform_channel.Pass(), app_context->io_runner(), 195 platform_channel.Pass(),
196 app_context->io_runner(),
195 base::Bind(&ChildControllerImpl::DidCreateChannel, 197 base::Bind(&ChildControllerImpl::DidCreateChannel,
196 base::Unretained(impl.get())), 198 base::Unretained(impl.get())),
197 base::MessageLoopProxy::current())); 199 base::ThreadTaskRunnerHandle::Get()));
198 200
199 impl->Bind(host_message_pipe.Pass()); 201 impl->Bind(host_message_pipe.Pass());
200 202
201 app_context->set_controller(impl.Pass()); 203 app_context->set_controller(impl.Pass());
202 } 204 }
203 205
204 void Bind(ScopedMessagePipeHandle handle) { binding_.Bind(handle.Pass()); } 206 void Bind(ScopedMessagePipeHandle handle) { binding_.Bind(handle.Pass()); }
205 207
206 // |ErrorHandler| methods: 208 // |ErrorHandler| methods:
207 void OnConnectionError() override { 209 void OnConnectionError() override {
(...skipping 104 matching lines...) Expand 10 before | Expand all | Expand 10 after
312 // This will block, then run whatever the controller wants. 314 // This will block, then run whatever the controller wants.
313 blocker.Block(); 315 blocker.Block();
314 316
315 app_context.Shutdown(); 317 app_context.Shutdown();
316 318
317 return 0; 319 return 0;
318 } 320 }
319 321
320 } // namespace runner 322 } // namespace runner
321 } // namespace mojo 323 } // namespace mojo
OLDNEW
« no previous file with comments | « mojo/common/handle_watcher.cc ('k') | mojo/runner/in_process_native_runner.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698