Added onCacheGroupStopped callback
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/77c5dc74 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/77c5dc74 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/77c5dc74 Branch: refs/heads/ignite-2.1.2-exchange Commit: 77c5dc7455b9bf020dee549cc91286a897dbfdbc Parents: 114c42e Author: Dmitriy Govorukhin <[email protected]> Authored: Tue Jul 4 19:40:21 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Jul 4 19:40:21 2017 +0300 ---------------------------------------------------------------------- .../cache/persistence/GridCacheDatabaseSharedManager.java | 6 +++++- .../cache/persistence/IgniteCacheSnapshotManager.java | 8 ++++++++ 2 files changed, 13 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/77c5dc74/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index 990f54c..b3ab1cd 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -821,7 +821,11 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan Map<PageMemoryEx, Collection<Integer>> destroyed = new HashMap<>(); for (IgniteBiTuple<CacheGroupContext, Boolean> tup : stoppedGrps) { - PageMemoryEx pageMem = (PageMemoryEx)tup.get1().memoryPolicy().pageMemory(); + CacheGroupContext gctx = tup.get1(); + + snapshotMgr.onCacheGroupStop(gctx); + + PageMemoryEx pageMem = (PageMemoryEx)gctx.memoryPolicy().pageMemory(); Collection<Integer> grpIds = destroyed.get(pageMem); http://git-wip-us.apache.org/repos/asf/ignite/blob/77c5dc74/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/IgniteCacheSnapshotManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/IgniteCacheSnapshotManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/IgniteCacheSnapshotManager.java index 95af487..ad804cb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/IgniteCacheSnapshotManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/IgniteCacheSnapshotManager.java @@ -26,6 +26,7 @@ import org.apache.ignite.internal.IgniteInternalFuture; import org.apache.ignite.internal.pagemem.FullPageId; import org.apache.ignite.internal.pagemem.PageMemory; import org.apache.ignite.internal.pagemem.snapshot.SnapshotOperation; +import org.apache.ignite.internal.processors.cache.CacheGroupContext; import org.apache.ignite.internal.processors.cache.GridCacheContext; import org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter; import org.apache.ignite.internal.processors.cluster.IgniteChangeGlobalStateSupport; @@ -109,6 +110,13 @@ public class IgniteCacheSnapshotManager extends GridCacheSharedManagerAdapter im } /** + * @param gctx Cctx. + */ + public void onCacheGroupStop(CacheGroupContext gctx) { + // No-op. + } + + /** * */ public void onChangeTrackerPage(
