Repository: ignite Updated Branches: refs/heads/ignite-1093-2 be4addef0 -> a34b20b6a
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a34b20b6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a34b20b6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a34b20b6 Branch: refs/heads/ignite-1093-2 Commit: a34b20b6aab4414372beabcfed2c9e6296b7419a Parents: be4adde Author: Anton Vinogradov <[email protected]> Authored: Tue Oct 20 14:36:29 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Tue Oct 20 14:36:29 2015 +0300 ---------------------------------------------------------------------- .../GridCacheRebalancingSyncSelfTest.java | 31 ++++++++++++++++++++ 1 file changed, 31 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a34b20b6/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 7af1d4f..b9bc96b 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 @@ -502,10 +502,41 @@ public class GridCacheRebalancingSyncSelfTest extends GridCommonAbstractTest { startGrid(1); + waitForRebalancing(0, 2); waitForRebalancing(1, 2); + checkData(grid(1), 0, 0); + + startGrid(2); + + waitForRebalancing(0, 3); + waitForRebalancing(1, 3); + waitForRebalancing(2, 3); + + checkData(grid(1), 0, 0); + + startGrid(3); + + waitForRebalancing(0, 4); + waitForRebalancing(1, 4); + waitForRebalancing(2, 4); + waitForRebalancing(3, 4); + + checkData(grid(1), 0, 0); + + stopGrid(2); + + waitForRebalancing(0, 5); + waitForRebalancing(1, 5); + waitForRebalancing(3, 5); + + checkData(grid(1), 0, 0); + stopGrid(0); + waitForRebalancing(1, 6); + waitForRebalancing(3, 6); + checkData(grid(1), 0, 0); }
