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

Side by Side Diff: shell/in_process_dynamic_service_runner.cc

Issue 775343004: Move //mojo/shell to //shell (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 6 years 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 "mojo/shell/in_process_dynamic_service_runner.h" 5 #include "shell/in_process_dynamic_service_runner.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/callback_helpers.h" 8 #include "base/callback_helpers.h"
9 #include "base/location.h" 9 #include "base/location.h"
10 #include "base/message_loop/message_loop_proxy.h" 10 #include "base/message_loop/message_loop_proxy.h"
11 #include "base/threading/platform_thread.h" 11 #include "base/threading/platform_thread.h"
12 12
13 namespace mojo { 13 namespace mojo {
14 namespace shell { 14 namespace shell {
15 15
16 InProcessDynamicServiceRunner::InProcessDynamicServiceRunner( 16 InProcessDynamicServiceRunner::InProcessDynamicServiceRunner(Context* context)
17 Context* context) : app_library_(nullptr) { 17 : app_library_(nullptr) {
18 } 18 }
19 19
20 InProcessDynamicServiceRunner::~InProcessDynamicServiceRunner() { 20 InProcessDynamicServiceRunner::~InProcessDynamicServiceRunner() {
21 if (thread_) { 21 if (thread_) {
22 DCHECK(thread_->HasBeenStarted()); 22 DCHECK(thread_->HasBeenStarted());
23 DCHECK(!thread_->HasBeenJoined()); 23 DCHECK(!thread_->HasBeenJoined());
24 thread_->Join(); 24 thread_->Join();
25 } 25 }
26 26
27 // It is important to let the thread exit before unloading the DSO because 27 // It is important to let the thread exit before unloading the DSO because
28 // the library may have registered thread-local data and destructors to run 28 // the library may have registered thread-local data and destructors to run
29 // on thread termination. 29 // on thread termination.
30 if (app_library_) 30 if (app_library_)
31 base::UnloadNativeLibrary(app_library_); 31 base::UnloadNativeLibrary(app_library_);
32 } 32 }
33 33
34 void InProcessDynamicServiceRunner::Start( 34 void InProcessDynamicServiceRunner::Start(
35 const base::FilePath& app_path, 35 const base::FilePath& app_path,
36 ScopedMessagePipeHandle service_handle, 36 ScopedMessagePipeHandle service_handle,
37 const base::Closure& app_completed_callback) { 37 const base::Closure& app_completed_callback) {
38 app_path_ = app_path; 38 app_path_ = app_path;
39 39
40 DCHECK(!service_handle_.is_valid()); 40 DCHECK(!service_handle_.is_valid());
41 service_handle_ = service_handle.Pass(); 41 service_handle_ = service_handle.Pass();
42 42
43 DCHECK(app_completed_callback_runner_.is_null()); 43 DCHECK(app_completed_callback_runner_.is_null());
44 app_completed_callback_runner_ = base::Bind(&base::TaskRunner::PostTask, 44 app_completed_callback_runner_ =
45 base::MessageLoopProxy::current(), 45 base::Bind(&base::TaskRunner::PostTask, base::MessageLoopProxy::current(),
46 FROM_HERE, 46 FROM_HERE, app_completed_callback);
47 app_completed_callback);
48 47
49 DCHECK(!thread_); 48 DCHECK(!thread_);
50 thread_.reset(new base::DelegateSimpleThread(this, "app_thread")); 49 thread_.reset(new base::DelegateSimpleThread(this, "app_thread"));
51 thread_->Start(); 50 thread_->Start();
52 } 51 }
53 52
54 void InProcessDynamicServiceRunner::Run() { 53 void InProcessDynamicServiceRunner::Run() {
55 DVLOG(2) << "Loading/running Mojo app in process from library: " 54 DVLOG(2) << "Loading/running Mojo app in process from library: "
56 << app_path_.value() 55 << app_path_.value()
57 << " thread id=" << base::PlatformThread::CurrentId(); 56 << " thread id=" << base::PlatformThread::CurrentId();
58 57
59 app_library_ = LoadAndRunService(app_path_, service_handle_.Pass()); 58 app_library_ = LoadAndRunService(app_path_, service_handle_.Pass());
60 app_completed_callback_runner_.Run(); 59 app_completed_callback_runner_.Run();
61 app_completed_callback_runner_.Reset(); 60 app_completed_callback_runner_.Reset();
62 } 61 }
63 62
64 } // namespace shell 63 } // namespace shell
65 } // namespace mojo 64 } // namespace mojo
OLDNEW
« no previous file with comments | « shell/in_process_dynamic_service_runner.h ('k') | shell/in_process_dynamic_service_runner_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698