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 2016/07/20 09:07:22 UTC
[37/46] ignite git commit: Fixes after merge.
Fixes after merge.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/869db216
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/869db216
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/869db216
Branch: refs/heads/ignite-1232
Commit: 869db21602c22a5340206016b64369d9eb3e4efa
Parents: 84fddee
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Tue Jul 19 17:09:19 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Tue Jul 19 17:09:19 2016 +0300
----------------------------------------------------------------------
.../processors/cache/GridCacheAdapter.java | 46 --------------------
1 file changed, 46 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/869db216/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 8bada9f..90669e0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@ -5709,52 +5709,6 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V
}
/**
- * Internal callable for partition size calculation.
- */
- @GridInternal
- private static class PartitionSizeLongJob extends TopologyVersionAwareJob {
- /** */
- private static final long serialVersionUID = 0L;
-
- /** Partition. */
- private final int partition;
-
- /** Peek modes. */
- private final CachePeekMode[] peekModes;
-
- /**
- * @param cacheName Cache name.
- * @param topVer Affinity topology version.
- * @param peekModes Cache peek modes.
- * @param partition partition.
- */
- private PartitionSizeLongJob(String cacheName, AffinityTopologyVersion topVer, CachePeekMode[] peekModes, int partition) {
- super(cacheName, topVer);
-
- this.peekModes = peekModes;
- this.partition = partition;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public Object localExecute(@Nullable IgniteInternalCache cache) {
- if (cache == null)
- return 0;
-
- try {
- return cache.localSizeLong(partition, peekModes);
- }
- catch (IgniteCheckedException e) {
- throw U.convertException(e);
- }
- }
-
- /** {@inheritDoc} */
- public String toString() {
- return S.toString(PartitionSizeLongJob.class, this);
- }
- }
-
- /**
* Internal callable for global size calculation.
*/
@GridInternal