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 2017/07/05 04:23:04 UTC
[06/13] ignite git commit: Added onCacheGroupStopped callback
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-gg-12389
Commit: 77c5dc7455b9bf020dee549cc91286a897dbfdbc
Parents: 114c42e
Author: Dmitriy Govorukhin <dm...@gmail.com>
Authored: Tue Jul 4 19:40:21 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
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(