You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/07/01 12:05:28 UTC
incubator-ignite git commit: # ignite-648: add jps.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-648-failover bd2c258e3 -> ad074f526
# ignite-648: add jps.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ad074f52
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ad074f52
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ad074f52
Branch: refs/heads/ignite-648-failover
Commit: ad074f526e074c5f60f7b928ad0d16bdca17fa92
Parents: bd2c258
Author: ashutak <as...@gridgain.com>
Authored: Wed Jul 1 13:06:21 2015 +0300
Committer: ashutak <as...@gridgain.com>
Committed: Wed Jul 1 13:06:21 2015 +0300
----------------------------------------------------------------------
.../testframework/junits/GridAbstractTest.java | 2 ++
.../junits/multijvm/IgniteNodeRunner.java | 38 ++++++++++++++++++++
2 files changed, 40 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ad074f52/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
index 5252c76..d9818e5 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
@@ -801,6 +801,8 @@ public abstract class GridAbstractTest extends TestCase {
}
IgniteNodeRunner.killAll();
+
+ IgniteNodeRunner.jps();
}
assert G.allGrids().isEmpty();
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ad074f52/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java
index 78a3fb0..1bbd2b2 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteNodeRunner.java
@@ -167,4 +167,42 @@ public class IgniteNodeRunner {
return Collections.emptyList();
}
}
+
+ /**
+ * Kill all Jvm runned by {#link IgniteNodeRunner}. Works based on jps command.
+ *
+ * @return List of killed process ids.
+ * @throws Exception If exception.
+ */
+ // TODO delete this method.
+ public static void jps() {
+ try {
+ // TODO delete logging.
+ X.println(">>>>> IgniteNodeRunner.jps");
+
+ MonitoredHost monitoredHost = MonitoredHost.getMonitoredHost(new HostIdentifier("localhost"));
+
+ Set<Integer> jvms = monitoredHost.activeVms();
+
+ List<Integer> res = new ArrayList<>();
+
+ for (Integer jvmId : jvms) {
+ try {
+ MonitoredVm vm = monitoredHost.getMonitoredVm(new VmIdentifier("//" + jvmId + "?mode=r"), 0);
+
+ String name = MonitoredVmUtil.mainClass(vm, false);
+
+ X.println(">>>>> " + jvmId + ' ' + name);
+ }
+ catch (Exception e) {
+ // Print stack trace just for information.
+ X.printerrln(">>>>> Could not PRINT IgniteNodeRunner java process. Jvm pid = " + jvmId, e);
+ }
+ }
+ }
+ catch (Exception e) {
+ // Print stack trace just for information.
+ X.printerrln(">>>>> Could not PRINT IgniteNodeRunner java processes.", e);
+ }
+ }
}