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/e7dd9cc1 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e7dd9cc1 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e7dd9cc1 Branch: refs/heads/ignite-4986 Commit: e7dd9cc1fc20216a7dcf260a9ec57517aa776a98 Parents: ff242a4 Author: Alexey Goncharuk <[email protected]> Authored: Fri Apr 14 16:54:42 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Fri Apr 14 18:27:00 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/e7dd9cc1/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 8799fbb..05d084d 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 @@ -983,6 +983,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(); @@ -1010,11 +1012,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(); @@ -1305,7 +1312,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());
