# ignite-157-1 added 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/01d2af19 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/01d2af19 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/01d2af19 Branch: refs/heads/ignite-831 Commit: 01d2af19e3ac3ed134aae5417c90866db30dc2c6 Parents: 788de6d Author: sboikov <sboi...@gridgain.com> Authored: Mon Apr 27 11:37:18 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Apr 27 11:51:09 2015 +0300 ---------------------------------------------------------------------- .../cache/IgniteCacheTxPreloadNoWriteTest.java | 29 +++++++++++++++++--- 1 file changed, 25 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/01d2af19/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheTxPreloadNoWriteTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheTxPreloadNoWriteTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheTxPreloadNoWriteTest.java index f17e6a8..f881451 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheTxPreloadNoWriteTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheTxPreloadNoWriteTest.java @@ -31,6 +31,8 @@ import org.apache.ignite.transactions.*; import static org.apache.ignite.cache.CacheAtomicityMode.*; import static org.apache.ignite.cache.CacheMode.*; +import static org.apache.ignite.cache.CacheRebalanceMode.*; +import static org.apache.ignite.cache.CacheWriteSynchronizationMode.*; import static org.apache.ignite.transactions.TransactionConcurrency.*; import static org.apache.ignite.transactions.TransactionIsolation.*; @@ -57,8 +59,9 @@ public class IgniteCacheTxPreloadNoWriteTest extends GridCommonAbstractTest { ccfg.setCacheMode(REPLICATED); ccfg.setAtomicityMode(TRANSACTIONAL); - ccfg.setRebalanceMode(CacheRebalanceMode.ASYNC); + ccfg.setRebalanceMode(ASYNC); ccfg.setAffinity(new RendezvousAffinityFunction(false, 100)); + ccfg.setWriteSynchronizationMode(FULL_SYNC); cfg.setCacheConfiguration(ccfg); @@ -76,14 +79,31 @@ public class IgniteCacheTxPreloadNoWriteTest extends GridCommonAbstractTest { * @throws Exception If failed. */ public void testTxNoWrite() throws Exception { + txNoWrite(true); + } + + /** + * @throws Exception If failed. + */ + public void testTxNoWriteRollback() throws Exception { + txNoWrite(false); + } + + /** + * @param commit {@code True} if commit transaction. + * @throws Exception If failed. + */ + private void txNoWrite(boolean commit) throws Exception { Ignite ignite0 = startGrid(0); Affinity<Integer> aff = ignite0.affinity(null); IgniteCache<Integer, Object> cache0 = ignite0.cache(null); - for (int i = 0; i < 1000; i++) - cache0.put(i + 10000, new byte[1024]); + try (IgniteDataStreamer<Integer, Object> streamer = ignite0.dataStreamer(null)) { + for (int i = 0; i < 1000; i++) + streamer.addData(i + 10000, new byte[1024]); + } Ignite ignite1 = startGrid(1); @@ -95,7 +115,8 @@ public class IgniteCacheTxPreloadNoWriteTest extends GridCommonAbstractTest { try (Transaction tx = ignite0.transactions().txStart(PESSIMISTIC, REPEATABLE_READ)) { cache0.get(key); - tx.commit(); + if (commit) + tx.commit(); } GridCacheAdapter cacheAdapter = ((IgniteKernal)ignite(0)).context().cache().internalCache();
