Repository: ignite Updated Branches: refs/heads/ignite-5267-merge-ea 52640357b -> eff3e09cb
IGNITE-5267 - Fixed CacheState record Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/eff3e09c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/eff3e09c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/eff3e09c Branch: refs/heads/ignite-5267-merge-ea Commit: eff3e09cb66738e987f7993a7d68e2278c4afe95 Parents: 5264035 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Thu Jun 8 16:58:10 2017 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Thu Jun 8 16:58:10 2017 +0300 ---------------------------------------------------------------------- .../ignite/internal/pagemem/wal/record/CacheState.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/eff3e09c/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/CacheState.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/CacheState.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/CacheState.java index 1c8b04a..41d38d0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/CacheState.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/CacheState.java @@ -24,7 +24,7 @@ import java.util.Arrays; */ public class CacheState { /** */ - private short[] parts; + private int[] parts; /** */ private long[] vals; @@ -36,7 +36,7 @@ public class CacheState { * @param partsCnt Partitions count. */ public CacheState(int partsCnt) { - parts = new short[partsCnt]; + parts = new int[partsCnt]; vals = new long[partsCnt * 2]; } @@ -56,7 +56,7 @@ public class CacheState { ", cur=" + partId + ']'); } - parts[idx] = (short)partId; + parts[idx] = partId; vals[2 * idx] = size; vals[2 * idx + 1] = cntr; @@ -92,7 +92,7 @@ public class CacheState { * @return Partition ID. */ public int partitionByIndex(int idx) { - return parts[idx] & 0xFFFF; + return parts[idx]; } /** @@ -123,7 +123,7 @@ public class CacheState { * @return Non-negative index of partition if found or negative value if not found. */ private int indexByPartition(int partId) { - return Arrays.binarySearch(parts, 0, idx, (short)partId); + return Arrays.binarySearch(parts, 0, idx, partId); } /** {@inheritDoc} */
