ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [17/20] ignite git commit: ignite-3621 Fixed 'testEvictExpired'.
Date Thu, 29 Sep 2016 12:41:45 GMT
ignite-3621 Fixed 'testEvictExpired'.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4ff19c20
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4ff19c20
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4ff19c20

Branch: refs/heads/ignite-comm-opts2
Commit: 4ff19c20b169e0373eafc8025a838db8bfc61f27
Parents: 53fbad7
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Sep 28 13:47:51 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Sep 28 13:47:51 2016 +0300

----------------------------------------------------------------------
 .../cache/GridCacheAbstractFullApiSelfTest.java          | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/4ff19c20/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
index f2cf414..b328960 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -3477,9 +3477,16 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
 
         grid(0).cache(null).withExpiryPolicy(expiry).put(key, 1);
 
+        final Affinity<String> aff = ignite(0).affinity(null);
+
         boolean wait = waitForCondition(new GridAbsPredicate() {
             @Override public boolean apply() {
-                return cache.localPeek(key) == null;
+                for (int i = 0; i < gridCount(); i++) {
+                    if (peek(jcache(i), key) != null)
+                        return false;
+                }
+
+                return true;
             }
         }, ttl + 1000);
 
@@ -3498,8 +3505,6 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
 
         load(cache, key, true);
 
-        Affinity<String> aff = ignite(0).affinity(null);
-
         for (int i = 0; i < gridCount(); i++) {
             if (aff.isPrimary(grid(i).cluster().localNode(), key))
                 assertEquals((Integer)1, peek(jcache(i), key));


Mime
View raw message