Merge branch 'ignite-3477' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-db-x
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f8c77533 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f8c77533 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f8c77533 Branch: refs/heads/ignite-3477 Commit: f8c7753395a6cf9c4948ebb32f1e0260e92d0915 Parents: b721d73d 7db65dd Author: Alexey Goncharuk <[email protected]> Authored: Tue Jan 17 20:52:42 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Jan 17 20:52:42 2017 +0300 ---------------------------------------------------------------------- .../internal/binary/BinaryEnumObjectImpl.java | 7 + .../internal/binary/BinaryObjectImpl.java | 5 + .../binary/BinaryObjectOffheapImpl.java | 5 + .../apache/ignite/internal/pagemem/Page.java | 11 +- .../ignite/internal/pagemem/PageMemory.java | 9 +- .../ignite/internal/pagemem/PageUtils.java | 185 ++++++ .../pagemem/impl/PageMemoryNoStoreImpl.java | 134 ++-- .../internal/pagemem/impl/PageNoStoreImpl.java | 91 +-- .../delta/DataPageInsertFragmentRecord.java | 8 +- .../wal/record/delta/DataPageInsertRecord.java | 8 +- .../wal/record/delta/DataPageRemoveRecord.java | 8 +- .../delta/DataPageSetFreeListPageRecord.java | 8 +- .../wal/record/delta/FixCountRecord.java | 8 +- .../record/delta/FixLeftmostChildRecord.java | 8 +- .../pagemem/wal/record/delta/FixRemoveId.java | 8 +- .../wal/record/delta/InitNewPageRecord.java | 8 +- .../wal/record/delta/InnerReplaceRecord.java | 4 +- .../pagemem/wal/record/delta/InsertRecord.java | 5 +- .../pagemem/wal/record/delta/MergeRecord.java | 3 +- .../wal/record/delta/MetaPageAddRootRecord.java | 8 +- .../wal/record/delta/MetaPageCutRootRecord.java | 7 +- .../wal/record/delta/MetaPageInitRecord.java | 14 +- .../record/delta/MetaPageInitRootRecord.java | 9 +- .../delta/MetaPageUpdateLastAllocatedIndex.java | 10 +- ...aPageUpdateLastSuccessfulFullSnapshotId.java | 8 +- .../MetaPageUpdateLastSuccessfulSnapshotId.java | 8 +- .../delta/MetaPageUpdateNextSnapshotId.java | 8 +- .../MetaPageUpdatePartitionDataRecord.java | 12 +- .../wal/record/delta/NewRootInitRecord.java | 6 +- .../wal/record/delta/PageDeltaRecord.java | 7 +- .../delta/PageListMetaResetCountRecord.java | 8 +- .../record/delta/PagesListAddPageRecord.java | 8 +- .../delta/PagesListInitNewPageRecord.java | 10 +- .../record/delta/PagesListRemovePageRecord.java | 8 +- .../record/delta/PagesListSetNextRecord.java | 8 +- .../delta/PagesListSetPreviousRecord.java | 8 +- .../pagemem/wal/record/delta/RecycleRecord.java | 6 +- .../pagemem/wal/record/delta/RemoveRecord.java | 12 +- .../pagemem/wal/record/delta/ReplaceRecord.java | 7 +- .../record/delta/SplitExistingPageRecord.java | 8 +- .../record/delta/SplitForwardPageRecord.java | 3 +- .../record/delta/TrackingPageDeltaRecord.java | 10 +- .../internal/processors/cache/CacheObject.java | 7 + .../processors/cache/CacheObjectAdapter.java | 40 +- .../cache/CacheObjectByteArrayImpl.java | 5 + .../cache/IgniteCacheOffheapManagerImpl.java | 372 +++++++---- .../processors/cache/database/CacheDataRow.java | 13 +- .../cache/database/CacheDataRowAdapter.java | 72 ++- .../cache/database/CacheSearchRow.java | 40 ++ .../cache/database/DataStructure.java | 36 +- .../IgniteCacheDatabaseSharedManager.java | 2 +- .../cache/database/MetadataStorage.java | 149 +++-- .../cache/database/freelist/FreeListImpl.java | 61 +- .../cache/database/freelist/PagesList.java | 212 +++---- .../database/freelist/io/PagesListMetaIO.java | 71 +-- .../database/freelist/io/PagesListNodeIO.java | 117 ++-- .../cache/database/tree/BPlusTree.java | 616 ++++++++++--------- .../cache/database/tree/io/BPlusIO.java | 201 +++--- .../cache/database/tree/io/BPlusInnerIO.java | 71 ++- .../cache/database/tree/io/BPlusLeafIO.java | 11 +- .../cache/database/tree/io/BPlusMetaIO.java | 79 +-- .../cache/database/tree/io/CacheVersionIO.java | 46 ++ .../cache/database/tree/io/DataPageIO.java | 545 ++++++++-------- .../cache/database/tree/io/DataPagePayload.java | 64 ++ .../cache/database/tree/io/IOVersions.java | 12 +- .../cache/database/tree/io/PageIO.java | 110 +++- .../cache/database/tree/io/PageMetaIO.java | 118 ++-- .../database/tree/io/PagePartitionMetaIO.java | 67 +- .../database/tree/reuse/ReuseListImpl.java | 2 +- .../cache/database/tree/util/PageHandler.java | 135 ++-- .../database/tree/util/PageLockListener.java | 17 +- .../atomic/GridDhtAtomicSingleUpdateFuture.java | 3 +- .../atomic/GridNearAtomicUpdateResponse.java | 3 + .../apache/ignite/internal/util/GridUnsafe.java | 12 + .../apache/ignite/internal/util/IgniteTree.java | 31 +- .../internal/GridAffinityNoCacheSelfTest.java | 5 + .../pagemem/impl/PageMemoryNoLoadSelfTest.java | 29 +- .../IgniteIncompleteCacheObjectSelfTest.java | 5 + .../database/tree/io/TrackingPageIOTest.java | 38 +- .../database/BPlusTreeReuseSelfTest.java | 22 +- .../processors/database/BPlusTreeSelfTest.java | 85 +-- .../database/FreeListImplSelfTest.java | 15 +- .../database/MetadataStorageSelfTest.java | 2 +- .../internal/processors/query/h2/H2Cursor.java | 9 +- .../processors/query/h2/database/H2Tree.java | 5 +- .../query/h2/database/H2TreeIndex.java | 5 +- .../query/h2/database/io/H2InnerIO.java | 24 +- .../query/h2/database/io/H2LeafIO.java | 22 +- .../query/h2/database/io/H2RowLinkIO.java | 6 +- .../processors/query/h2/opt/GridH2Row.java | 5 + .../query/IgniteSqlDistributedJoinSelfTest.java | 46 +- .../h2/GridIndexingSpiAbstractSelfTest.java | 5 + .../IgniteDistributedJoinTestSuite.java | 2 +- 93 files changed, 2579 insertions(+), 1807 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f8c77533/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java ----------------------------------------------------------------------
