Repository: incubator-ignite Updated Branches: refs/heads/ignite-1003 582e2b76a -> dbaecd104
ignite-1003: added 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/dbaecd10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dbaecd10 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dbaecd10 Branch: refs/heads/ignite-1003 Commit: dbaecd10430c2562bdcb52f29d55cf913b05093d Parents: 582e2b7 Author: Denis Magda <dma...@gridgain.com> Authored: Mon Jul 20 16:35:48 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Mon Jul 20 16:35:48 2015 +0300 ---------------------------------------------------------------------- .../tcp/TcpDiscoveryMultiThreadedTest.java | 31 +++++++++++++++++--- 1 file changed, 27 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dbaecd10/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java index 5fa98d5..b0784ef 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java @@ -24,10 +24,13 @@ import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.spi.communication.tcp.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.*; +import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; import org.apache.ignite.testframework.*; import org.apache.ignite.testframework.junits.common.*; +import java.net.*; +import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; @@ -59,7 +62,7 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { } /** */ - private TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true); + private TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true); /** * @throws Exception If fails. @@ -73,11 +76,26 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(gridName); - if (client()) + if (client()) { cfg.setClientMode(true); - cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder).setNetworkTimeout(10_000). - setSocketTimeout(10_000).setHeartbeatFrequency(10_000)); + ArrayList<String> srvAddresses = new ArrayList<>(); + srvAddresses.add("192.168.56.1:47500"); + srvAddresses.add("192.168.56.1:47501"); + srvAddresses.add("192.168.56.1:47502"); + srvAddresses.add("192.168.56.1:47503"); + srvAddresses.add("192.168.56.1:47504"); + srvAddresses.add("192.168.56.1:47505"); + srvAddresses.add("192.168.56.1:47506"); + + ipFinder.setAddresses(srvAddresses); + + cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder).setNetworkTimeout(10_000). + setSocketTimeout(10_000).setHeartbeatFrequency(10_000)); + } + else + cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder).setNetworkTimeout(10_000). + setSocketTimeout(10_000).setHeartbeatFrequency(10_000).setLocalAddress("192.168.56.1")); TcpCommunicationSpi commSpi = new TcpCommunicationSpi(); commSpi.setConnectTimeout(10_000); @@ -111,6 +129,11 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { startGridsMultiThreaded(8); + Collection<InetSocketAddress> addresses = ipFinder.getRegisteredAddresses(); + + for (InetSocketAddress addr : addresses) + System.out.println(addr); + Thread.sleep(getTestTimeout()); }
