ignite-3478
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fdfe779f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fdfe779f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fdfe779f Branch: refs/heads/ignite-3478 Commit: fdfe779f063d015dd0fcb7f2880a1b227a3e190f Parents: 07a5602 Author: sboikov <[email protected]> Authored: Tue Oct 3 17:34:30 2017 +0300 Committer: sboikov <[email protected]> Committed: Tue Oct 3 17:34:30 2017 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridPartitionedGetFuture.java | 11 ----------- 1 file changed, 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fdfe779f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java index 67d918f..7993d05 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java @@ -675,17 +675,6 @@ public class GridPartitionedGetFuture<K, V> extends CacheDistributedGetFutureAda return Collections.emptyMap(); } - /** - * @param curTopVer Current topology version. - * @return Future to wait for before remapping. - */ - private IgniteInternalFuture<AffinityTopologyVersion> waitRemapFuture(AffinityTopologyVersion curTopVer) { - AffinityTopologyVersion updTopVer = - new AffinityTopologyVersion(Math.max(curTopVer.topologyVersion() + 1, cctx.discovery().topologyVersion())); - - return cctx.affinity().affinityReadyFuture(updTopVer); - } - /** {@inheritDoc} */ @Override public String toString() { Collection<String> futs = F.viewReadOnly(futures(), new C1<IgniteInternalFuture<?>, String>() {
