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 2015/09/08 15:08:43 UTC
ignite git commit: ignite-1349 Use proxy in IgfsDataManager
Repository: ignite
Updated Branches:
refs/heads/ignite-1349 [created] ee7cc294a
ignite-1349 Use proxy in IgfsDataManager
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ee7cc294
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ee7cc294
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ee7cc294
Branch: refs/heads/ignite-1349
Commit: ee7cc294a0b96e9b54404d3d638ccaa528bcedf0
Parents: 069653b
Author: sboikov <sb...@gridgain.com>
Authored: Tue Sep 8 16:07:49 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue Sep 8 16:07:49 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/igfs/IgfsDataManager.java | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/ee7cc294/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
index c571f41..f6b7d61 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
@@ -239,16 +239,15 @@ public class IgfsDataManager extends IgfsManager {
}
/** {@inheritDoc} */
+ @SuppressWarnings("unchecked")
@Override protected void onKernalStart0() throws IgniteCheckedException {
- igfsCtx.kernalContext().cache().getOrStartCache(igfsCtx.configuration().getDataCacheName());
- dataCachePrj = igfsCtx.kernalContext().cache().internalCache(igfsCtx.configuration().getDataCacheName());
+ dataCachePrj = igfsCtx.kernalContext().cache().getOrStartCache(igfsCtx.configuration().getDataCacheName());
- igfsCtx.kernalContext().cache().getOrStartCache(igfsCtx.configuration().getDataCacheName());
- dataCache = igfsCtx.kernalContext().cache().internalCache(igfsCtx.configuration().getDataCacheName());
+ assert dataCachePrj != null;
- metrics = igfsCtx.igfs().localMetrics();
+ dataCache = (IgniteInternalCache)dataCachePrj;
- assert dataCachePrj != null;
+ metrics = igfsCtx.igfs().localMetrics();
AffinityKeyMapper mapper = igfsCtx.kernalContext().cache()
.internalCache(igfsCtx.configuration().getDataCacheName()).configuration().getAffinityMapper();