Repository: ignite
Updated Branches:
  refs/heads/ignite-3478 3f33d6a5d -> e2853a2f5


ignite-3478


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e2853a2f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e2853a2f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e2853a2f

Branch: refs/heads/ignite-3478
Commit: e2853a2f5ce786c1e9ff5a14c469d260249d937e
Parents: 3f33d6a
Author: sboikov <[email protected]>
Authored: Mon Oct 16 15:14:07 2017 +0300
Committer: sboikov <[email protected]>
Committed: Mon Oct 16 15:14:07 2017 +0300

----------------------------------------------------------------------
 .../processors/cache/mvcc/CacheMvccTransactionsTest.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e2853a2f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java
index 9da6876..642771e 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java
@@ -4326,8 +4326,13 @@ public class CacheMvccTransactionsTest extends 
GridCommonAbstractTest {
      */
     private static <K, V> TestCache<K, V> randomCache(List<TestCache> caches, 
ThreadLocalRandom rnd) {
         synchronized (caches) {
-            if (caches.size() == 1)
-                return caches.get(0);
+            if (caches.size() == 1) {
+                TestCache cache = caches.get(0);
+
+                assertTrue(cache.readLock());
+
+                return cache;
+            }
 
             for (;;) {
                 int idx = rnd.nextInt(caches.size());

Reply via email to