You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2017/02/16 14:40:59 UTC
[07/17] ignite git commit: ignite-db-x - restartFromRoot
ignite-db-x - restartFromRoot
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9fe01a49
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9fe01a49
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9fe01a49
Branch: refs/heads/ignite-4652
Commit: 9fe01a494d97f98a5cbf2873046a8bb1a38b69d7
Parents: 97e9bd9
Author: Sergi Vladykin <se...@gmail.com>
Authored: Tue Feb 14 13:20:36 2017 +0300
Committer: Sergi Vladykin <se...@gmail.com>
Committed: Tue Feb 14 13:20:36 2017 +0300
----------------------------------------------------------------------
.../processors/cache/database/tree/BPlusTree.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9fe01a49/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/BPlusTree.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/BPlusTree.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/BPlusTree.java
index f87ba2b..7770c27 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/BPlusTree.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/BPlusTree.java
@@ -2198,7 +2198,7 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements
* @param rootLvl Root level.
* @param rmvId Remove ID to be afraid of.
*/
- final void restartFromRoot(long rootId, int rootLvl, long rmvId) {
+ void restartFromRoot(long rootId, int rootLvl, long rmvId) {
this.rootId = rootId;
this.rootLvl = rootLvl;
this.rmvId = rmvId;
@@ -2660,6 +2660,14 @@ public abstract class BPlusTree<L, T extends L> extends DataStructure implements
}
/** {@inheritDoc} */
+ @Override void restartFromRoot(long rootId, int rootLvl, long rmvId) {
+ super.restartFromRoot(rootId, rootLvl, rmvId);
+
+ if (op != null)
+ op.restartFromRoot(rootId, rootLvl, rmvId);
+ }
+
+ /** {@inheritDoc} */
@Override boolean found(BPlusIO<L> io, long pageAddr, int idx, int lvl) throws IgniteCheckedException {
if (lvl == 0) {
invokeClosure(io, pageAddr, idx);