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 2015/10/13 09:05:42 UTC
[09/21] ignite git commit: ignite-1607 WIP
ignite-1607 WIP
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/caed8659
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/caed8659
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/caed8659
Branch: refs/heads/ignite-1607
Commit: caed8659d2acceb05c4b64743e5864546a1dc4d0
Parents: 7572810
Author: sboikov <sb...@gridgain.com>
Authored: Thu Oct 8 15:31:01 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Thu Oct 8 15:31:01 2015 +0300
----------------------------------------------------------------------
.../cache/CacheSerializableTransactionsTest.java | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/caed8659/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheSerializableTransactionsTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheSerializableTransactionsTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheSerializableTransactionsTest.java
index 8ecd045..9f74b9c 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheSerializableTransactionsTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheSerializableTransactionsTest.java
@@ -162,6 +162,18 @@ public class CacheSerializableTransactionsTest extends GridCommonAbstractTest {
}
checkValue(key, storeVal, cache.getName());
+
+ cache.remove(key);
+
+ try (Transaction tx = txs.txStart(OPTIMISTIC, SERIALIZABLE)) {
+ Integer val = cache.get(key);
+
+ assertNull(val);
+
+ tx.commit();
+ }
+
+ checkValue(key, null, cache.getName());
}
}
finally {
@@ -1382,7 +1394,7 @@ public class CacheSerializableTransactionsTest extends GridCommonAbstractTest {
for (int i = 0; i < ITERS; i++) {
log.info("Iteration: " + i);
- final long stopTime = U.currentTimeMillis() + 10_000;
+ final long stopTime = U.currentTimeMillis() + (FAST ? 1000 : 10_000);
final AtomicInteger idx = new AtomicInteger();