ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: start nodes tc: add logging + comment tests
Date Thu, 02 Apr 2015 14:24:20 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-tc-snodes [created] 69c496bf5


start nodes tc: add logging + comment tests


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/69c496bf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/69c496bf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/69c496bf

Branch: refs/heads/ignite-tc-snodes
Commit: 69c496bf573995b7ac917094a13cd4baa8e3e9ba
Parents: 9b23109
Author: Artem Shutak <ashutak@gridgain.com>
Authored: Thu Apr 2 17:24:19 2015 +0300
Committer: Artem Shutak <ashutak@gridgain.com>
Committed: Thu Apr 2 17:24:19 2015 +0300

----------------------------------------------------------------------
 .../eventstorage/GridEventStorageManager.java   |    2 +
 ...gniteProjectionStartStopRestartSelfTest.java | 1444 +++++++++---------
 2 files changed, 723 insertions(+), 723 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/69c496bf/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java
index e8c9396..dd91d52 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageManager.java
@@ -247,6 +247,8 @@ public class GridEventStorageManager extends GridManagerAdapter<EventStorageSpi>
      */
     public void record(Event evt) {
         assert evt != null;
+        
+        log.info(">>>>> Record event=" + evt);
 
         if (!enterBusy())
             return;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/69c496bf/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java b/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java
index d4c5fc5..ae9ae81 100644
--- a/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java
+++ b/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java
@@ -18,7 +18,6 @@
 package org.apache.ignite.internal;
 
 import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
 import org.apache.ignite.events.*;
 import org.apache.ignite.internal.util.lang.*;
 import org.apache.ignite.internal.util.nodestart.*;
@@ -29,7 +28,6 @@ import org.apache.ignite.testframework.junits.common.*;
 import org.jetbrains.annotations.*;
 
 import java.io.*;
-import java.nio.file.*;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.*;
@@ -113,9 +111,9 @@ public class IgniteProjectionStartStopRestartSelfTest extends GridCommonAbstract
         else
             pwd = SSH_PWD;
 
-        log.info("Username: " + SSH_UNAME);
-        log.info("Password: " + pwd);
-        log.info("Key path: " + key);
+        log.info("Username: '" + SSH_UNAME + '\'');
+        log.info("Password: '" + pwd + '\'');
+        log.info("Key path: '" + key + '\'');
 
         G.setDaemon(true);
 
@@ -202,724 +200,724 @@ public class IgniteProjectionStartStopRestartSelfTest extends GridCommonAbstract
         assert ignite.cluster().nodes().size() == 1;
     }
 
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartThreeNodes() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, DFLT_TIMEOUT, 1);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartThreeNodesAndDoEmptyCall() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, false, 0, 16);
-
-        assert res.isEmpty();
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartThreeNodesAndTryToStartOneNode() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 1, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, false, 0, 16);
-
-        assert res.isEmpty();
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartFiveNodesInTwoCalls() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(2);
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 5, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, false, 0, 16);
-
-        assert res.size() == 2;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 5;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 5;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartFiveWithTwoSpecs() throws Exception {
-        joinedLatch = new CountDownLatch(5);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                F.asList(map(HOST, SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_NO_ATTR, null),
-                    map(HOST, SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null)),
-                null, false, 0, 16);
-
-        assert res.size() == 5;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 5;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 5;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStartThreeNodesAndRestart() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 3;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(3);
-        leftLatch = new CountDownLatch(3);
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, true, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 6;
-        assert leftCnt.get() == 3;
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testCustomScript() throws Exception {
-        joinedLatch = new CountDownLatch(1);
-
-        String script = U.isWindows() ? CUSTOM_SCRIPT_WIN : CUSTOM_SCRIPT_LINUX;
-
-        script = Paths.get(U.getIgniteHome()).relativize(U.resolveIgnitePath(script).toPath()).toString();
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 1, U.getIgniteHome(), null, script),
-                null, false, 0, 16);
-
-        assert res.size() == 1;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert joinedCnt.get() == 1;
-        assert leftCnt.get() == 0;
-
-        assert ignite.cluster().nodes().size() == 1;
-
-        assert CUSTOM_CFG_ATTR_VAL.equals(F.first(ignite.cluster().nodes()).<String>attribute(CUSTOM_CFG_ATTR_KEY));
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStopNodes() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, null, 3, U.getIgniteHome(), CFG_NO_ATTR,
-                null), null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        leftLatch = new CountDownLatch(3);
-
-        ignite.cluster().stopNodes();
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().isEmpty();
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStopNodesFiltered() throws Exception {
-        joinedLatch = new CountDownLatch(2);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 2;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        joinedLatch = new CountDownLatch(1);
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, false, 0, 16);
-
-        assert res.size() == 1;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        leftLatch = new CountDownLatch(2);
-
-        Collection<UUID> ids = F.transform(ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes(),
-            new IgniteClosure<ClusterNode, UUID>() {
-            @Override public UUID apply(ClusterNode node) {
-                return node.id();
-            }
-        });
-
-        ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes();
-
-        ignite.cluster().stopNodes(ids);
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 1;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStopNodeById() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        leftLatch = new CountDownLatch(1);
-
-        ignite.cluster().stopNodes(Collections.singleton(F.first(ignite.cluster().forRemotes().nodes()).id()));
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 2;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStopNodesByIds() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        leftLatch = new CountDownLatch(2);
-
-        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
-
-        Collection<UUID> ids = new HashSet<>();
-
-        ids.add(it.next().id());
-        ids.add(it.next().id());
-
-        ignite.cluster().stopNodes(ids);
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 1;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testStopNodesByIdsC() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        leftLatch = new CountDownLatch(2);
-
-        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
-
-        ignite.cluster().stopNodes(F.asList(it.next().id(), it.next().id()));
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 1;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testRestartNodes() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(3);
-        leftLatch = new CountDownLatch(3);
-
-        ignite.cluster().restartNodes();
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testRestartNodesFiltered() throws Exception {
-        joinedLatch = new CountDownLatch(2);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 2;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        joinedLatch = new CountDownLatch(1);
-
-        res = startNodes(ignite.cluster(),
-            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-            null, false, 0, 16);
-
-        assert res.size() == 1;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(2);
-        leftLatch = new CountDownLatch(2);
-
-        X.println("Restarting nodes with " + CUSTOM_CFG_ATTR_KEY);
-
-        Collection<UUID> ids = F.transform(ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes(),
-            new IgniteClosure<ClusterNode, UUID>() {
-                @Override public UUID apply(ClusterNode node) {
-                    return node.id();
-                }
-            }
-        );
-
-        ignite.cluster().restartNodes(ids);
-
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testRestartNodeById() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(1);
-        leftLatch = new CountDownLatch(1);
-
-        ignite.cluster().restartNodes(Collections.singleton(F.first(ignite.cluster().forRemotes().nodes()).id()));
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testRestartNodesByIds() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(2);
-        leftLatch = new CountDownLatch(2);
-
-        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
-
-        ignite.cluster().restartNodes(F.asList(it.next().id(), it.next().id()));
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testRestartNodesByIdsC() throws Exception {
-        joinedLatch = new CountDownLatch(3);
-
-        Collection<GridTuple3<String, Boolean, String>> res =
-            startNodes(ignite.cluster(),
-                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
-                null, false, 0, 16);
-
-        assert res.size() == 3;
-
-        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
-            @Override public void apply(GridTuple3<String, Boolean, String> t) {
-                assert t.get1().equals(HOST);
-
-                if (!t.get2())
-                    throw new IgniteException(t.get3());
-            }
-        });
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-
-        joinedLatch = new CountDownLatch(2);
-        leftLatch = new CountDownLatch(2);
-
-        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
-
-        ignite.cluster().restartNodes(F.asList(it.next().id(), it.next().id()));
-
-        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
-
-        assert ignite.cluster().nodes().size() == 3;
-    }
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartThreeNodes() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, DFLT_TIMEOUT, 1);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartThreeNodesAndDoEmptyCall() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, false, 0, 16);
+//
+//        assert res.isEmpty();
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartThreeNodesAndTryToStartOneNode() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 1, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, false, 0, 16);
+//
+//        assert res.isEmpty();
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartFiveNodesInTwoCalls() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(2);
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 5, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, false, 0, 16);
+//
+//        assert res.size() == 2;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 5;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 5;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartFiveWithTwoSpecs() throws Exception {
+//        joinedLatch = new CountDownLatch(5);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                F.asList(map(HOST, SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                    map(HOST, SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null)),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 5;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 5;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 5;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStartThreeNodesAndRestart() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 3;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(3);
+//        leftLatch = new CountDownLatch(3);
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, true, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 6;
+//        assert leftCnt.get() == 3;
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testCustomScript() throws Exception {
+//        joinedLatch = new CountDownLatch(1);
+//
+//        String script = U.isWindows() ? CUSTOM_SCRIPT_WIN : CUSTOM_SCRIPT_LINUX;
+//
+//        script = Paths.get(U.getIgniteHome()).relativize(U.resolveIgnitePath(script).toPath()).toString();
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 1, U.getIgniteHome(), null, script),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 1;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert joinedCnt.get() == 1;
+//        assert leftCnt.get() == 0;
+//
+//        assert ignite.cluster().nodes().size() == 1;
+//
+//        assert CUSTOM_CFG_ATTR_VAL.equals(F.first(ignite.cluster().nodes()).<String>attribute(CUSTOM_CFG_ATTR_KEY));
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStopNodes() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, null, 3, U.getIgniteHome(), CFG_NO_ATTR,
+//                null), null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        leftLatch = new CountDownLatch(3);
+//
+//        ignite.cluster().stopNodes();
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().isEmpty();
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStopNodesFiltered() throws Exception {
+//        joinedLatch = new CountDownLatch(2);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 2;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        joinedLatch = new CountDownLatch(1);
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, false, 0, 16);
+//
+//        assert res.size() == 1;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        leftLatch = new CountDownLatch(2);
+//
+//        Collection<UUID> ids = F.transform(ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes(),
+//            new IgniteClosure<ClusterNode, UUID>() {
+//            @Override public UUID apply(ClusterNode node) {
+//                return node.id();
+//            }
+//        });
+//
+//        ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes();
+//
+//        ignite.cluster().stopNodes(ids);
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 1;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStopNodeById() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        leftLatch = new CountDownLatch(1);
+//
+//        ignite.cluster().stopNodes(Collections.singleton(F.first(ignite.cluster().forRemotes().nodes()).id()));
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 2;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStopNodesByIds() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        leftLatch = new CountDownLatch(2);
+//
+//        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
+//
+//        Collection<UUID> ids = new HashSet<>();
+//
+//        ids.add(it.next().id());
+//        ids.add(it.next().id());
+//
+//        ignite.cluster().stopNodes(ids);
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 1;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testStopNodesByIdsC() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        leftLatch = new CountDownLatch(2);
+//
+//        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
+//
+//        ignite.cluster().stopNodes(F.asList(it.next().id(), it.next().id()));
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 1;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testRestartNodes() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(3);
+//        leftLatch = new CountDownLatch(3);
+//
+//        ignite.cluster().restartNodes();
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testRestartNodesFiltered() throws Exception {
+//        joinedLatch = new CountDownLatch(2);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 2, U.getIgniteHome(), CFG_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 2;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        joinedLatch = new CountDownLatch(1);
+//
+//        res = startNodes(ignite.cluster(),
+//            maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//            null, false, 0, 16);
+//
+//        assert res.size() == 1;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(2);
+//        leftLatch = new CountDownLatch(2);
+//
+//        X.println("Restarting nodes with " + CUSTOM_CFG_ATTR_KEY);
+//
+//        Collection<UUID> ids = F.transform(ignite.cluster().forAttribute(CUSTOM_CFG_ATTR_KEY, CUSTOM_CFG_ATTR_VAL).nodes(),
+//            new IgniteClosure<ClusterNode, UUID>() {
+//                @Override public UUID apply(ClusterNode node) {
+//                    return node.id();
+//                }
+//            }
+//        );
+//
+//        ignite.cluster().restartNodes(ids);
+//
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testRestartNodeById() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(1);
+//        leftLatch = new CountDownLatch(1);
+//
+//        ignite.cluster().restartNodes(Collections.singleton(F.first(ignite.cluster().forRemotes().nodes()).id()));
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testRestartNodesByIds() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(2);
+//        leftLatch = new CountDownLatch(2);
+//
+//        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
+//
+//        ignite.cluster().restartNodes(F.asList(it.next().id(), it.next().id()));
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testRestartNodesByIdsC() throws Exception {
+//        joinedLatch = new CountDownLatch(3);
+//
+//        Collection<GridTuple3<String, Boolean, String>> res =
+//            startNodes(ignite.cluster(),
+//                maps(Collections.singleton(HOST), SSH_UNAME, pwd, key, 3, U.getIgniteHome(), CFG_NO_ATTR, null),
+//                null, false, 0, 16);
+//
+//        assert res.size() == 3;
+//
+//        F.forEach(res, new CI1<GridTuple3<String, Boolean, String>>() {
+//            @Override public void apply(GridTuple3<String, Boolean, String> t) {
+//                assert t.get1().equals(HOST);
+//
+//                if (!t.get2())
+//                    throw new IgniteException(t.get3());
+//            }
+//        });
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//
+//        joinedLatch = new CountDownLatch(2);
+//        leftLatch = new CountDownLatch(2);
+//
+//        Iterator<ClusterNode> it = ignite.cluster().nodes().iterator();
+//
+//        ignite.cluster().restartNodes(F.asList(it.next().id(), it.next().id()));
+//
+//        assert joinedLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//        assert leftLatch.await(WAIT_TIMEOUT, MILLISECONDS);
+//
+//        assert ignite.cluster().nodes().size() == 3;
+//    }
 
     /**
      * @param host Hostname.


Mime
View raw message