Repository: ignite Updated Branches: refs/heads/ignite-3477-no-wlock 75dbef734 -> ca035ca61
minor Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ca035ca6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ca035ca6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ca035ca6 Branch: refs/heads/ignite-3477-no-wlock Commit: ca035ca61d130cf768e58b88cdd0ab930876adca Parents: 75dbef7 Author: Yakov Zhdanov <[email protected]> Authored: Fri Mar 3 12:22:11 2017 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Fri Mar 3 12:22:11 2017 +0300 ---------------------------------------------------------------------- .../cache/database/freelist/FreeListImpl.java | 21 ++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ca035ca6/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java index 80139dd..19da994 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java @@ -437,16 +437,17 @@ public class FreeListImpl extends PagesList implements FreeList, ReuseList { long pageId = PageIdUtils.pageId(link); int itemId = PageIdUtils.itemId(link); - try (Page page = pageMem.page(cacheId, pageId)) { - DataPageIO init = PageIO.getPageIO(((PageNoStoreImpl)page).pointer()); - - Boolean updated = updateRow.run(page, init, - ((PageNoStoreImpl)page).pointer(), row, itemId); - - assert updated != null; // Can't fail here. - - return updated != null ? updated : false; - } +// try (Page page = pageMem.page(cacheId, pageId)) { +// DataPageIO init = PageIO.getPageIO(((PageNoStoreImpl)page).pointer()); +// +// Boolean updated = updateRow.run(page, init, +// ((PageNoStoreImpl)page).pointer(), row, itemId); +// +// assert updated != null; // Can't fail here. +// +// return updated != null ? updated : false; +// } + return true; } /** {@inheritDoc} */
