Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TCFTestSuite.java8
-rw-r--r--plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TestSysMonitor.java96
2 files changed, 104 insertions, 0 deletions
diff --git a/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TCFTestSuite.java b/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TCFTestSuite.java
index e4bfc4929..b01b50126 100644
--- a/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TCFTestSuite.java
+++ b/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TCFTestSuite.java
@@ -93,6 +93,14 @@ public class TCFTestSuite {
});
pending_tests.add(new Runnable() {
public void run() {
+ listener.progress("Running Sys monitor Test...", ++count_done, count_total);
+ for (IChannel channel : channels) {
+ active_tests.put(new TestSysMonitor(TCFTestSuite.this, channel), channel);
+ }
+ }
+ });
+ pending_tests.add(new Runnable() {
+ public void run() {
int i = 0;
listener.progress("Running Run Control Test...", ++count_done, count_total);
for (IChannel channel : channels) {
diff --git a/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TestSysMonitor.java b/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TestSysMonitor.java
new file mode 100644
index 000000000..8d100adc0
--- /dev/null
+++ b/plugins/org.eclipse.tm.tcf.debug/src/org/eclipse/tm/internal/tcf/debug/tests/TestSysMonitor.java
@@ -0,0 +1,96 @@
+package org.eclipse.tm.internal.tcf.debug.tests;
+
+import java.util.HashMap;
+import java.util.HashSet;
+
+import org.eclipse.tm.tcf.protocol.IChannel;
+import org.eclipse.tm.tcf.protocol.IToken;
+import org.eclipse.tm.tcf.services.ISysMonitor;
+import org.eclipse.tm.tcf.services.ISysMonitor.SysMonitorContext;
+
+class TestSysMonitor implements ITCFTest {
+
+ private final TCFTestSuite test_suite;
+ private final ISysMonitor sys_mon;
+ private final HashMap<String,ISysMonitor.SysMonitorContext> procs =
+ new HashMap<String,ISysMonitor.SysMonitorContext>();
+
+ TestSysMonitor(TCFTestSuite test_suite, IChannel channel) {
+ this.test_suite = test_suite;
+ sys_mon = channel.getRemoteService(ISysMonitor.class);
+ }
+
+ public void start() {
+ if (sys_mon == null) {
+ test_suite.done(this, null);
+ }
+ else {
+ sys_mon.getChildren(null, new ISysMonitor.DoneGetChildren() {
+ public void doneGetChildren(IToken token, Exception error, String[] context_ids) {
+ if (error != null) {
+ exit(error);
+ }
+ else if (context_ids == null || context_ids.length == 0) {
+ exit(new Exception("ISysMonitor.getChildren(null) returned empty list"));
+ }
+ else {
+ final HashSet<IToken> cmds = new HashSet<IToken>();
+ for (final String id : context_ids) {
+ cmds.add(sys_mon.getContext(id, new ISysMonitor.DoneGetContext() {
+ public void doneGetContext(IToken token, Exception error, SysMonitorContext context) {
+ cmds.remove(token);
+ if (error != null) {
+ // Some errors are expected, like "Access Denied"
+ }
+ else {
+ procs.put(id, context);
+ }
+ if (cmds.isEmpty()) getEnvironment();
+ }
+ }));
+ }
+ }
+ }
+ });
+ }
+ }
+
+ private void getEnvironment() {
+ final HashSet<IToken> cmds = new HashSet<IToken>();
+ for (final String id : procs.keySet()) {
+ cmds.add(sys_mon.getEnvironment(id, new ISysMonitor.DoneGetEnvironment() {
+ public void doneGetEnvironment(IToken token, Exception error, String[] environment) {
+ cmds.remove(token);
+ if (error != null) {
+ exit(error);
+ }
+ else {
+ if (cmds.isEmpty()) getCommandLine();
+ }
+ }
+ }));
+ }
+ }
+
+ private void getCommandLine() {
+ final HashSet<IToken> cmds = new HashSet<IToken>();
+ for (final String id : procs.keySet()) {
+ cmds.add(sys_mon.getCommandLine(id, new ISysMonitor.DoneGetCommandLine() {
+ public void doneGetCommandLine(IToken token, Exception error, String[] cmd_line) {
+ cmds.remove(token);
+ if (error != null) {
+ exit(error);
+ }
+ else {
+ if (cmds.isEmpty()) exit(null);
+ }
+ }
+ }));
+ }
+ }
+
+ private void exit(Throwable x) {
+ if (!test_suite.isActive(this)) return;
+ test_suite.done(this, x);
+ }
+}

Back to the top