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 <ashu...@gridgain.com> Authored: Wed Jul 1 13:06:21 2015 +0300 Committer: ashutak <ashu...@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); + } + } }
