Repository: incubator-ignite Updated Branches: refs/heads/sprint-2 f65cbdb0e -> 0f1fc65bd
# sprint-2 fixed test Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/0f1fc65b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/0f1fc65b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/0f1fc65b Branch: refs/heads/sprint-2 Commit: 0f1fc65bd595b55e81639f96378c532820e0b441 Parents: f65cbdb Author: sboikov <sboi...@gridgain.com> Authored: Tue Mar 17 09:50:47 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Mar 17 09:50:47 2015 +0300 ---------------------------------------------------------------------- ...iteCacheStoreSessionWriteBehindAbstractTest.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0f1fc65b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionWriteBehindAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionWriteBehindAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionWriteBehindAbstractTest.java index 5e68a34..408bd93 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionWriteBehindAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionWriteBehindAbstractTest.java @@ -76,7 +76,7 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign ccfg0.setWriteThrough(true); ccfg0.setWriteBehindBatchSize(10); ccfg0.setWriteBehindFlushSize(10); - ccfg0.setWriteBehindFlushFrequency(5000); + ccfg0.setWriteBehindFlushFrequency(60_000); ccfg0.setWriteBehindEnabled(true); ccfg0.setCacheStoreFactory(new FactoryBuilder.SingletonFactory(new TestStore())); @@ -87,7 +87,7 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign ccfg1.setWriteThrough(true); ccfg1.setWriteBehindBatchSize(10); ccfg1.setWriteBehindFlushSize(10); - ccfg1.setWriteBehindFlushFrequency(5000); + ccfg1.setWriteBehindFlushFrequency(60_000); ccfg1.setWriteBehindEnabled(true); ccfg1.setName(CACHE_NAME1); @@ -116,11 +116,11 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign IgniteCache<Integer, Integer> cache = ignite(0).jcache(cacheName); try { - latch = new CountDownLatch(1); + latch = new CountDownLatch(2); expData = new ExpectedData("writeAll", cacheName); - for (int i = 0; i < 10; i++) + for (int i = 0; i < 11; i++) cache.put(i, i); assertTrue(latch.await(10_000, TimeUnit.MILLISECONDS)); @@ -130,11 +130,11 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign } try { - latch = new CountDownLatch(1); + latch = new CountDownLatch(2); expData = new ExpectedData("deleteAll", cacheName); - for (int i = 0; i < 10; i++) + for (int i = 0; i < 11; i++) cache.remove(i); assertTrue(latch.await(10_000, TimeUnit.MILLISECONDS)); @@ -189,7 +189,7 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign @Override public void writeAll(Collection<Cache.Entry<?, ?>> entries) throws CacheWriterException { log.info("writeAll: " + entries); - assertEquals(10, entries.size()); + assertTrue("Unexpected entries: " + entries, entries.size() == 10 || entries.size() == 1); checkSession("writeAll"); } @@ -203,7 +203,7 @@ public abstract class IgniteCacheStoreSessionWriteBehindAbstractTest extends Ign @Override public void deleteAll(Collection<?> keys) throws CacheWriterException { log.info("deleteAll: " + keys); - assertEquals(10, keys.size()); + assertTrue("Unexpected keys: " + keys, keys.size() == 10 || keys.size() == 1); checkSession("deleteAll"); }
