Repository: ignite Updated Branches: refs/heads/ignite-1093-2 f34d950db -> bf109db73
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/bf109db7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/bf109db7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/bf109db7 Branch: refs/heads/ignite-1093-2 Commit: bf109db73e219aaa4bde308e925726581e4b482b Parents: f34d950 Author: Anton Vinogradov <[email protected]> Authored: Sat Oct 17 13:14:02 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Sat Oct 17 13:14:02 2015 +0300 ---------------------------------------------------------------------- .../rebalancing/GridCacheRebalancingSyncSelfTest.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/bf109db7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java index 7c4a56e..7af1d4f 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java @@ -32,6 +32,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheAdapter; import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander; import org.apache.ignite.internal.util.typedef.G; import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi; import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode; import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; @@ -106,6 +107,9 @@ public class GridCacheRebalancingSyncSelfTest extends GridCommonAbstractTest { cacheRCfg.setRebalanceMode(CacheRebalanceMode.SYNC); cacheRCfg.setRebalanceBatchSize(1); cacheRCfg.setRebalanceBatchesCount(Integer.MAX_VALUE); + ((TcpCommunicationSpi)iCfg.getCommunicationSpi()).setSharedMemoryPort(-1);//Shmem fix for Integer.MAX_VALUE. + //hang on o.a.i.i.util.nio.GridShmemCommunicationClient.sendMessage(GridShmemCommunicationClient.java:126) + //Todo: fix or create issue CacheConfiguration<Integer, Integer> cacheRCfg2 = new CacheConfiguration<>();
