Repository: ignite Updated Branches: refs/heads/ignite-8446 96f30a5e4 -> f7a03679e
IGNITE-9051 Unnecessary ssh tests were removed. - Fixes #4404. Signed-off-by: Dmitriy Pavlov <dpav...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1cd58450 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1cd58450 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1cd58450 Branch: refs/heads/ignite-8446 Commit: 1cd58450e5ab3b1b7a845f198a17aa3abf888461 Parents: d7ba537 Author: Fedotov <vane...@gmail.com> Authored: Mon Jul 23 17:22:08 2018 +0300 Committer: Dmitriy Pavlov <dpav...@apache.org> Committed: Mon Jul 23 17:22:08 2018 +0300 ---------------------------------------------------------------------- ...gniteProjectionStartStopRestartSelfTest.java | 76 -------------------- 1 file changed, 76 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1cd58450/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 5de7363..4314a98 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 @@ -698,43 +698,6 @@ public class IgniteProjectionStartStopRestartSelfTest extends GridCommonAbstract /** * @throws Exception If failed. */ - public void testStopNodesByIdsC() throws Exception { - joinedLatch = new CountDownLatch(3); - - Collection<ClusterStartNodeResult> 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<ClusterStartNodeResult>() { - @Override public void apply(ClusterStartNodeResult t) { - assert t.getHostName().equals(HOST); - - if (!t.isSuccess()) - throw new IgniteException(t.getError()); - } - }); - - 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); @@ -912,45 +875,6 @@ public class IgniteProjectionStartStopRestartSelfTest extends GridCommonAbstract } /** - * @throws Exception If failed. - */ - public void testRestartNodesByIdsC() throws Exception { - joinedLatch = new CountDownLatch(3); - - Collection<ClusterStartNodeResult> 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<ClusterStartNodeResult>() { - @Override public void apply(ClusterStartNodeResult t) { - assert t.getHostName().equals(HOST); - - if (!t.isSuccess()) - throw new IgniteException(t.getError()); - } - }); - - 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. * @param uname Username. * @param passwd Password.
