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
3 // found in the LICENSE file.
4
5 #include "mojo/shell/in_process_dynamic_service_runner.h"
6
7 #include "base/bind.h"
8 #include "base/callback_helpers.h"
9 #include "base/location.h"
10 #include "base/logging.h"
11 #include "base/message_loop/message_loop_proxy.h"
12 #include "base/scoped_native_library.h"
13 #include "mojo/public/platform/native/system_thunks.h"
14
15 namespace mojo {
16 namespace shell {
17
InProcessDynamicServiceRunner(Context * context)18 InProcessDynamicServiceRunner::InProcessDynamicServiceRunner(
19 Context* context)
20 : keep_alive_(context),
21 thread_(this, "app_thread") {
22 }
23
~InProcessDynamicServiceRunner()24 InProcessDynamicServiceRunner::~InProcessDynamicServiceRunner() {
25 if (thread_.HasBeenStarted()) {
26 DCHECK(!thread_.HasBeenJoined());
27 thread_.Join();
28 }
29 }
30
Start(const base::FilePath & app_path,ScopedMessagePipeHandle service_handle,const base::Closure & app_completed_callback)31 void InProcessDynamicServiceRunner::Start(
32 const base::FilePath& app_path,
33 ScopedMessagePipeHandle service_handle,
34 const base::Closure& app_completed_callback) {
35 app_path_ = app_path;
36
37 DCHECK(!service_handle_.is_valid());
38 service_handle_ = service_handle.Pass();
39
40 DCHECK(app_completed_callback_runner_.is_null());
41 app_completed_callback_runner_ = base::Bind(&base::TaskRunner::PostTask,
42 base::MessageLoopProxy::current(),
43 FROM_HERE,
44 app_completed_callback);
45
46 DCHECK(!thread_.HasBeenStarted());
47 thread_.Start();
48 }
49
Run()50 void InProcessDynamicServiceRunner::Run() {
51 DVLOG(2) << "Loading/running Mojo app in process from library: "
52 << app_path_.value();
53
54 do {
55 base::NativeLibraryLoadError error;
56 base::ScopedNativeLibrary app_library(
57 base::LoadNativeLibrary(app_path_, &error));
58 if (!app_library.is_valid()) {
59 LOG(ERROR) << "Failed to load app library (error: " << error.ToString()
60 << ")";
61 break;
62 }
63
64 MojoSetSystemThunksFn mojo_set_system_thunks_fn =
65 reinterpret_cast<MojoSetSystemThunksFn>(app_library.GetFunctionPointer(
66 "MojoSetSystemThunks"));
67 if (mojo_set_system_thunks_fn) {
68 MojoSystemThunks system_thunks = MojoMakeSystemThunks();
69 size_t expected_size = mojo_set_system_thunks_fn(&system_thunks);
70 if (expected_size > sizeof(MojoSystemThunks)) {
71 LOG(ERROR)
72 << "Invalid app library: expected MojoSystemThunks size: "
73 << expected_size;
74 break;
75 }
76 } else {
77 // Strictly speaking this is not required, but it's very unusual to have
78 // an app that doesn't require the basic system library.
79 LOG(WARNING) << "MojoSetSystemThunks not found in app library";
80 }
81
82 typedef MojoResult (*MojoMainFunction)(MojoHandle);
83 MojoMainFunction main_function = reinterpret_cast<MojoMainFunction>(
84 app_library.GetFunctionPointer("MojoMain"));
85 if (!main_function) {
86 LOG(ERROR) << "Entrypoint MojoMain not found";
87 break;
88 }
89
90 // |MojoMain()| takes ownership of the service handle.
91 MojoResult result = main_function(service_handle_.release().value());
92 if (result < MOJO_RESULT_OK)
93 LOG(ERROR) << "MojoMain returned an error: " << result;
94 } while (false);
95
96 bool success = app_completed_callback_runner_.Run();
97 app_completed_callback_runner_.Reset();
98 LOG_IF(ERROR, !success) << "Failed post run app_completed_callback";
99 }
100
101 } // namespace shell
102 } // namespace mojo
103