Repository: ignite Updated Branches: refs/heads/ignite-2.7 a7846d1ef -> db52210a5
IGNITE-10278: MVCC: Checkpoint read lock must be acquired before calling MvccProcessor.updateState. This closes #5401. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db52210a Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db52210a Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db52210a Branch: refs/heads/ignite-2.7 Commit: db52210a5fd53c11d59a72d975c2f58c5eb2b6b4 Parents: a7846d1 Author: Slava Koptilin <slava.kopti...@gmail.com> Authored: Sat Nov 17 15:18:08 2018 +0300 Committer: devozerov <ppoze...@gmail.com> Committed: Sat Nov 17 15:19:16 2018 +0300 ---------------------------------------------------------------------- .../cache/persistence/GridCacheDatabaseSharedManager.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/db52210a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index 3e47ede..da965f8 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -2250,6 +2250,8 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan break; case MVCC_TX_RECORD: + checkpointReadLock(); + try { MvccTxRecord txRecord = (MvccTxRecord)rec; @@ -2260,6 +2262,9 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan catch (IgniteCheckedException e) { throw new IgniteException(e); } + finally { + checkpointReadUnlock(); + } break;
