Repository: ignite Updated Branches: refs/heads/ignite-1093-3 b46015cbf -> 9dfdb6999
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9dfdb699 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9dfdb699 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9dfdb699 Branch: refs/heads/ignite-1093-3 Commit: 9dfdb6999fe0576d180ce2efe5e718b6979bac41 Parents: b46015c Author: Anton Vinogradov <[email protected]> Authored: Wed Oct 28 14:02:01 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Wed Oct 28 14:02:01 2015 +0300 ---------------------------------------------------------------------- .../rebalancing/GridCacheRebalancingAsyncSelfTest.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9dfdb699/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingAsyncSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingAsyncSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingAsyncSelfTest.java index c65a0ed..7759c70 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingAsyncSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingAsyncSelfTest.java @@ -22,6 +22,7 @@ import org.apache.ignite.cache.CacheRebalanceMode; import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander; +import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.spi.discovery.tcp.TestTcpDiscoverySpi; /** @@ -56,8 +57,12 @@ public class GridCacheRebalancingAsyncSelfTest extends GridCacheRebalancingSyncS fut.get(); + U.sleep(10); + ((TestTcpDiscoverySpi)grid(1).configuration().getDiscoverySpi()).simulateNodeFailure(); + waitForRebalancing(0, 3); + checkSupplyContextMapIsEmpty(); } } \ No newline at end of file
