Fixed test to do not fail with non-full-sync mode.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/041cd38d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/041cd38d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/041cd38d Branch: refs/heads/ignite-1282 Commit: 041cd38d46b458ea3ae945e15411d4519c1bf777 Parents: 28d6e00 Author: sboikov <sboi...@gridgain.com> Authored: Thu Nov 26 10:09:46 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Nov 26 10:09:46 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/IgniteClientReconnectCacheTest.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/041cd38d/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java index 6cf10f4..3d8f601 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java @@ -56,6 +56,7 @@ import org.apache.ignite.internal.processors.cache.distributed.near.GridNearLock import org.apache.ignite.internal.processors.cache.distributed.near.GridNearSingleGetResponse; import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishResponse; import org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareResponse; +import org.apache.ignite.internal.util.lang.GridAbsPredicate; import org.apache.ignite.internal.util.typedef.CI1; import org.apache.ignite.internal.util.typedef.F; import org.apache.ignite.internal.util.typedef.T2; @@ -1292,6 +1293,12 @@ public class IgniteClientReconnectCacheTest extends IgniteClientReconnectAbstrac cache.put(1, 1); + GridTestUtils.waitForCondition(new GridAbsPredicate() { + @Override public boolean apply() { + return cache.get(1) != null; + } + }, 5000); + assertEquals(1, cache.get(1)); }
