You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dp...@apache.org on 2019/03/22 12:16:10 UTC
[ignite] branch ignite-2.7.5 updated: IGNITE-11265 Removed unused
method came from cherry-pick from commit 3a77531
This is an automated email from the ASF dual-hosted git repository.
dpavlov pushed a commit to branch ignite-2.7.5
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/ignite-2.7.5 by this push:
new b0fd586 IGNITE-11265 Removed unused method came from cherry-pick from commit 3a77531
b0fd586 is described below
commit b0fd58607a92b6a7da31790ae4e5456612610ab2
Author: Dmitriy Pavlov <dp...@apache.org>
AuthorDate: Fri Mar 22 15:15:50 2019 +0300
IGNITE-11265 Removed unused method came from cherry-pick from commit 3a77531
---
.../preloader/GridDhtPartitionsExchangeFuture.java | 34 ----------------------
1 file changed, 34 deletions(-)
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 177fed1..e84b7a0 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
@@ -3501,40 +3501,6 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
}
/**
- * @param msg Single message to process.
- * @param messageAccumulator Message to store message which need to be sent after.
- */
- private void processSingleMessageOnCrdFinish(
- GridDhtPartitionsSingleMessage msg,
- Map<Integer, CacheGroupAffinityMessage> messageAccumulator
- ) {
- for (Map.Entry<Integer, GridDhtPartitionMap> e : msg.partitions().entrySet()) {
- Integer grpId = e.getKey();
-
- CacheGroupContext grp = cctx.cache().cacheGroup(grpId);
-
- GridDhtPartitionTopology top = grp != null
- ? grp.topology()
- : cctx.exchange().clientTopology(grpId, events().discoveryCache());
-
- CachePartitionPartialCountersMap cntrs = msg.partitionUpdateCounters(grpId, top.partitions());
-
- if (cntrs != null)
- top.collectUpdateCounters(cntrs);
- }
-
- Collection<Integer> affReq = msg.cacheGroupsAffinityRequest();
-
- if (affReq != null)
- CacheGroupAffinityMessage.createAffinityMessages(
- cctx,
- exchCtx.events().topologyVersion(),
- affReq,
- messageAccumulator
- );
- }
-
- /**
* Validates that partition update counters and cache sizes for all caches are consistent.
*/
private void validatePartitionsState() {