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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
import com.sun.jdi.*;
import com.sun.jdi.connect.*;
import com.sun.jdi.request.ClassPrepareRequest;
import com.sun.jdi.request.EventRequestManager;
import java.util.*;
import java.io.*;
/**
* @version 1.0
* @author
*/
public class JdiTest {
static Thread errThread, outThread;
public static void main(String[] xxx) throws Exception {
LaunchingConnector lc = findLaunchingConnector();
String mainArgs = "Hello";
Map args = connectorArguments(lc, mainArgs);
System.out.println(args);
VirtualMachine vm = lc.launch(args);
System.out.println(vm);
redirectOutput(vm);
vm.resume();
while (vm.classesByName("Hello").size() == 0) {}
ReferenceType rt = (ReferenceType)vm.classesByName("Hello").get(0);
System.out.println(rt);
System.out.println(rt.availableStrata());
try {
System.out.println(rt.sourceDebugExtension());
System.out.println("Names: " + rt.sourceNames("AspectJ"));
} catch (AbsentInformationException aie) {
System.out.println("NO source debug extension");
}
System.out.println("Name: " + rt.sourceName());
for (Iterator i = rt.allLineLocations().iterator(); i.hasNext(); ) {
Location loc = (Location)i.next();
System.out.println(" " + loc.sourceName() + ":" + loc.lineNumber());
}
try {
//eventThread.join();
errThread.join(); // Make sure output is forwarded
outThread.join(); // before we exit
} catch (InterruptedException exc) {
// we don't interrupt
}
}
/**
* Find a com.sun.jdi.CommandLineLaunch connector
*/
static LaunchingConnector findLaunchingConnector() {
List connectors = Bootstrap.virtualMachineManager().allConnectors();
Iterator iter = connectors.iterator();
while (iter.hasNext()) {
Connector connector = (Connector) iter.next();
if (connector.name().equals("com.sun.jdi.CommandLineLaunch")) {
return (LaunchingConnector) connector;
}
}
throw new Error("No launching connector");
}
/**
* Return the launching connector's arguments.
*/
static Map connectorArguments(LaunchingConnector connector, String mainArgs) {
Map arguments = connector.defaultArguments();
Connector.Argument mainArg = (Connector.Argument) arguments.get("main");
if (mainArg == null) {
throw new Error("Bad launching connector");
}
mainArg.setValue(mainArgs);
// if (watchFields) {
// // We need a VM that supports watchpoints
// Connector.Argument optionArg = (Connector.Argument) arguments.get("options");
// if (optionArg == null) {
// throw new Error("Bad launching connector");
// }
// optionArg.setValue("-classic");
// }
return arguments;
}
static void redirectOutput(VirtualMachine vm) {
Process process = vm.process();
// Copy target's output and error to our output and error.
errThread = new StreamRedirectThread("error reader",
process.getErrorStream(),
System.err);
outThread = new StreamRedirectThread("output reader",
process.getInputStream(),
System.out);
errThread.start();
outThread.start();
}
}
class StreamRedirectThread extends Thread {
private final Reader in;
private final Writer out;
private static final int BUFFER_SIZE = 2048;
/**
* Set up for copy.
* @param name Name of the thread
* @param in Stream to copy from
* @param out Stream to copy to
*/
StreamRedirectThread(String name, InputStream in, OutputStream out) {
super(name);
this.in = new InputStreamReader(in);
this.out = new OutputStreamWriter(out);
setPriority(Thread.MAX_PRIORITY-1);
}
/**
* Copy.
*/
public void run() {
try {
char[] cbuf = new char[BUFFER_SIZE];
int count;
while ((count = in.read(cbuf, 0, BUFFER_SIZE)) >= 0) {
out.write(cbuf, 0, count);
}
out.flush();
} catch(IOException exc) {
System.err.println("Child I/O Transfer - " + exc);
}
}
}
|
