You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/04/14 13:54:12 UTC
ignite git commit: IGNITE-4986 - Debug
Repository: ignite
Updated Branches:
refs/heads/ignite-4986 ca4ce7e87 -> 8586e7773
IGNITE-4986 - Debug
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8586e777
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8586e777
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8586e777
Branch: refs/heads/ignite-4986
Commit: 8586e777394c7f1123237adc71d989330ca0e88c
Parents: ca4ce7e
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Fri Apr 14 16:54:42 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Fri Apr 14 16:54:42 2017 +0300
----------------------------------------------------------------------
.../internal/processors/cache/GridCacheProcessor.java | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8586e777/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index 7c7d45f..3a1d770 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -996,6 +996,8 @@ public class GridCacheProcessor extends GridProcessorAdapter {
/** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Override public void stop(boolean cancel) throws IgniteCheckedException {
+ U.debug("Stopping cache processor");
+
stopCaches(cancel);
List<? extends GridCacheSharedManager<?, ?>> mgrs = sharedCtx.managers();
@@ -1023,11 +1025,16 @@ public class GridCacheProcessor extends GridProcessorAdapter {
if (cache != null)
stopCache(cache, cancel, false);
+ else
+ U.debug("CACHE IS NULL: " + cacheName);
}
for (GridCacheAdapter<?, ?> cache : stoppedCaches.values()) {
if (cache == stoppedCaches.remove(maskNull(cache.name())))
stopCache(cache, cancel, false);
+ else {
+ U.debug("????? " + cache.name());
+ }
}
registeredCaches.clear();
@@ -1318,7 +1325,11 @@ public class GridCacheProcessor extends GridProcessorAdapter {
ctx.kernalContext().cache().context().database().onCacheStop(ctx);
- U.stopLifecycleAware(log, lifecycleAwares(cache.configuration(), ctx.store().configuredStore()));
+ Iterable<Object> lca = lifecycleAwares(cache.configuration(), ctx.store().configuredStore());
+
+ U.debug("LCA for cache [cache=" + cache.configuration().getName() + ", LCA=" + lca + ']');
+
+ U.stopLifecycleAware(log, lca);
if (log.isInfoEnabled())
log.info("Stopped cache: " + cache.name());