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/10/03 14:46:13 UTC
[17/17] ignite git commit: ignite-3478
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 <sb...@gridgain.com>
Authored: Tue Oct 3 17:34:30 2017 +0300
Committer: sboikov <sb...@gridgain.com>
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>() {