-
Notifications
You must be signed in to change notification settings - Fork 5.2k
/
TestProcessLauncher.java
92 lines (72 loc) · 2.94 KB
/
TestProcessLauncher.java
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
/*
* Copyright (c) 2019, 2021, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
import nsk.share.*;
import nsk.share.jpda.*;
import nsk.share.jdi.*;
import java.nio.file.FileSystems;
import java.nio.file.Path;
/**
* Launches a new Java process that uses a communication pipe to interact
* with the test.
*/
public class TestProcessLauncher {
protected static final Path USER_DIR = FileSystems.getDefault().getPath(System.getProperty("user.dir", "."));
protected static final Path TEST_CLASSES_DIR = FileSystems.getDefault().getPath(System.getProperty("test.classes"));
protected final String className;
private final ArgumentHandler argHandler;
private IOPipe pipe;
public TestProcessLauncher(String className, ArgumentHandler argHandler) {
this.className = className;
this.argHandler = argHandler;
}
public TestProcessLauncher(String className) {
this(className, new ArgumentHandler(new String[0]));
}
public Process launch() {
String java = argHandler.getLaunchExecPath();
Log log = new Log(System.out, argHandler);
Binder binder = new Binder(argHandler, log);
binder.prepareForPipeConnection(argHandler);
pipe = IOPipe.startDebuggerPipe(binder);
String cmd = prepareLaunch(java, argHandler.getPipePort());
Debugee debuggee = binder.startLocalDebugee(cmd);
debuggee.redirectOutput(log);
String line = pipe.readln();
if (!"ready".equals(line)) {
System.out.println("Wrong reply received:" + line);
}
return debuggee.getProcess();
}
public void quit() {
if (pipe != null) {
if (pipe.isConnected()) {
pipe.println("quit");
} else {
System.out.println("WARNING: IOPipe is not connected");
}
}
}
protected String prepareLaunch(String javaExec, String pipePort) {
return javaExec + " " + className + " -pipe.port=" + pipePort;
}
}