You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2016/02/19 02:05:56 UTC
[13/16] incubator-geode git commit: renamed off-heap classes with
GemFire in their name
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FragmentJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FragmentJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FragmentJUnitTest.java
index 1b37f23..54eac9e 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FragmentJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FragmentJUnitTest.java
@@ -211,7 +211,7 @@ public class FragmentJUnitTest {
Long fragmentAddress = fragment.getMemoryAddress();
byte[] bytes = new byte[(int)OffHeapStorage.MIN_SLAB_SIZE];
byte[] expectedBytes = new byte[(int)OffHeapStorage.MIN_SLAB_SIZE];
- Arrays.fill(expectedBytes, GemFireChunk.FILL_BYTE);;
+ Arrays.fill(expectedBytes, ObjectChunk.FILL_BYTE);;
fragment.fill();
UnsafeMemoryChunk.readAbsoluteBytes(fragmentAddress, bytes, 0, (int)OffHeapStorage.MIN_SLAB_SIZE);
assertThat(bytes, is(equalTo(expectedBytes)));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListManagerTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListManagerTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListManagerTest.java
index ce98510..64032cc 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListManagerTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListManagerTest.java
@@ -104,12 +104,12 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int tinySize = 10;
- GemFireChunk c = this.freeListManager.allocate(tinySize);
+ ObjectChunk c = this.freeListManager.allocate(tinySize);
validateChunkSizes(c, tinySize);
}
- private void validateChunkSizes(GemFireChunk c, int dataSize) {
+ private void validateChunkSizes(ObjectChunk c, int dataSize) {
assertThat(c).isNotNull();
assertThat(c.getDataSize()).isEqualTo(dataSize);
assertThat(c.getSize()).isEqualTo(computeExpectedSize(dataSize));
@@ -120,8 +120,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int tinySize = 10;
- GemFireChunk c = this.freeListManager.allocate(tinySize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(tinySize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
c = this.freeListManager.allocate(tinySize);
validateChunkSizes(c, tinySize);
@@ -132,8 +132,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = 10;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
this.freeListManager.allocate(dataSize);
// free list will now be empty
c = this.freeListManager.allocate(dataSize);
@@ -146,7 +146,7 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int hugeSize = FreeListManager.MAX_TINY+1;
- GemFireChunk c = this.freeListManager.allocate(hugeSize);
+ ObjectChunk c = this.freeListManager.allocate(hugeSize);
validateChunkSizes(c, hugeSize);
}
@@ -156,8 +156,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = FreeListManager.MAX_TINY+1;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
this.freeListManager.allocate(dataSize);
// free list will now be empty
c = this.freeListManager.allocate(dataSize);
@@ -170,8 +170,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = FreeListManager.MAX_TINY+1+1024;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
dataSize = FreeListManager.MAX_TINY+1;
c = this.freeListManager.allocate(dataSize);
@@ -188,8 +188,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = 10;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
assertThat(this.freeListManager.getFreeTinyMemory()).isEqualTo(computeExpectedSize(dataSize));
}
@@ -199,13 +199,13 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = 10;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
int dataSize2 = 100;
- GemFireChunk c2 = this.freeListManager.allocate(dataSize2);
- GemFireChunk.release(c2.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c2 = this.freeListManager.allocate(dataSize2);
+ ObjectChunk.release(c2.getMemoryAddress(), this.freeListManager);
assertThat(this.freeListManager.getFreeTinyMemory()).isEqualTo(computeExpectedSize(dataSize)+computeExpectedSize(dataSize2));
}
@@ -221,8 +221,8 @@ public class FreeListManagerTest {
setUpSingleSlabManager();
int dataSize = FreeListManager.MAX_TINY+1+1024;
- GemFireChunk c = this.freeListManager.allocate(dataSize);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(dataSize);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
assertThat(this.freeListManager.getFreeHugeMemory()).isEqualTo(computeExpectedSize(dataSize));
}
@@ -237,7 +237,7 @@ public class FreeListManagerTest {
@Test
public void freeFragmentMemorySomeOfFragmentAllocated() {
setUpSingleSlabManager();
- GemFireChunk c = this.freeListManager.allocate(DEFAULT_SLAB_SIZE/4-8);
+ ObjectChunk c = this.freeListManager.allocate(DEFAULT_SLAB_SIZE/4-8);
assertThat(this.freeListManager.getFreeFragmentMemory()).isEqualTo((DEFAULT_SLAB_SIZE/4)*3);
}
@@ -245,13 +245,13 @@ public class FreeListManagerTest {
@Test
public void freeFragmentMemoryMostOfFragmentAllocated() {
setUpSingleSlabManager();
- GemFireChunk c = this.freeListManager.allocate(DEFAULT_SLAB_SIZE-8-8);
+ ObjectChunk c = this.freeListManager.allocate(DEFAULT_SLAB_SIZE-8-8);
assertThat(this.freeListManager.getFreeFragmentMemory()).isZero();
}
private int computeExpectedSize(int dataSize) {
- return ((dataSize + GemFireChunk.OFF_HEAP_HEADER_SIZE + 7) / 8) * 8;
+ return ((dataSize + ObjectChunk.OFF_HEAP_HEADER_SIZE + 7) / 8) * 8;
}
@Test(expected = AssertionError.class)
@@ -288,13 +288,13 @@ public class FreeListManagerTest {
new UnsafeMemoryChunk(SMALL_SLAB),
new UnsafeMemoryChunk(MEDIUM_SLAB),
slab});
- ArrayList<GemFireChunk> chunks = new ArrayList<>();
+ ArrayList<ObjectChunk> chunks = new ArrayList<>();
chunks.add(this.freeListManager.allocate(SMALL_SLAB-8+1));
chunks.add(this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8));
chunks.add(this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8));
chunks.add(this.freeListManager.allocate(SMALL_SLAB-8+1));
- for (GemFireChunk c: chunks) {
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ for (ObjectChunk c: chunks) {
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
}
this.freeListManager.firstCompact = false;
assertThat(this.freeListManager.compact(DEFAULT_SLAB_SIZE+1)).isFalse();
@@ -310,13 +310,13 @@ public class FreeListManagerTest {
new UnsafeMemoryChunk(SMALL_SLAB),
new UnsafeMemoryChunk(MEDIUM_SLAB),
slab});
- ArrayList<GemFireChunk> chunks = new ArrayList<>();
+ ArrayList<ObjectChunk> chunks = new ArrayList<>();
chunks.add(this.freeListManager.allocate(SMALL_SLAB-8+1));
chunks.add(this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8));
chunks.add(this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8));
chunks.add(this.freeListManager.allocate(SMALL_SLAB-8+1));
- for (GemFireChunk c: chunks) {
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ for (ObjectChunk c: chunks) {
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
}
assertThat(this.freeListManager.compact(DEFAULT_SLAB_SIZE)).isTrue();
@@ -333,13 +333,13 @@ public class FreeListManagerTest {
new UnsafeMemoryChunk(SMALL_SLAB),
new UnsafeMemoryChunk(MEDIUM_SLAB),
slab});
- ArrayList<GemFireChunk> chunks = new ArrayList<>();
+ ArrayList<ObjectChunk> chunks = new ArrayList<>();
chunks.add(this.freeListManager.allocate(SMALL_SLAB-8+1));
this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8);
chunks.add(this.freeListManager.allocate(DEFAULT_SLAB_SIZE/2-8));
this.freeListManager.allocate(SMALL_SLAB-8+1);
- for (GemFireChunk c: chunks) {
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ for (ObjectChunk c: chunks) {
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
}
assertThat(this.freeListManager.compact(DEFAULT_SLAB_SIZE/2)).isTrue();
@@ -348,7 +348,7 @@ public class FreeListManagerTest {
@Test
public void compactAfterAllocatingAll() {
setUpSingleSlabManager();
- GemFireChunk c = freeListManager.allocate(DEFAULT_SLAB_SIZE-8);
+ ObjectChunk c = freeListManager.allocate(DEFAULT_SLAB_SIZE-8);
this.freeListManager.firstCompact = false;
assertThat(this.freeListManager.compact(1)).isFalse();
// call compact twice for extra code coverage
@@ -359,46 +359,46 @@ public class FreeListManagerTest {
@Test
public void afterAllocatingAllOneSizeCompactToAllocateDifferentSize() {
setUpSingleSlabManager();
- ArrayList<GemFireChunk> chunksToFree = new ArrayList<>();
- ArrayList<GemFireChunk> chunksToFreeLater = new ArrayList<>();
+ ArrayList<ObjectChunk> chunksToFree = new ArrayList<>();
+ ArrayList<ObjectChunk> chunksToFreeLater = new ArrayList<>();
int ALLOCATE_COUNT = 1000;
- GemFireChunk bigChunk = freeListManager.allocate(DEFAULT_SLAB_SIZE-8-(ALLOCATE_COUNT*32)-256-256);
+ ObjectChunk bigChunk = freeListManager.allocate(DEFAULT_SLAB_SIZE-8-(ALLOCATE_COUNT*32)-256-256);
for (int i=0; i < ALLOCATE_COUNT; i++) {
- GemFireChunk c = freeListManager.allocate(24);
+ ObjectChunk c = freeListManager.allocate(24);
if (i%3 != 2) {
chunksToFree.add(c);
} else {
chunksToFreeLater.add(c);
}
}
- GemFireChunk c1 = freeListManager.allocate(64-8);
- GemFireChunk c2 = freeListManager.allocate(64-8);
- GemFireChunk c3 = freeListManager.allocate(64-8);
- GemFireChunk c4 = freeListManager.allocate(64-8);
+ ObjectChunk c1 = freeListManager.allocate(64-8);
+ ObjectChunk c2 = freeListManager.allocate(64-8);
+ ObjectChunk c3 = freeListManager.allocate(64-8);
+ ObjectChunk c4 = freeListManager.allocate(64-8);
- GemFireChunk mediumChunk1 = freeListManager.allocate(128-8);
- GemFireChunk mediumChunk2 = freeListManager.allocate(128-8);
+ ObjectChunk mediumChunk1 = freeListManager.allocate(128-8);
+ ObjectChunk mediumChunk2 = freeListManager.allocate(128-8);
- GemFireChunk.release(bigChunk.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(bigChunk.getMemoryAddress(), freeListManager);
int s = chunksToFree.size();
for (int i=s/2; i >=0; i--) {
- GemFireChunk c = chunksToFree.get(i);
- GemFireChunk.release(c.getMemoryAddress(), freeListManager);
+ ObjectChunk c = chunksToFree.get(i);
+ ObjectChunk.release(c.getMemoryAddress(), freeListManager);
}
for (int i=(s/2)+1; i < s; i++) {
- GemFireChunk c = chunksToFree.get(i);
- GemFireChunk.release(c.getMemoryAddress(), freeListManager);
+ ObjectChunk c = chunksToFree.get(i);
+ ObjectChunk.release(c.getMemoryAddress(), freeListManager);
}
- GemFireChunk.release(c3.getMemoryAddress(), freeListManager);
- GemFireChunk.release(c1.getMemoryAddress(), freeListManager);
- GemFireChunk.release(c2.getMemoryAddress(), freeListManager);
- GemFireChunk.release(c4.getMemoryAddress(), freeListManager);
- GemFireChunk.release(mediumChunk1.getMemoryAddress(), freeListManager);
- GemFireChunk.release(mediumChunk2.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(c3.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(c1.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(c2.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(c4.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(mediumChunk1.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(mediumChunk2.getMemoryAddress(), freeListManager);
this.freeListManager.firstCompact = false;
assertThat(freeListManager.compact(DEFAULT_SLAB_SIZE-(ALLOCATE_COUNT*32))).isFalse();
for (int i=0; i < ((256*2)/96); i++) {
- GemFireChunk.release(chunksToFreeLater.get(i).getMemoryAddress(), freeListManager);
+ ObjectChunk.release(chunksToFreeLater.get(i).getMemoryAddress(), freeListManager);
}
assertThat(freeListManager.compact(DEFAULT_SLAB_SIZE-(ALLOCATE_COUNT*32))).isTrue();
}
@@ -407,14 +407,14 @@ public class FreeListManagerTest {
public void afterAllocatingAndFreeingCompact() {
int slabSize = 1024*3;
setUpSingleSlabManager(slabSize);
- GemFireChunk bigChunk1 = freeListManager.allocate(slabSize/3-8);
- GemFireChunk bigChunk2 = freeListManager.allocate(slabSize/3-8);
- GemFireChunk bigChunk3 = freeListManager.allocate(slabSize/3-8);
+ ObjectChunk bigChunk1 = freeListManager.allocate(slabSize/3-8);
+ ObjectChunk bigChunk2 = freeListManager.allocate(slabSize/3-8);
+ ObjectChunk bigChunk3 = freeListManager.allocate(slabSize/3-8);
this.freeListManager.firstCompact = false;
assertThat(freeListManager.compact(1)).isFalse();
- GemFireChunk.release(bigChunk3.getMemoryAddress(), freeListManager);
- GemFireChunk.release(bigChunk2.getMemoryAddress(), freeListManager);
- GemFireChunk.release(bigChunk1.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(bigChunk3.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(bigChunk2.getMemoryAddress(), freeListManager);
+ ObjectChunk.release(bigChunk1.getMemoryAddress(), freeListManager);
assertThat(freeListManager.compact(slabSize)).isTrue();
}
@@ -422,8 +422,8 @@ public class FreeListManagerTest {
public void compactWithEmptyTinyFreeList() {
setUpSingleSlabManager();
Fragment originalFragment = this.freeListManager.getFragmentList().get(0);
- GemFireChunk c = freeListManager.allocate(16);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = freeListManager.allocate(16);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
c = freeListManager.allocate(16);
this.freeListManager.firstCompact = false;
assertThat(this.freeListManager.compact(1)).isTrue();
@@ -443,8 +443,8 @@ public class FreeListManagerTest {
new UnsafeMemoryChunk(SMALL_SLAB),
new UnsafeMemoryChunk(MEDIUM_SLAB),
slab});
- this.freeListManager.allocate(DEFAULT_SLAB_SIZE-8-(GemFireChunk.MIN_CHUNK_SIZE-1));
- this.freeListManager.allocate(MEDIUM_SLAB-8-(GemFireChunk.MIN_CHUNK_SIZE-1));
+ this.freeListManager.allocate(DEFAULT_SLAB_SIZE-8-(ObjectChunk.MIN_CHUNK_SIZE-1));
+ this.freeListManager.allocate(MEDIUM_SLAB-8-(ObjectChunk.MIN_CHUNK_SIZE-1));
assertThat(this.freeListManager.compact(SMALL_SLAB)).isTrue();
}
@@ -672,9 +672,9 @@ public class FreeListManagerTest {
UnsafeMemoryChunk chunk = new UnsafeMemoryChunk(96);
long address = chunk.getMemoryAddress();
this.freeListManager = createFreeListManager(ma, new UnsafeMemoryChunk[] {chunk});
- GemFireChunk c = this.freeListManager.allocate(24);
- GemFireChunk c2 = this.freeListManager.allocate(24);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(24);
+ ObjectChunk c2 = this.freeListManager.allocate(24);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
List<MemoryBlock> ob = this.freeListManager.getOrderedBlocks();
assertThat(ob).hasSize(3);
@@ -692,8 +692,8 @@ public class FreeListManagerTest {
public void allocatedBlocksEmptyAfterFree() {
UnsafeMemoryChunk chunk = new UnsafeMemoryChunk(96);
this.freeListManager = createFreeListManager(ma, new UnsafeMemoryChunk[] {chunk});
- GemFireChunk c = this.freeListManager.allocate(24);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(24);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
List<MemoryBlock> ob = this.freeListManager.getAllocatedBlocks();
assertThat(ob).hasSize(0);
}
@@ -702,7 +702,7 @@ public class FreeListManagerTest {
public void allocatedBlocksHasAllocatedChunk() {
UnsafeMemoryChunk chunk = new UnsafeMemoryChunk(96);
this.freeListManager = createFreeListManager(ma, new UnsafeMemoryChunk[] {chunk});
- GemFireChunk c = this.freeListManager.allocate(24);
+ ObjectChunk c = this.freeListManager.allocate(24);
List<MemoryBlock> ob = this.freeListManager.getAllocatedBlocks();
assertThat(ob).hasSize(1);
assertThat(ob.get(0).getMemoryAddress()).isEqualTo(c.getMemoryAddress());
@@ -712,8 +712,8 @@ public class FreeListManagerTest {
public void allocatedBlocksHasBothAllocatedChunks() {
UnsafeMemoryChunk chunk = new UnsafeMemoryChunk(96);
this.freeListManager = createFreeListManager(ma, new UnsafeMemoryChunk[] {chunk});
- GemFireChunk c = this.freeListManager.allocate(24);
- GemFireChunk c2 = this.freeListManager.allocate(33);
+ ObjectChunk c = this.freeListManager.allocate(24);
+ ObjectChunk c2 = this.freeListManager.allocate(33);
List<MemoryBlock> ob = this.freeListManager.getAllocatedBlocks();
assertThat(ob).hasSize(2);
}
@@ -731,10 +731,10 @@ public class FreeListManagerTest {
UnsafeMemoryChunk chunk = new UnsafeMemoryChunk(32);
UnsafeMemoryChunk chunk2 = new UnsafeMemoryChunk(1024*1024*5);
this.freeListManager = createFreeListManager(ma, new UnsafeMemoryChunk[] {chunk, chunk2});
- GemFireChunk c = this.freeListManager.allocate(24);
- GemFireChunk c2 = this.freeListManager.allocate(1024*1024);
- GemFireChunk.release(c.getMemoryAddress(), this.freeListManager);
- GemFireChunk.release(c2.getMemoryAddress(), this.freeListManager);
+ ObjectChunk c = this.freeListManager.allocate(24);
+ ObjectChunk c2 = this.freeListManager.allocate(1024*1024);
+ ObjectChunk.release(c.getMemoryAddress(), this.freeListManager);
+ ObjectChunk.release(c2.getMemoryAddress(), this.freeListManager);
LogWriter lw = mock(LogWriter.class);
this.freeListManager.logOffHeapState(lw, 1024);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListOffHeapRegionJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListOffHeapRegionJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListOffHeapRegionJUnitTest.java
index edbe235..6790f6a 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListOffHeapRegionJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/FreeListOffHeapRegionJUnitTest.java
@@ -40,7 +40,7 @@ public class FreeListOffHeapRegionJUnitTest extends OffHeapRegionBase {
@Override
public int perObjectOverhead() {
- return GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ return ObjectChunk.OFF_HEAP_HEADER_SIZE;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkJUnitTest.java
index 23445cf..7f4b27f 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkJUnitTest.java
@@ -98,7 +98,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
}
@Override
- public GemFireChunk createValueAsUnserializedStoredObject(Object value) {
+ public ObjectChunk createValueAsUnserializedStoredObject(Object value) {
byte[] valueInByteArray;
if (value instanceof Long) {
valueInByteArray = convertValueToByteArray(value);
@@ -113,7 +113,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
}
@Override
- public GemFireChunk createValueAsSerializedStoredObject(Object value) {
+ public ObjectChunk createValueAsSerializedStoredObject(Object value) {
byte[] valueInSerializedByteArray = EntryEventImpl.serialize(value);
boolean isSerialized = true;
@@ -122,16 +122,16 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
return createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
}
- private GemFireChunk createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
+ private ObjectChunk createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
return chunk;
}
@Test
public void chunkCanBeCreatedFromAnotherChunk() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
- GemFireChunk newChunk = new GemFireChunk(chunk);
+ ObjectChunk newChunk = new ObjectChunk(chunk);
assertNotNull(newChunk);
assertThat(newChunk.getMemoryAddress()).isEqualTo(chunk.getMemoryAddress());
@@ -141,9 +141,9 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void chunkCanBeCreatedWithOnlyMemoryAddress() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
- GemFireChunk newChunk = new GemFireChunk(chunk.getMemoryAddress());
+ ObjectChunk newChunk = new ObjectChunk(chunk.getMemoryAddress());
assertNotNull(newChunk);
assertThat(newChunk.getMemoryAddress()).isEqualTo(chunk.getMemoryAddress());
@@ -153,15 +153,15 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void chunkSliceCanBeCreatedFromAnotherChunk() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
int position = 1;
int end = 2;
- GemFireChunk newChunk = (GemFireChunk) chunk.slice(position, end);
+ ObjectChunk newChunk = (ObjectChunk) chunk.slice(position, end);
assertNotNull(newChunk);
- assertThat(newChunk.getClass()).isEqualTo(GemFireChunkSlice.class);
+ assertThat(newChunk.getClass()).isEqualTo(ObjectChunkSlice.class);
assertThat(newChunk.getMemoryAddress()).isEqualTo(chunk.getMemoryAddress());
chunk.release();
@@ -169,7 +169,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void fillSerializedValueShouldFillWrapperWithSerializedValueIfValueIsSerialized() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
// mock the things
BytesAndBitsForCompactor wrapper = mock(BytesAndBitsForCompactor.class);
@@ -185,7 +185,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void fillSerializedValueShouldFillWrapperWithDeserializedValueIfValueIsNotSerialized() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
// mock the things
BytesAndBitsForCompactor wrapper = mock(BytesAndBitsForCompactor.class);
@@ -200,7 +200,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getShortClassNameShouldReturnShortClassName() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getShortClassName()).isEqualTo("GemFireChunk");
chunk.release();
@@ -208,12 +208,12 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void chunksAreEqualsOnlyByAddress() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
- GemFireChunk newChunk = new GemFireChunk(chunk.getMemoryAddress());
+ ObjectChunk newChunk = new ObjectChunk(chunk.getMemoryAddress());
assertThat(chunk.equals(newChunk)).isTrue();
- GemFireChunk chunkWithSameValue = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunkWithSameValue = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.equals(chunkWithSameValue)).isFalse();
Object someObject = getValue();
@@ -225,16 +225,16 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void chunksShouldBeComparedBySize() {
- GemFireChunk chunk1 = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk1 = createValueAsSerializedStoredObject(getValue());
- GemFireChunk chunk2 = chunk1;
+ ObjectChunk chunk2 = chunk1;
assertThat(chunk1.compareTo(chunk2)).isEqualTo(0);
- GemFireChunk chunkWithSameValue = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunkWithSameValue = createValueAsSerializedStoredObject(getValue());
assertThat(chunk1.compareTo(chunkWithSameValue)).isEqualTo(Long.signum(chunk1.getMemoryAddress() - chunkWithSameValue.getMemoryAddress()));
- GemFireChunk chunk3 = createValueAsSerializedStoredObject(Long.MAX_VALUE);
- GemFireChunk chunk4 = createValueAsSerializedStoredObject(Long.MAX_VALUE);
+ ObjectChunk chunk3 = createValueAsSerializedStoredObject(Long.MAX_VALUE);
+ ObjectChunk chunk4 = createValueAsSerializedStoredObject(Long.MAX_VALUE);
int newSizeForChunk3 = 2;
int newSizeForChunk4 = 3;
@@ -253,9 +253,9 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = false;
boolean isCompressed = false;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
- int headerBeforeSerializedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + GemFireChunk.REF_COUNT_OFFSET);
+ int headerBeforeSerializedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + ObjectChunk.REF_COUNT_OFFSET);
assertThat(chunk.isSerialized()).isFalse();
@@ -263,16 +263,16 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
assertThat(chunk.isSerialized()).isTrue();
- int headerAfterSerializedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + GemFireChunk.REF_COUNT_OFFSET);
+ int headerAfterSerializedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + ObjectChunk.REF_COUNT_OFFSET);
- assertThat(headerAfterSerializedBitSet).isEqualTo(headerBeforeSerializedBitSet | GemFireChunk.IS_SERIALIZED_BIT);
+ assertThat(headerAfterSerializedBitSet).isEqualTo(headerBeforeSerializedBitSet | ObjectChunk.IS_SERIALIZED_BIT);
chunk.release();
}
@Test(expected = IllegalStateException.class)
public void setSerialziedShouldThrowExceptionIfChunkIsAlreadyReleased() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
chunk.setSerialized(true);
@@ -287,9 +287,9 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = false;
boolean isCompressed = false;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
- int headerBeforeCompressedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + GemFireChunk.REF_COUNT_OFFSET);
+ int headerBeforeCompressedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + ObjectChunk.REF_COUNT_OFFSET);
assertThat(chunk.isCompressed()).isFalse();
@@ -297,16 +297,16 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
assertThat(chunk.isCompressed()).isTrue();
- int headerAfterCompressedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + GemFireChunk.REF_COUNT_OFFSET);
+ int headerAfterCompressedBitSet = UnsafeMemoryChunk.readAbsoluteIntVolatile(chunk.getMemoryAddress() + ObjectChunk.REF_COUNT_OFFSET);
- assertThat(headerAfterCompressedBitSet).isEqualTo(headerBeforeCompressedBitSet | GemFireChunk.IS_COMPRESSED_BIT);
+ assertThat(headerAfterCompressedBitSet).isEqualTo(headerBeforeCompressedBitSet | ObjectChunk.IS_COMPRESSED_BIT);
chunk.release();
}
@Test(expected = IllegalStateException.class)
public void setCompressedShouldThrowExceptionIfChunkIsAlreadyReleased() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
chunk.setCompressed(true);
@@ -315,7 +315,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void setDataSizeShouldSetTheDataSizeBits() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
int beforeSize = chunk.getDataSize();
@@ -331,7 +331,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void setDataSizeShouldThrowExceptionIfChunkIsAlreadyReleased() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
chunk.setDataSize(1);
@@ -340,7 +340,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void initializeUseCountShouldThrowIllegalStateExceptionIfChunkIsAlreadyRetained() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.retain();
chunk.initializeUseCount();
@@ -349,7 +349,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void initializeUseCountShouldThrowIllegalStateExceptionIfChunkIsAlreadyReleased() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
chunk.initializeUseCount();
@@ -358,7 +358,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void isSerializedPdxInstanceShouldReturnTrueIfItsPDXInstance() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
byte[] serailizedValue = chunk.getSerializedValue();
serailizedValue[0] = DSCODE.PDX;
@@ -383,7 +383,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void isSerializedPdxInstanceShouldReturnFalseIfItsNotPDXInstance() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
assertThat(chunk.isSerializedPdxInstance()).isFalse();
chunk.release();
@@ -391,22 +391,22 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void checkDataEqualsByChunk() {
- GemFireChunk chunk1 = createValueAsSerializedStoredObject(getValue());
- GemFireChunk sameAsChunk1 = chunk1;
+ ObjectChunk chunk1 = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk sameAsChunk1 = chunk1;
assertThat(chunk1.checkDataEquals(sameAsChunk1)).isTrue();
- GemFireChunk unserializedChunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk unserializedChunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk1.checkDataEquals(unserializedChunk)).isFalse();
- GemFireChunk chunkDifferBySize = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunkDifferBySize = createValueAsSerializedStoredObject(getValue());
chunkDifferBySize.setSize(0);
assertThat(chunk1.checkDataEquals(chunkDifferBySize)).isFalse();
- GemFireChunk chunkDifferByValue = createValueAsSerializedStoredObject(Long.MAX_VALUE - 1);
+ ObjectChunk chunkDifferByValue = createValueAsSerializedStoredObject(Long.MAX_VALUE - 1);
assertThat(chunk1.checkDataEquals(chunkDifferByValue)).isFalse();
- GemFireChunk newChunk1 = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk newChunk1 = createValueAsSerializedStoredObject(getValue());
assertThat(chunk1.checkDataEquals(newChunk1)).isTrue();
chunk1.release();
@@ -418,13 +418,13 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void checkDataEqualsBySerializedValue() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
assertThat(chunk.checkDataEquals(new byte[1])).isFalse();
- GemFireChunk chunkDifferByValue = createValueAsSerializedStoredObject(Long.MAX_VALUE - 1);
+ ObjectChunk chunkDifferByValue = createValueAsSerializedStoredObject(Long.MAX_VALUE - 1);
assertThat(chunk.checkDataEquals(chunkDifferByValue.getSerializedValue())).isFalse();
- GemFireChunk newChunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk newChunk = createValueAsSerializedStoredObject(getValue());
assertThat(chunk.checkDataEquals(newChunk.getSerializedValue())).isTrue();
chunk.release();
@@ -440,7 +440,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = true;
boolean isCompressed = true;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
RegionEntryContext regionContext = mock(RegionEntryContext.class);
CachePerfStats cacheStats = mock(CachePerfStats.class);
@@ -469,7 +469,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void incSizeShouldIncrementSize() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
int beforeSize = chunk.getSize();
@@ -484,7 +484,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void readyForFreeShouldResetTheRefCount() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
int refCountBeforeFreeing = chunk.getRefCount();
assertThat(refCountBeforeFreeing).isEqualTo(1);
@@ -497,7 +497,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void readyForAllocationShouldThrowExceptionIfAlreadyAllocated() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
// chunk is already allocated when we created it, so calling readyForAllocation should throw exception.
chunk.readyForAllocation();
@@ -507,7 +507,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void checkIsAllocatedShouldReturnIfAllocated() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.checkIsAllocated();
chunk.release();
@@ -515,7 +515,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void checkIsAllocatedShouldThrowExceptionIfNotAllocated() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.release();
chunk.checkIsAllocated();
@@ -524,8 +524,8 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void sendToShouldWriteSerializedValueToDataOutputIfValueIsSerialized() throws IOException {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
- GemFireChunk spyChunk = spy(chunk);
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk spyChunk = spy(chunk);
HeapDataOutputStream dataOutput = mock(HeapDataOutputStream.class);
ByteBuffer directByteBuffer = ByteBuffer.allocate(1024);
@@ -543,7 +543,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void sendToShouldWriteUnserializedValueToDataOutputIfValueIsUnserialized() throws IOException {
byte[] regionEntryValue = getValueAsByteArray();
- GemFireChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
// writeByte is a final method and cannot be mocked, so creating a real one
HeapDataOutputStream dataOutput = new HeapDataOutputStream(Version.CURRENT);
@@ -566,7 +566,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void sendAsByteArrayShouldWriteValueToDataOutput() throws IOException {
byte[] regionEntryValue = getValueAsByteArray();
- GemFireChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
// writeByte is a final method and cannot be mocked, so creating a real one
HeapDataOutputStream dataOutput = new HeapDataOutputStream(Version.CURRENT);
@@ -589,7 +589,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
public void createDirectByteBufferShouldCreateAByteBuffer() {
byte[] regionEntryValue = getValueAsByteArray();
- GemFireChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
ByteBuffer buffer = chunk.createDirectByteBuffer();
@@ -604,20 +604,20 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getDirectByteBufferShouldCreateAByteBuffer() {
byte[] regionEntryValue = getValueAsByteArray();
- GemFireChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(regionEntryValue);
ByteBuffer buffer = chunk.createDirectByteBuffer();
- long bufferAddress = GemFireChunk.getDirectByteBufferAddress(buffer);
+ long bufferAddress = ObjectChunk.getDirectByteBufferAddress(buffer);
// returned address should be starting of the value (after skipping HEADER_SIZE bytes)
- assertEquals(chunk.getMemoryAddress() + GemFireChunk.OFF_HEAP_HEADER_SIZE, bufferAddress);
+ assertEquals(chunk.getMemoryAddress() + ObjectChunk.OFF_HEAP_HEADER_SIZE, bufferAddress);
chunk.release();
}
@Test(expected = AssertionError.class)
public void getAddressForReadingShouldFailIfItsOutsideOfChunk() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.getAddressForReading(0, chunk.getDataSize() + 1);
chunk.release();
@@ -625,7 +625,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getAddressForReadingShouldReturnDataAddressFromGivenOffset() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
int offset = 1;
long requestedAddress = chunk.getAddressForReading(offset, 1);
@@ -637,7 +637,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getSizeInBytesShouldReturnSize() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
assertThat(chunk.getSizeInBytes()).isEqualTo(chunk.getSize());
chunk.release();
@@ -645,7 +645,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = AssertionError.class)
public void getUnsafeAddressShouldFailIfOffsetIsNegative() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.getUnsafeAddress(-1, 1);
chunk.release();
@@ -653,7 +653,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = AssertionError.class)
public void getUnsafeAddressShouldFailIfSizeIsNegative() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.getUnsafeAddress(1, -1);
chunk.release();
@@ -661,7 +661,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = AssertionError.class)
public void getUnsafeAddressShouldFailIfItsOutsideOfChunk() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.getUnsafeAddress(0, chunk.getDataSize() + 1);
chunk.release();
@@ -669,7 +669,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getUnsafeAddressShouldReturnUnsafeAddress() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
int offset = 1;
long unsafeAddress = chunk.getUnsafeAddress(offset, 1);
@@ -681,7 +681,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = AssertionError.class)
public void readByteAndWriteByteShouldFailIfOffsetIsOutside() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
chunk.readByte(chunk.getDataSize() + 1);
@@ -692,7 +692,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void writeByteShouldWriteAtCorrectLocation() {
- GemFireChunk chunk = createValueAsSerializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsSerializedStoredObject(getValue());
byte valueBeforeWrite = chunk.readByte(2);
@@ -709,7 +709,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void retainShouldIncrementRefCount() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getRefCount()).isEqualTo(1);
chunk.retain();
@@ -728,10 +728,10 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void retainShouldThrowExceptionAfterMaxNumberOfTimesRetained() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
// loop though and invoke retain for MAX_REF_COUNT-1 times, as create chunk above counted as one reference
- for (int i = 0; i < GemFireChunk.MAX_REF_COUNT - 1; i++)
+ for (int i = 0; i < ObjectChunk.MAX_REF_COUNT - 1; i++)
chunk.retain();
// invoke for the one more time should throw exception
@@ -740,7 +740,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void releaseShouldDecrementRefCount() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getRefCount()).isEqualTo(1);
chunk.retain();
@@ -763,20 +763,20 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = IllegalStateException.class)
public void releaseShouldThrowExceptionIfChunkIsAlreadyReleased() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
chunk.release();
}
@Test
public void testToStringForOffHeapByteSource() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
String expected = ":<dataSize=" + chunk.getDataSize() + " refCount=" + chunk.getRefCount() + " addr=" + Long.toHexString(chunk.getMemoryAddress()) + ">";
assertThat(chunk.toStringForOffHeapByteSource()).endsWith(expected);
// test toString
- GemFireChunk spy = spy(chunk);
+ ObjectChunk spy = spy(chunk);
spy.toString();
verify(spy, times(1)).toStringForOffHeapByteSource();
@@ -785,7 +785,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getStateShouldReturnAllocatedIfRefCountIsGreaterThanZero() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertEquals(State.ALLOCATED, chunk.getState());
chunk.release();
@@ -793,14 +793,14 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getStateShouldReturnDeallocatedIfRefCountIsZero() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.release();
assertEquals(State.DEALLOCATED, chunk.getState());
}
@Test(expected = UnsupportedOperationException.class)
public void getNextBlockShouldThrowUnSupportedOperationException() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.getNextBlock();
chunk.release();
@@ -808,7 +808,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getBlockSizeShouldBeSameSameGetSize() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertEquals(chunk.getSize(), chunk.getBlockSize());
chunk.release();
@@ -816,7 +816,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = UnsupportedOperationException.class)
public void copyBytesShouldThrowUnSupportedOperationException() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.copyBytes(1, 2, 1);
chunk.release();
@@ -824,7 +824,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test(expected = UnsupportedOperationException.class)
public void getSlabIdShouldThrowUnSupportedOperationException() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
chunk.getSlabId();
chunk.release();
@@ -832,7 +832,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getFreeListIdShouldReturnMinusOne() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getFreeListId()).isEqualTo(-1);
chunk.release();
@@ -840,7 +840,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getDataTypeShouldReturnNull() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getDataType()).isNull();
chunk.release();
@@ -848,7 +848,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
@Test
public void getDataDataShouldReturnNull() {
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
assertThat(chunk.getDataValue()).isNull();
}
@@ -860,7 +860,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = true;
boolean isCompressed = true;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
chunk.getRawBytes();
@@ -875,7 +875,7 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = false;
boolean isCompressed = false;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(regionEntryValueAsBytes, isSerialized, isCompressed);
byte[] serializedValue = chunk.getSerializedValue();
@@ -889,10 +889,10 @@ public class GemFireChunkJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = false;
boolean isCompressed = false;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(new byte[100], isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(new byte[100], isSerialized, isCompressed);
// first fill the unused part with FILL_PATTERN
- GemFireChunk.fill(chunk.getMemoryAddress());
+ ObjectChunk.fill(chunk.getMemoryAddress());
// Validate that it is filled
chunk.validateFill();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkSliceJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkSliceJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkSliceJUnitTest.java
index 39ee620..60a7f9e 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkSliceJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/GemFireChunkSliceJUnitTest.java
@@ -33,11 +33,11 @@ public class GemFireChunkSliceJUnitTest extends GemFireChunkJUnitTest {
int position = 1;
int end = 2;
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
- GemFireChunkSlice slice = (GemFireChunkSlice) chunk.slice(position, end);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunkSlice slice = (ObjectChunkSlice) chunk.slice(position, end);
assertNotNull(slice);
- assertEquals(GemFireChunkSlice.class, slice.getClass());
+ assertEquals(ObjectChunkSlice.class, slice.getClass());
assertEquals(end - position, slice.getDataSize());
}
@@ -47,11 +47,11 @@ public class GemFireChunkSliceJUnitTest extends GemFireChunkJUnitTest {
int position = 1;
int end = 2;
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
- GemFireChunkSlice slice = (GemFireChunkSlice) chunk.slice(position, end);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunkSlice slice = (ObjectChunkSlice) chunk.slice(position, end);
assertNotNull(slice);
- assertEquals(GemFireChunkSlice.class, slice.getClass());
+ assertEquals(ObjectChunkSlice.class, slice.getClass());
assertEquals(chunk.getBaseDataAddress() + position, slice.getBaseDataAddress());
}
@@ -61,11 +61,11 @@ public class GemFireChunkSliceJUnitTest extends GemFireChunkJUnitTest {
int position = 1;
int end = 2;
- GemFireChunk chunk = createValueAsUnserializedStoredObject(getValue());
- GemFireChunkSlice slice = (GemFireChunkSlice) chunk.slice(position, end);
+ ObjectChunk chunk = createValueAsUnserializedStoredObject(getValue());
+ ObjectChunkSlice slice = (ObjectChunkSlice) chunk.slice(position, end);
assertNotNull(slice);
- assertEquals(GemFireChunkSlice.class, slice.getClass());
+ assertEquals(ObjectChunkSlice.class, slice.getClass());
assertEquals(chunk.getBaseDataOffset() + position, slice.getBaseDataOffset());
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
index 6c037e1..b1e3af0 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
@@ -128,8 +128,8 @@ public class OffHeapHelperJUnitTest extends AbstractStoredObjectTestBase {
return createdObject;
}
- private GemFireChunk createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
+ private ObjectChunk createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
return chunk;
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
index 78143d5..8de0406 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
@@ -540,11 +540,11 @@ public abstract class OffHeapRegionBase {
@Released(OffHeapIdentifier.TEST_OFF_HEAP_REGION_BASE_LISTENER)
@Override
public void close() {
- if (this.ohOldValue instanceof GemFireChunk) {
- ((GemFireChunk)this.ohOldValue).release();
+ if (this.ohOldValue instanceof ObjectChunk) {
+ ((ObjectChunk)this.ohOldValue).release();
}
- if (this.ohNewValue instanceof GemFireChunk) {
- ((GemFireChunk)this.ohNewValue).release();
+ if (this.ohNewValue instanceof ObjectChunk) {
+ ((ObjectChunk)this.ohNewValue).release();
}
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelperJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelperJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelperJUnitTest.java
index a611aa5..5d53109 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelperJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelperJUnitTest.java
@@ -54,7 +54,7 @@ import com.gemstone.gemfire.test.junit.categories.UnitTest;
@Category(UnitTest.class)
@RunWith(PowerMockRunner.class)
@PowerMockIgnore("*.UnitTest")
-@PrepareForTest({ GemFireChunk.class, OffHeapRegionEntryHelper.class })
+@PrepareForTest({ ObjectChunk.class, OffHeapRegionEntryHelper.class })
public class OffHeapRegionEntryHelperJUnitTest {
private static final Long VALUE_IS_NOT_ENCODABLE = 0L;
@@ -75,13 +75,13 @@ public class OffHeapRegionEntryHelperJUnitTest {
SimpleMemoryAllocatorImpl.freeOffHeapMemory();
}
- private GemFireChunk createChunk(Object value) {
+ private ObjectChunk createChunk(Object value) {
byte[] v = EntryEventImpl.serialize(value);
boolean isSerialized = true;
boolean isCompressed = false;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(v, isSerialized, isCompressed);
return chunk;
}
@@ -294,7 +294,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
@Test
public void isOffHeapShouldReturnTrueIfAddressIsOnOffHeap() {
- GemFireChunk value = createChunk(Long.MAX_VALUE);
+ ObjectChunk value = createChunk(Long.MAX_VALUE);
assertThat(OffHeapRegionEntryHelper.isOffHeap(value.getMemoryAddress())).isTrue();
}
@@ -327,7 +327,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
long oldAddress = 1L;
// testing when the newValue is a chunk
- GemFireChunk newValue = createChunk(Long.MAX_VALUE);
+ ObjectChunk newValue = createChunk(Long.MAX_VALUE);
// mock region entry methods required for test
when(re.getAddress()).thenReturn(oldAddress);
when(re.setAddress(oldAddress, newValue.getMemoryAddress())).thenReturn(Boolean.TRUE);
@@ -440,13 +440,13 @@ public class OffHeapRegionEntryHelperJUnitTest {
// mock region entry
OffHeapRegionEntry re = mock(OffHeapRegionEntry.class);
- GemFireChunk oldValue = createChunk(Long.MAX_VALUE);
- GemFireChunk newValue = createChunk(Long.MAX_VALUE - 1);
+ ObjectChunk oldValue = createChunk(Long.MAX_VALUE);
+ ObjectChunk newValue = createChunk(Long.MAX_VALUE - 1);
// mock Chunk static methods - in-order to verify that release is called
- PowerMockito.spy(GemFireChunk.class);
- PowerMockito.doNothing().when(GemFireChunk.class);
- GemFireChunk.release(oldValue.getMemoryAddress());
+ PowerMockito.spy(ObjectChunk.class);
+ PowerMockito.doNothing().when(ObjectChunk.class);
+ ObjectChunk.release(oldValue.getMemoryAddress());
// mock region entry methods required for test
when(re.getAddress()).thenReturn(oldValue.getMemoryAddress());
@@ -460,7 +460,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
// verify oldAddress is released
PowerMockito.verifyStatic();
- GemFireChunk.release(oldValue.getMemoryAddress());
+ ObjectChunk.release(oldValue.getMemoryAddress());
}
@Test
@@ -475,9 +475,9 @@ public class OffHeapRegionEntryHelperJUnitTest {
DataAsAddress newAddress = new DataAsAddress(OffHeapRegionEntryHelper.encodeDataAsAddress(newData, false, false));
// mock Chunk static methods - in-order to verify that release is never called
- PowerMockito.spy(GemFireChunk.class);
- PowerMockito.doNothing().when(GemFireChunk.class);
- GemFireChunk.release(oldAddress);
+ PowerMockito.spy(ObjectChunk.class);
+ PowerMockito.doNothing().when(ObjectChunk.class);
+ ObjectChunk.release(oldAddress);
// mock region entry methods required for test
when(re.getAddress()).thenReturn(oldAddress);
@@ -491,7 +491,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
// verify that release is never called as the old address is not on offheap
PowerMockito.verifyStatic(never());
- GemFireChunk.release(oldAddress);
+ ObjectChunk.release(oldAddress);
}
@Test
@@ -505,9 +505,9 @@ public class OffHeapRegionEntryHelperJUnitTest {
long newAddress = OffHeapRegionEntryHelper.REMOVED_PHASE2_ADDRESS;
// mock Chunk static methods - in-order to verify that release is never called
- PowerMockito.spy(GemFireChunk.class);
- PowerMockito.doNothing().when(GemFireChunk.class);
- GemFireChunk.release(oldAddress);
+ PowerMockito.spy(ObjectChunk.class);
+ PowerMockito.doNothing().when(ObjectChunk.class);
+ ObjectChunk.release(oldAddress);
// mock region entry methods required for test
when(re.getAddress()).thenReturn(oldAddress);
@@ -521,7 +521,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
// verify that release is never called as the old address is not on offheap
PowerMockito.verifyStatic(never());
- GemFireChunk.release(oldAddress);
+ ObjectChunk.release(oldAddress);
}
@Test(expected = IllegalStateException.class)
@@ -541,7 +541,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
// mock region entry
OffHeapRegionEntry re = mock(OffHeapRegionEntry.class);
- GemFireChunk chunk = createChunk(Long.MAX_VALUE);
+ ObjectChunk chunk = createChunk(Long.MAX_VALUE);
// mock region entry methods required for test
when(re.getAddress()).thenReturn(chunk.getMemoryAddress());
@@ -627,10 +627,10 @@ public class OffHeapRegionEntryHelperJUnitTest {
@Test
public void addressToObjectShouldReturnValueFromChunk() {
- GemFireChunk expected = createChunk(Long.MAX_VALUE);
+ ObjectChunk expected = createChunk(Long.MAX_VALUE);
Object actual = OffHeapRegionEntryHelper.addressToObject(expected.getMemoryAddress(), false, null);
- assertThat(actual).isInstanceOf(GemFireChunk.class);
+ assertThat(actual).isInstanceOf(ObjectChunk.class);
assertThat(actual).isEqualTo(expected);
}
@@ -640,7 +640,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
boolean isSerialized = true;
boolean isCompressed = true;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(data, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(data, isSerialized, isCompressed);
// create the mock context
RegionEntryContext regionContext = mock(RegionEntryContext.class);
@@ -669,7 +669,7 @@ public class OffHeapRegionEntryHelperJUnitTest {
boolean isSerialized = false;
boolean isCompressed = true;
- GemFireChunk chunk = (GemFireChunk) ma.allocateAndInitialize(data, isSerialized, isCompressed);
+ ObjectChunk chunk = (ObjectChunk) ma.allocateAndInitialize(data, isSerialized, isCompressed);
// create the mock context
RegionEntryContext regionContext = mock(RegionEntryContext.class);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapValidationJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapValidationJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapValidationJUnitTest.java
index 2379c2d..630ae22 100755
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapValidationJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapValidationJUnitTest.java
@@ -296,8 +296,8 @@ public class OffHeapValidationJUnitTest {
private long getMemoryAddress(Region region, String key) {
Object entry = ((LocalRegion) region).getRegionEntry(key)._getValue();
- assertTrue(entry instanceof GemFireChunk);
- long memoryAddress = ((GemFireChunk)entry).getMemoryAddress();
+ assertTrue(entry instanceof ObjectChunk);
+ long memoryAddress = ((ObjectChunk)entry).getMemoryAddress();
assertTrue(memoryAddress > 0);
return memoryAddress;
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapWriteObjectAsByteArrayJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapWriteObjectAsByteArrayJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapWriteObjectAsByteArrayJUnitTest.java
index c0fc0b3..9c83f5b 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapWriteObjectAsByteArrayJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapWriteObjectAsByteArrayJUnitTest.java
@@ -64,7 +64,7 @@ public class OffHeapWriteObjectAsByteArrayJUnitTest {
public void testByteArrayChunk() throws IOException, ClassNotFoundException {
byte[] expected = new byte[] {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16};
StoredObject so = createStoredObject(expected, false, false);
- assertTrue(so instanceof GemFireChunk);
+ assertTrue(so instanceof ObjectChunk);
HeapDataOutputStream hdos = new HeapDataOutputStream(new byte[1024]);
DataSerializer.writeObjectAsByteArray(so, hdos);
DataInputStream in = createInput(hdos);
@@ -88,7 +88,7 @@ public class OffHeapWriteObjectAsByteArrayJUnitTest {
public void testStringChunk() throws IOException, ClassNotFoundException {
byte[] expected = EntryEventImpl.serialize("1234567890");
StoredObject so = createStoredObject(expected, true, false);
- assertTrue(so instanceof GemFireChunk);
+ assertTrue(so instanceof ObjectChunk);
HeapDataOutputStream hdos = new HeapDataOutputStream(new byte[1024]);
DataSerializer.writeObjectAsByteArray(so, hdos);
DataInputStream in = createInput(hdos);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OldFreeListOffHeapRegionJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OldFreeListOffHeapRegionJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OldFreeListOffHeapRegionJUnitTest.java
index 104aba8..d8c35b8 100755
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OldFreeListOffHeapRegionJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/OldFreeListOffHeapRegionJUnitTest.java
@@ -41,7 +41,7 @@ public class OldFreeListOffHeapRegionJUnitTest extends OffHeapRegionBase {
@Override
public int perObjectOverhead() {
- return GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ return ObjectChunk.OFF_HEAP_HEADER_SIZE;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternIntegrationTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternIntegrationTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternIntegrationTest.java
index 9f49da1..51f46a1 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternIntegrationTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternIntegrationTest.java
@@ -163,7 +163,7 @@ public class SimpleMemoryAllocatorFillPatternIntegrationTest {
private int totalAllocation = 0;
// List of Chunks allocated by this thread
- private List<GemFireChunk> chunks = new LinkedList<GemFireChunk>();
+ private List<ObjectChunk> chunks = new LinkedList<ObjectChunk>();
// Time to end thread execution
private long endTime = System.currentTimeMillis() + RUN_TIME_IN_MILLIS;
@@ -173,7 +173,7 @@ public class SimpleMemoryAllocatorFillPatternIntegrationTest {
*/
private void allocate() {
int allocation = chunkSizer.allocationSize();
- GemFireChunk chunk = (GemFireChunk) allocator.allocate(allocation);
+ ObjectChunk chunk = (ObjectChunk) allocator.allocate(allocation);
// This should always work just after allocation
chunk.validateFill();
@@ -186,7 +186,7 @@ public class SimpleMemoryAllocatorFillPatternIntegrationTest {
* Frees a random chunk from the Chunk list.
*/
private void free() {
- GemFireChunk chunk = chunks.remove(random.nextInt(chunks.size()));
+ ObjectChunk chunk = chunks.remove(random.nextInt(chunks.size()));
totalAllocation -= chunk.getSize();
/*
@@ -200,7 +200,7 @@ public class SimpleMemoryAllocatorFillPatternIntegrationTest {
* Writes canned data to a random Chunk from the Chunk list.
*/
private void write() {
- GemFireChunk chunk = chunks.get(random.nextInt(chunks.size()));
+ ObjectChunk chunk = chunks.get(random.nextInt(chunks.size()));
chunk.writeBytes(0, WRITE_BYTES);
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternJUnitTest.java
index a03cf57..7c26f86 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorFillPatternJUnitTest.java
@@ -101,7 +101,7 @@ public class SimpleMemoryAllocatorFillPatternJUnitTest {
* Pull a chunk off the fragment. This will have no fill because
* it is a "fresh" chunk.
*/
- GemFireChunk chunk = (GemFireChunk) this.allocator.allocate(chunkSize);
+ ObjectChunk chunk = (ObjectChunk) this.allocator.allocate(chunkSize);
/*
* Chunk should have valid fill from initial fragment allocation.
@@ -109,7 +109,7 @@ public class SimpleMemoryAllocatorFillPatternJUnitTest {
chunk.validateFill();
// "Dirty" the chunk so the release has something to fill over
- chunk.writeBytes(GemFireChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
+ chunk.writeBytes(ObjectChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
// This should free the Chunk (ref count == 1)
chunk.release();
@@ -118,20 +118,20 @@ public class SimpleMemoryAllocatorFillPatternJUnitTest {
* This chunk should have a fill because it was reused from the
* free list (assuming no fragmentation at this point...)
*/
- chunk = (GemFireChunk) this.allocator.allocate(chunkSize);
+ chunk = (ObjectChunk) this.allocator.allocate(chunkSize);
// Make sure we have a fill this time
chunk.validateFill();
// Give the fill code something to write over during the release
- chunk.writeBytes(GemFireChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
+ chunk.writeBytes(ObjectChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
chunk.release();
// Again, make sure the release implemented the fill
chunk.validateFill();
// "Dirty up" the free chunk
- chunk.writeBytes(GemFireChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
+ chunk.writeBytes(ObjectChunk.MIN_CHUNK_SIZE + 1, WRITE_BYTES);
catchException(chunk).validateFill();
assertTrue(caughtException() instanceof IllegalStateException);
@@ -149,14 +149,14 @@ public class SimpleMemoryAllocatorFillPatternJUnitTest {
/*
* Stores our allocated memory.
*/
- GemFireChunk[] allocatedChunks = new GemFireChunk[COMPACTION_CHUNKS];
+ ObjectChunk[] allocatedChunks = new ObjectChunk[COMPACTION_CHUNKS];
/*
* Use up most of our memory
* Our memory looks like [ ][ ][ ]
*/
for(int i =0;i < allocatedChunks.length;++i) {
- allocatedChunks[i] = (GemFireChunk) this.allocator.allocate(COMPACTION_CHUNK_SIZE);
+ allocatedChunks[i] = (ObjectChunk) this.allocator.allocate(COMPACTION_CHUNK_SIZE);
allocatedChunks[i].validateFill();
}
@@ -173,7 +173,7 @@ public class SimpleMemoryAllocatorFillPatternJUnitTest {
* our initial chunks. This should force a compaction causing our
* memory to look like [ ][ ].
*/
- GemFireChunk slightlyLargerChunk = (GemFireChunk) this.allocator.allocate(FORCE_COMPACTION_CHUNK_SIZE);
+ ObjectChunk slightlyLargerChunk = (ObjectChunk) this.allocator.allocate(FORCE_COMPACTION_CHUNK_SIZE);
/*
* Make sure the compacted memory has the fill validation.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
index 12c0e6d..1f17f9b 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
@@ -191,7 +191,7 @@ public class SimpleMemoryAllocatorJUnitTest {
int BATCH_SIZE = 1;
int TINY_MULTIPLE = com.gemstone.gemfire.internal.offheap.FreeListManager.TINY_MULTIPLE;
int HUGE_MULTIPLE = com.gemstone.gemfire.internal.offheap.FreeListManager.HUGE_MULTIPLE;
- int perObjectOverhead = com.gemstone.gemfire.internal.offheap.GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ int perObjectOverhead = com.gemstone.gemfire.internal.offheap.ObjectChunk.OFF_HEAP_HEADER_SIZE;
int maxTiny = com.gemstone.gemfire.internal.offheap.FreeListManager.MAX_TINY-perObjectOverhead;
int minHuge = maxTiny+1;
int TOTAL_MEM = (maxTiny+perObjectOverhead)*BATCH_SIZE /*+ (maxBig+perObjectOverhead)*BATCH_SIZE*/ + round(TINY_MULTIPLE, minHuge+1+perObjectOverhead)*BATCH_SIZE + (TINY_MULTIPLE+perObjectOverhead)*BATCH_SIZE /*+ (MIN_BIG_SIZE+perObjectOverhead)*BATCH_SIZE*/ + round(TINY_MULTIPLE, minHuge+perObjectOverhead+1);
@@ -273,7 +273,7 @@ public class SimpleMemoryAllocatorJUnitTest {
bb.put((byte) i);
}
bb.position(0);
- GemFireChunk c = (GemFireChunk) ma.allocateAndInitialize(bb.array(), false, false);
+ ObjectChunk c = (ObjectChunk) ma.allocateAndInitialize(bb.array(), false, false);
assertEquals(1024, c.getDataSize());
if (!Arrays.equals(bb.array(), c.getRawBytes())) {
fail("arrays are not equal. Expected " + Arrays.toString(bb.array()) + " but found: " + Arrays.toString(c.getRawBytes()));
@@ -427,7 +427,7 @@ public class SimpleMemoryAllocatorJUnitTest {
@Test
public void testCompaction() {
- final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.ObjectChunk.OFF_HEAP_HEADER_SIZE;
final int BIG_ALLOC_SIZE = 150000;
final int SMALL_ALLOC_SIZE = BIG_ALLOC_SIZE/2;
final int TOTAL_MEM = BIG_ALLOC_SIZE;
@@ -543,7 +543,7 @@ public class SimpleMemoryAllocatorJUnitTest {
boolean memoryUsageEventReceived;
@Test
public void testUsageEventListener() {
- final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.ObjectChunk.OFF_HEAP_HEADER_SIZE;
final int SMALL_ALLOC_SIZE = 1000;
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(3000);
try {
@@ -596,7 +596,7 @@ public class SimpleMemoryAllocatorJUnitTest {
@Test
public void testOutOfOffHeapMemory() {
- final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.GemFireChunk.OFF_HEAP_HEADER_SIZE;
+ final int perObjectOverhead = com.gemstone.gemfire.internal.offheap.ObjectChunk.OFF_HEAP_HEADER_SIZE;
final int BIG_ALLOC_SIZE = 150000;
final int SMALL_ALLOC_SIZE = BIG_ALLOC_SIZE/2;
final int TOTAL_MEM = BIG_ALLOC_SIZE;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SyncChunkStackJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SyncChunkStackJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SyncChunkStackJUnitTest.java
index 8d6eef0..3ae6159 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SyncChunkStackJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/offheap/SyncChunkStackJUnitTest.java
@@ -107,7 +107,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
SyncChunkStack stack = new SyncChunkStack(chunk.getMemoryAddress());
assertEquals(false, stack.isEmpty());
@@ -121,7 +121,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
SyncChunkStack stack = new SyncChunkStack();
stack.offer(chunk.getMemoryAddress());
@@ -136,7 +136,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
long addr = chunk.getMemoryAddress();
SyncChunkStack stack = new SyncChunkStack();
@@ -163,7 +163,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
long addr = chunk.getMemoryAddress();
SyncChunkStack stack = new SyncChunkStack();
@@ -181,7 +181,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
long addr = chunk.getMemoryAddress();
SyncChunkStack stack = new SyncChunkStack();
@@ -199,7 +199,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
int chunkSize = chunk.getSize();
long addr = chunk.getMemoryAddress();
@@ -217,7 +217,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
int chunkSize = chunk.getSize();
long addr = chunk.getMemoryAddress();
@@ -242,7 +242,7 @@ public class SyncChunkStackJUnitTest {
protected void testHookDoConcurrentModification() {
if (doConcurrentMod) {
doConcurrentMod = false;
- GemFireChunk chunk2 = (GemFireChunk) ma.allocate(50);
+ ObjectChunk chunk2 = (ObjectChunk) ma.allocate(50);
this.chunk2Size = chunk2.getSize();
this.offer(chunk2.getMemoryAddress());
}
@@ -253,7 +253,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
int chunkSize = chunk.getSize();
long addr = chunk.getMemoryAddress();
@@ -272,7 +272,7 @@ public class SyncChunkStackJUnitTest {
UnsafeMemoryChunk slab = new UnsafeMemoryChunk(1024);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new UnsafeMemoryChunk[]{slab});
- GemFireChunk chunk = (GemFireChunk) ma.allocate(100);
+ ObjectChunk chunk = (ObjectChunk) ma.allocate(100);
int chunkSize = chunk.getSize();
long addr = chunk.getMemoryAddress();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteBufferByteSourceJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteBufferByteSourceJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteBufferByteSourceJUnitTest.java
index 4272bfd..0f918cb 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteBufferByteSourceJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteBufferByteSourceJUnitTest.java
@@ -22,7 +22,7 @@ import java.nio.ByteBuffer;
import org.junit.experimental.categories.Category;
-import com.gemstone.gemfire.internal.offheap.GemFireChunk;
+import com.gemstone.gemfire.internal.offheap.ObjectChunk;
import com.gemstone.gemfire.internal.offheap.SimpleMemoryAllocatorImpl;
import com.gemstone.gemfire.internal.offheap.StoredObject;
import com.gemstone.gemfire.internal.tcp.ByteBufferInputStream.ByteSource;
@@ -35,8 +35,8 @@ public class OffHeapByteBufferByteSourceJUnitTest extends OffHeapByteSourceJUnit
@Override
protected ByteSource createByteSource(byte[] bytes) {
StoredObject so = SimpleMemoryAllocatorImpl.getAllocator().allocateAndInitialize(bytes, false, false);
- if (so instanceof GemFireChunk) {
- GemFireChunk c = (GemFireChunk) so;
+ if (so instanceof ObjectChunk) {
+ ObjectChunk c = (ObjectChunk) so;
ByteBuffer bb = c.createDirectByteBuffer();
if (bb == null) {
fail("could not create a direct ByteBuffer for an off-heap Chunk");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1a82c80c/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteSourceJUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteSourceJUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteSourceJUnitTest.java
index 91b52e4..6457425 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteSourceJUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/pdx/OffHeapByteSourceJUnitTest.java
@@ -20,7 +20,7 @@ import org.junit.After;
import org.junit.Before;
import org.junit.experimental.categories.Category;
-import com.gemstone.gemfire.internal.offheap.GemFireChunk;
+import com.gemstone.gemfire.internal.offheap.ObjectChunk;
import com.gemstone.gemfire.internal.offheap.NullOffHeapMemoryStats;
import com.gemstone.gemfire.internal.offheap.NullOutOfOffHeapMemoryListener;
import com.gemstone.gemfire.internal.offheap.SimpleMemoryAllocatorImpl;
@@ -52,9 +52,9 @@ public class OffHeapByteSourceJUnitTest extends ByteSourceJUnitTest {
@Override
protected ByteSource createByteSource(byte[] bytes) {
StoredObject so = SimpleMemoryAllocatorImpl.getAllocator().allocateAndInitialize(bytes, false, false);
- if (so instanceof GemFireChunk) {
+ if (so instanceof ObjectChunk) {
// bypass the factory to make sure that OffHeapByteSource is tested
- return new OffHeapByteSource((GemFireChunk)so);
+ return new OffHeapByteSource((ObjectChunk)so);
} else {
// bytes are so small they can be encoded in a long (see DataAsAddress).
// So for this test just wrap the original bytes.