ignite-5075
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8271aa52 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8271aa52 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8271aa52 Branch: refs/heads/ignite-5075-pds Commit: 8271aa52f13505ce8c346a5f7494ca2671509710 Parents: 7a76845 Author: sboikov <[email protected]> Authored: Sun Jun 4 10:47:01 2017 +0300 Committer: sboikov <[email protected]> Committed: Sun Jun 4 10:47:01 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/distributed/dht/GridDhtLocalPartition.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8271aa52/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java index 882c15a..a53e864 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java @@ -996,7 +996,7 @@ public class GridDhtLocalPartition extends GridCacheConcurrentMapImpl implements true, false); - cctx.shared().database().checkpointReadLock(); + ctx.database().checkpointReadLock(); try {if (cached instanceof GridDhtCacheEntry && ((GridDhtCacheEntry)cached).clearInternal(clearVer, extras)) { if (rec) { @@ -1017,7 +1017,7 @@ public class GridDhtLocalPartition extends GridCacheConcurrentMapImpl implements } } finally { - cctx.shared().database().checkpointReadUnlock(); + ctx.database().checkpointReadUnlock(); } } catch (GridDhtInvalidPartitionException e) {
