conn
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/831aa16d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/831aa16d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/831aa16d Branch: refs/heads/ignite-comm-balance Commit: 831aa16dcdad7501ef9c58f2b3e7a4e191e5452b Parents: 79ca4aab Author: sboikov <sboi...@gridgain.com> Authored: Thu Sep 22 14:35:53 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Sep 22 14:35:53 2016 +0300 ---------------------------------------------------------------------- .../ignite/spi/GridTcpSpiForwardingSelfTest.java | 13 +++++++------ ...mmunicationSpiRecoveryFailureDetectionSelfTest.java | 1 + 2 files changed, 8 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/831aa16d/modules/core/src/test/java/org/apache/ignite/spi/GridTcpSpiForwardingSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/GridTcpSpiForwardingSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/GridTcpSpiForwardingSelfTest.java index deda313..5ca8f26 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/GridTcpSpiForwardingSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/GridTcpSpiForwardingSelfTest.java @@ -69,7 +69,7 @@ public class GridTcpSpiForwardingSelfTest extends GridCommonAbstractTest { private static final int commExtPort2 = 20100; /** */ - private AddressResolver resolver; + private AddressResolver rslvr; /** */ private boolean ipFinderUseLocPorts; @@ -127,12 +127,13 @@ public class GridTcpSpiForwardingSelfTest extends GridCommonAbstractTest { commSpi.setLocalPort(commLocPort); commSpi.setLocalPortRange(1); commSpi.setSharedMemoryPort(-1); + commSpi.setConnectionsPerNode(1); cfg.setCommunicationSpi(commSpi); - assert resolver != null; + assert rslvr != null; - cfg.setAddressResolver(resolver); + cfg.setAddressResolver(rslvr); return cfg; } @@ -148,7 +149,7 @@ public class GridTcpSpiForwardingSelfTest extends GridCommonAbstractTest { map.put(new InetSocketAddress("127.0.0.1", locPort2), F.asList(new InetSocketAddress("127.0.0.1", extPort2))); map.put(new InetSocketAddress("127.0.0.1", commLocPort2), F.asList(new InetSocketAddress("127.0.0.1", commExtPort2))); - resolver = new AddressResolver() { + rslvr = new AddressResolver() { @Override public Collection<InetSocketAddress> getExternalAddresses(InetSocketAddress addr) { return map.get(addr); } @@ -168,7 +169,7 @@ public class GridTcpSpiForwardingSelfTest extends GridCommonAbstractTest { map.put("127.0.0.1:" + locPort2, "127.0.0.1:" + extPort2); map.put("127.0.0.1:" + commLocPort2, "127.0.0.1:" + commExtPort2); - resolver = new BasicAddressResolver(map); + rslvr = new BasicAddressResolver(map); doTestForward(); } @@ -181,7 +182,7 @@ public class GridTcpSpiForwardingSelfTest extends GridCommonAbstractTest { map.put("127.0.0.1", "127.0.0.1"); - resolver = new BasicAddressResolver(map); + rslvr = new BasicAddressResolver(map); ipFinderUseLocPorts = true; http://git-wip-us.apache.org/repos/asf/ignite/blob/831aa16d/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest.java index 95c9e40..b1aa119 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest.java @@ -33,6 +33,7 @@ public class GridTcpCommunicationSpiRecoveryFailureDetectionSelfTest extends Gri spi.setAckSendThreshold(5); spi.setSocketSendBuffer(512); spi.setSocketReceiveBuffer(512); + spi.setConnectionsPerNode(1); return spi; }
