You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/09/29 12:41:45 UTC
[17/20] ignite git commit: ignite-3621 Fixed 'testEvictExpired'.
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 <sb...@gridgain.com>
Authored: Wed Sep 28 13:47:51 2016 +0300
Committer: sboikov <sb...@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));