1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "mojo/shell/runner/host/out_of_process_native_runner.h"
#include <stdint.h>
#include <utility>
#include "base/bind.h"
#include "base/callback_helpers.h"
#include "base/files/file_util.h"
#include "base/logging.h"
#include "base/task_runner.h"
#include "mojo/shell/runner/host/child_process_host.h"
#include "mojo/shell/runner/host/in_process_native_runner.h"
namespace mojo {
namespace shell {
OutOfProcessNativeRunner::OutOfProcessNativeRunner(
base::TaskRunner* launch_process_runner,
NativeRunnerDelegate* delegate)
: launch_process_runner_(launch_process_runner), delegate_(delegate) {}
OutOfProcessNativeRunner::~OutOfProcessNativeRunner() {
if (child_process_host_ && !app_path_.empty())
child_process_host_->Join();
}
void OutOfProcessNativeRunner::Start(
const base::FilePath& app_path,
const Identity& target,
bool start_sandboxed,
mojom::ShellClientRequest request,
const base::Callback<void(base::ProcessId)>& pid_available_callback,
const base::Closure& app_completed_callback) {
app_path_ = app_path;
DCHECK(app_completed_callback_.is_null());
app_completed_callback_ = app_completed_callback;
child_process_host_.reset(new ChildProcessHost(
launch_process_runner_, delegate_, start_sandboxed, target, app_path));
child_process_host_->Start(std::move(request), target.name(),
pid_available_callback,
base::Bind(&OutOfProcessNativeRunner::AppCompleted,
base::Unretained(this)));
}
void OutOfProcessNativeRunner::AppCompleted() {
if (child_process_host_)
child_process_host_->Join();
child_process_host_.reset();
// This object may be deleted by this callback.
base::Closure app_completed_callback = app_completed_callback_;
app_completed_callback_.Reset();
if (!app_completed_callback.is_null())
app_completed_callback.Run();
}
OutOfProcessNativeRunnerFactory::OutOfProcessNativeRunnerFactory(
base::TaskRunner* launch_process_runner,
NativeRunnerDelegate* delegate)
: launch_process_runner_(launch_process_runner), delegate_(delegate) {}
OutOfProcessNativeRunnerFactory::~OutOfProcessNativeRunnerFactory() {}
scoped_ptr<shell::NativeRunner> OutOfProcessNativeRunnerFactory::Create(
const base::FilePath& app_path) {
return make_scoped_ptr(
new OutOfProcessNativeRunner(launch_process_runner_, delegate_));
}
} // namespace shell
} // namespace mojo
|
