IGNITE-4717 VisorClearTask minor fix. (cherry picked from commit d4b87f4)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/590b82d8 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/590b82d8 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/590b82d8 Branch: refs/heads/ignite-4565-ddl Commit: 590b82d817595b82a0706e332c545e4746fafbc2 Parents: 3310f10 Author: Alexey Kuznetsov <[email protected]> Authored: Fri Mar 10 15:51:38 2017 +0700 Committer: Alexey Kuznetsov <[email protected]> Committed: Fri Mar 10 16:37:40 2017 +0700 ---------------------------------------------------------------------- .../visor/cache/VisorCacheClearTask.java | 57 +++++++++++++++++++- 1 file changed, 56 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/590b82d8/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java index 0c8476f..ce74f17 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheClearTask.java @@ -25,6 +25,7 @@ import org.apache.ignite.internal.util.typedef.internal.S; import org.apache.ignite.internal.visor.VisorJob; import org.apache.ignite.internal.visor.VisorOneNodeTask; import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.lang.IgniteCallable; import org.apache.ignite.lang.IgniteFuture; import org.apache.ignite.lang.IgniteInClosure; import org.apache.ignite.resources.JobContextResource; @@ -145,4 +146,58 @@ public class VisorCacheClearTask extends VisorOneNodeTask<String, IgniteBiTuple< return S.toString(VisorCacheClearJob.class, this); } } -} \ No newline at end of file + + /** + * Callable to get cache size. + * + * @deprecated This class needed only for compatibility. + */ + @GridInternal @Deprecated + private static class VisorCacheSizeCallable implements IgniteCallable<Integer> { + /** */ + private static final long serialVersionUID = 0L; + + /** */ + private final IgniteCache cache; + + /** + * @param cache Cache to take size from. + */ + private VisorCacheSizeCallable(IgniteCache cache) { + this.cache = cache; + } + + /** {@inheritDoc} */ + @Override public Integer call() throws Exception { + return cache.size(CachePeekMode.PRIMARY); + } + } + + /** + * Callable to clear cache. + * + * @deprecated This class needed only for compatibility. + */ + @GridInternal @Deprecated + private static class VisorCacheClearCallable implements IgniteCallable<Integer> { + /** */ + private static final long serialVersionUID = 0L; + + /** */ + private final IgniteCache cache; + + /** + * @param cache Cache to clear. + */ + private VisorCacheClearCallable(IgniteCache cache) { + this.cache = cache; + } + + /** {@inheritDoc} */ + @Override public Integer call() throws Exception { + cache.clear(); + + return 0; + } + } +}
