MetaPageInitRecord fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d4c99979 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d4c99979 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d4c99979 Branch: refs/heads/ignite-5398 Commit: d4c999795917b7695cc13f2fea3e69cd1a3d5078 Parents: 46cba2a Author: Alexey Goncharuk <[email protected]> Authored: Wed May 17 20:58:21 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed May 17 20:58:21 2017 +0300 ---------------------------------------------------------------------- .../pagemem/wal/record/delta/MetaPageInitRecord.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d4c99979/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/MetaPageInitRecord.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/MetaPageInitRecord.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/MetaPageInitRecord.java index 3d351a2..1dadd69 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/MetaPageInitRecord.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/delta/MetaPageInitRecord.java @@ -67,18 +67,14 @@ public class MetaPageInitRecord extends InitNewPageRecord { return reuseListRoot; } - /** - * @return IO type. - */ - public int ioType() { + /** {@inheritDoc} */ + @Override public int ioType() { return ioType; } /** {@inheritDoc} */ @Override public void applyDelta(PageMemory pageMem, long pageAddr) throws IgniteCheckedException { - PageMetaIO io = ioType == PageIO.T_META ? - PageMetaIO.VERSIONS.forPage(pageAddr) : - PagePartitionMetaIO.VERSIONS.forPage(pageAddr); + PageMetaIO io = PageMetaIO.getPageIO(ioType, ioVer); io.initNewPage(pageAddr, newPageId, pageMem.pageSize());
