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/02/16 10:41:47 UTC
[6/6] ignite git commit: ignite-2515 Review.
ignite-2515 Review.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4cbe064f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4cbe064f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4cbe064f
Branch: refs/heads/ignite-2515
Commit: 4cbe064f7ae832cf70665ce7dc61ee3b92ef43d1
Parents: 0c0ef99
Author: sboikov <sb...@gridgain.com>
Authored: Tue Feb 16 12:41:33 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue Feb 16 12:41:33 2016 +0300
----------------------------------------------------------------------
.../CacheContinuousQueryRandomOperationsTest.java | 17 ++++++++++-------
1 file changed, 10 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/4cbe064f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
index abbb807..62ed66f 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
@@ -74,6 +74,9 @@ import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
import static org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryRandomOperationsTest.ContinuousDeploy.ALL;
import static org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryRandomOperationsTest.ContinuousDeploy.CLIENT;
import static org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryRandomOperationsTest.ContinuousDeploy.SERVER;
+import static org.apache.ignite.transactions.TransactionIsolation.READ_COMMITTED;
+import static org.apache.ignite.transactions.TransactionIsolation.REPEATABLE_READ;
+import static org.apache.ignite.transactions.TransactionIsolation.SERIALIZABLE;
/**
*
@@ -989,7 +992,7 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
if (val == null && oldVal == null) {
checkNoEvent(evtsQueues);
- return;
+ continue;
}
CacheEntryEvent evt = rcvEvts.get(key);
@@ -1016,14 +1019,14 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
* @return {@link TransactionIsolation}.
*/
private TransactionIsolation txRandomIsolation(Random rnd) {
- double val = rnd.nextDouble();
+ int val = rnd.nextInt(3);
- if (val < 1/3)
- return TransactionIsolation.READ_COMMITTED;
- else if (val < 2/3)
- return TransactionIsolation.REPEATABLE_READ;
+ if (val == 0)
+ return READ_COMMITTED;
+ else if (val == 1)
+ return REPEATABLE_READ;
else
- return TransactionIsolation.SERIALIZABLE;
+ return SERIALIZABLE;
}
/**