You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/04/12 07:34:15 UTC
[44/57] [abbrv] ignite git commit: IGNITE-4534: Page eviction
rebalance test fix.
IGNITE-4534: Page eviction rebalance test fix.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2068a751
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2068a751
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2068a751
Branch: refs/heads/ignite-3477-debug
Commit: 2068a7510b09e193a33ae074b5161f1166399b7e
Parents: 7eb1234
Author: Ivan Rakov <iv...@gmail.com>
Authored: Tue Apr 11 15:24:02 2017 +0300
Committer: Ivan Rakov <iv...@gmail.com>
Committed: Tue Apr 11 15:24:02 2017 +0300
----------------------------------------------------------------------
.../cache/eviction/paged/PageEvictionWithRebalanceTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2068a751/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java
index fd80201..f174908 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java
@@ -51,11 +51,11 @@ public abstract class PageEvictionWithRebalanceTest extends PageEvictionAbstract
System.out.println(">>> Entries put: " + i);
}
- int size = cache.size(CachePeekMode.PRIMARY);
+ int size = cache.size(CachePeekMode.ALL);
System.out.println(">>> Resulting size: " + size);
- assertTrue(size < ENTRIES);
+ assertTrue(size < ENTRIES * 2); // Primary entries and backups.
for (int i = 3; i >= 1; i--) {
stopGrid(i);
@@ -64,7 +64,7 @@ public abstract class PageEvictionWithRebalanceTest extends PageEvictionAbstract
awaitPartitionMapExchange();
- int rebalanceSize = cache.size(CachePeekMode.PRIMARY);
+ int rebalanceSize = cache.size(CachePeekMode.ALL);
System.out.println(">>> Size after rebalance: " + rebalanceSize);