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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "base/test/multiprocess_test.h"
#include <string.h>
#include <vector>
#include "base/android/binder_box.h"
#include "base/android/jni_android.h"
#include "base/android/jni_array.h"
#include "base/android/scoped_java_ref.h"
#include "base/base_switches.h"
#include "base/check.h"
#include "base/command_line.h"
// Must come after all headers that specialize FromJniType() / ToJniType().
#include "base/test/test_support_jni_headers/MainReturnCodeResult_jni.h"
#include "base/test/test_support_jni_headers/MultiprocessTestClientLauncher_jni.h"
namespace base {
// A very basic implementation for Android. On Android tests can run in an APK
// and we don't have an executable to exec*. This implementation does the bare
// minimum to execute the method specified by procname (in the child process).
// - All options except |fds_to_remap| are ignored.
//
// NOTE: This MUST NOT run on the main thread of the NativeTest application.
Process SpawnMultiProcessTestChild(const std::string& procname,
const CommandLine& base_command_line,
const LaunchOptions& options) {
JNIEnv* env = android::AttachCurrentThread();
DCHECK(env);
std::vector<int> fd_keys;
std::vector<int> fd_fds;
for (auto& iter : options.fds_to_remap) {
fd_keys.push_back(iter.second);
fd_fds.push_back(iter.first);
}
android::ScopedJavaLocalRef<jobjectArray> fds =
android::Java_MultiprocessTestClientLauncher_makeFdInfoArray(
env, android::ToJavaIntArray(env, fd_keys),
android::ToJavaIntArray(env, fd_fds));
CommandLine command_line(base_command_line);
if (!command_line.HasSwitch(switches::kTestChildProcess)) {
command_line.AppendSwitchASCII(switches::kTestChildProcess, procname);
}
android::ScopedJavaLocalRef<jobjectArray> j_argv =
android::ToJavaArrayOfStrings(env, command_line.argv());
jint pid = android::Java_MultiprocessTestClientLauncher_launchClient(
env, j_argv, fds, base::android::PackBinderBox(env, options.binders));
return Process(pid);
}
bool WaitForMultiprocessTestChildExit(const Process& process,
TimeDelta timeout,
int* exit_code) {
JNIEnv* env = android::AttachCurrentThread();
DCHECK(env);
android::ScopedJavaLocalRef<jobject> result_code =
android::Java_MultiprocessTestClientLauncher_waitForMainToReturn(
env, process.Pid(), static_cast<int32_t>(timeout.InMilliseconds()));
if (result_code.is_null() ||
android::Java_MainReturnCodeResult_hasTimedOut(env, result_code)) {
return false;
}
if (exit_code) {
*exit_code =
android::Java_MainReturnCodeResult_getReturnCode(env, result_code);
}
return true;
}
bool TerminateMultiProcessTestChild(const Process& process,
int exit_code,
bool wait) {
JNIEnv* env = android::AttachCurrentThread();
DCHECK(env);
return android::Java_MultiprocessTestClientLauncher_terminate(
env, process.Pid(), exit_code, wait);
}
bool MultiProcessTestChildHasCleanExit(const Process& process) {
JNIEnv* env = android::AttachCurrentThread();
DCHECK(env);
return android::Java_MultiprocessTestClientLauncher_hasCleanExit(
env, process.Pid());
}
} // namespace base
|
