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 <[email protected]> Authored: Tue Feb 14 13:20:36 2017 +0300 Committer: Sergi Vladykin <[email protected]> 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);
