ignite-998
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/46e6c48e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/46e6c48e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/46e6c48e Branch: refs/heads/ignite-883-1 Commit: 46e6c48ee59a3837c06564d2431caabc55cf9a63 Parents: c47438e Author: sboikov <sboi...@gridgain.com> Authored: Wed Jun 10 15:33:01 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Wed Jun 10 15:33:01 2015 +0300 ---------------------------------------------------------------------- .../discovery/tcp/TcpClientDiscoverySpiSelfTest.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/46e6c48e/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java index ece898d..55a14e4 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java @@ -1136,6 +1136,8 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest { * @param clientCnt Number of client nodes. */ private void checkNodes(int srvCnt, int clientCnt) { + long topVer = -1; + for (int i = 0; i < srvCnt; i++) { Ignite g = G.ignite("server-" + i); @@ -1144,6 +1146,11 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest { assertFalse(g.cluster().localNode().isClient()); checkRemoteNodes(g, srvCnt + clientCnt - 1); + + if (topVer < 0) + topVer = g.cluster().topologyVersion(); + else + assertEquals(topVer, g.cluster().topologyVersion()); } for (int i = 0; i < clientCnt; i++) { @@ -1156,6 +1163,11 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest { assertTrue(g.cluster().localNode().isClient()); checkRemoteNodes(g, srvCnt + clientCnt - 1); + + if (topVer < 0) + topVer = g.cluster().topologyVersion(); + else + assertEquals(topVer, g.cluster().topologyVersion()); } }
