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 2017/06/26 06:49:01 UTC
[07/25] ignite git commit: ignite-gg-12329 do not update partition
map, in case cluster transitioning to inactive state.
ignite-gg-12329 do not update partition map, in case cluster transitioning to inactive state.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9b77b700
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9b77b700
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9b77b700
Branch: refs/heads/ignite-2.1.2-exchange
Commit: 9b77b700f0980db94f358fbfff3fc7ff7d18dd6b
Parents: 7c515ee
Author: Dmitriy Govorukhin <dm...@gmail.com>
Authored: Wed Jun 21 14:45:02 2017 +0300
Committer: Dmitriy Govorukhin <dm...@gmail.com>
Committed: Wed Jun 21 14:45:02 2017 +0300
----------------------------------------------------------------------
.../dht/preloader/GridDhtPartitionsExchangeFuture.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9b77b700/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 230a25c..6cc269a 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
@@ -1444,7 +1444,9 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
if (updateSingleMap) {
try {
- updatePartitionSingleMap(node, msg);
+ // Do not update partition map, in case cluster transitioning to inactive state.
+ if (!exchangeOnChangeGlobalState || exchActions.newClusterState() != ClusterState.INACTIVE)
+ updatePartitionSingleMap(node, msg);
}
finally {
synchronized (this) {