Repository: ignite Updated Branches: refs/heads/ignite-zk f03aab3b2 -> 6d4a32dde
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6d4a32dd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6d4a32dd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6d4a32dd Branch: refs/heads/ignite-zk Commit: 6d4a32ddebb0456e0e88f874e4b9d3cadff20297 Parents: f03aab3 Author: sboikov <[email protected]> Authored: Mon Dec 11 13:23:32 2017 +0300 Committer: sboikov <[email protected]> Committed: Mon Dec 11 13:23:32 2017 +0300 ---------------------------------------------------------------------- .../ZookeeperDiscoverySpiBasicTest.java | 103 +++++++++++++++++++ 1 file changed, 103 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6d4a32dd/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java index 8498c7c..af5fc8f 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java @@ -36,6 +36,7 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import org.apache.curator.test.InstanceSpec; import org.apache.curator.test.TestingCluster; +import org.apache.curator.test.TestingZooKeeperServer; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.IgniteCheckedException; @@ -565,6 +566,108 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { /** * @throws Exception If failed. */ + public void testSegmentation2() throws Exception { + sesTimeout = 2000; + + Ignite node0 = startGrid(0); + + final CountDownLatch l = new CountDownLatch(1); + + node0.events().localListen(new IgnitePredicate<Event>() { + @Override public boolean apply(Event event) { + l.countDown(); + + return false; + } + }, EventType.EVT_NODE_SEGMENTED); + + try { + zkCluster.close(); + + assertTrue(l.await(10, TimeUnit.SECONDS)); + } + finally { + zkCluster = createTestingCluster(ZK_SRVS); + + zkCluster.start(); + } + } + + /** + * @throws Exception If failed. + */ + public void testSegmentation3() throws Exception { + sesTimeout = 5000; + + Ignite node0 = startGrid(0); + + final CountDownLatch l = new CountDownLatch(1); + + node0.events().localListen(new IgnitePredicate<Event>() { + @Override public boolean apply(Event event) { + l.countDown(); + + return false; + } + }, EventType.EVT_NODE_SEGMENTED); + + List<TestingZooKeeperServer> srvs = zkCluster.getServers(); + + assertEquals(3, srvs.size()); + + try { + srvs.get(0).stop(); + srvs.get(1).stop(); + + assertTrue(l.await(20, TimeUnit.SECONDS)); + } + finally { + zkCluster.close(); + + zkCluster = createTestingCluster(ZK_SRVS); + + zkCluster.start(); + } + } + + /** + * @throws Exception If failed. + */ + public void testQuorumRestore() throws Exception { + sesTimeout = 15_000; + + startGrids(3); + + waitForTopology(3); + + List<TestingZooKeeperServer> srvs = zkCluster.getServers(); + + assertEquals(3, srvs.size()); + + try { + srvs.get(0).stop(); + srvs.get(1).stop(); + + U.sleep(2000); + + srvs.get(1).restart(); + + startGrid(4); + + waitForTopology(4); + } + finally { + zkCluster.close(); + + zkCluster = createTestingCluster(ZK_SRVS); + + zkCluster.start(); + } + } + + /** + * @throws Exception If failed. + */ public void testConnectionRestore1() throws Exception { testSockNio = true;
