You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2016/12/30 20:55:11 UTC
[3/3] ignite git commit: Added removeExplicitNodeLocks lost during a
merge.
Added removeExplicitNodeLocks lost during a merge.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f8a152ef
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f8a152ef
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f8a152ef
Branch: refs/heads/ignite-3477
Commit: f8a152ef931e4334bfa44fca30c5d32151a8b470
Parents: aa54b18
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Fri Dec 30 22:03:37 2016 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Fri Dec 30 22:03:37 2016 +0300
----------------------------------------------------------------------
.../distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f8a152ef/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index e2c6b49..b7f6680 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -1862,6 +1862,8 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
if (isDone() || !enterBusy())
return;
+ cctx.mvcc().removeExplicitNodeLocks(node.id(), topologyVersion());
+
try {
onDiscoveryEvent(new IgniteRunnable() {
@Override public void run() {