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/03/05 01:51:20 UTC
[20/38] incubator-geode git commit: renamed ObjectStoredOffHeap to
AddressableStoredObject
renamed ObjectStoredOffHeap to AddressableStoredObject
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/63d9e08a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/63d9e08a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/63d9e08a
Branch: refs/heads/feature/GEODE-982
Commit: 63d9e08a2a88f905aa2d0a44a147e9c17aac3879
Parents: f97fd21
Author: Darrel Schneider <ds...@pivotal.io>
Authored: Tue Mar 1 16:48:35 2016 -0800
Committer: Darrel Schneider <ds...@pivotal.io>
Committed: Tue Mar 1 16:48:35 2016 -0800
----------------------------------------------------------------------
.../gemfire/internal/cache/DiskStoreImpl.java | 2 +-
.../gemfire/internal/cache/EntryEventImpl.java | 6 +-
.../gemfire/internal/cache/RegionEntry.java | 4 +-
.../offheap/AddressableStoredObject.java | 85 ++++++++++++++++++++
.../internal/offheap/MemoryAllocator.java | 2 +-
.../gemfire/internal/offheap/ObjectChunk.java | 2 +-
.../internal/offheap/ObjectStoredOffHeap.java | 85 --------------------
.../gemfire/internal/offheap/OffHeapHelper.java | 12 +--
.../offheap/OffHeapRegionEntryHelper.java | 2 +-
.../offheap/SimpleMemoryAllocatorImpl.java | 2 +-
.../gemfire/cache30/MultiVMRegionTestCase.java | 8 +-
.../offheap/MemoryBlockNodeJUnitTest.java | 22 ++---
.../offheap/OffHeapHelperJUnitTest.java | 10 +--
.../internal/offheap/OffHeapRegionBase.java | 6 +-
.../offheap/SimpleMemoryAllocatorJUnitTest.java | 34 ++++----
.../offheap/TinyMemoryBlockJUnitTest.java | 24 +++---
16 files changed, 153 insertions(+), 153 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/DiskStoreImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/DiskStoreImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/DiskStoreImpl.java
index 3f6762f..26395b6 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/DiskStoreImpl.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/DiskStoreImpl.java
@@ -110,7 +110,7 @@ import com.gemstone.gemfire.internal.logging.LogService;
import com.gemstone.gemfire.internal.logging.LoggingThreadGroup;
import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage;
import com.gemstone.gemfire.internal.logging.log4j.LogMarker;
-import com.gemstone.gemfire.internal.offheap.ObjectStoredOffHeap;
+import com.gemstone.gemfire.internal.offheap.AddressableStoredObject;
import com.gemstone.gemfire.internal.offheap.OffHeapHelper;
import com.gemstone.gemfire.internal.offheap.annotations.Released;
import com.gemstone.gemfire.internal.offheap.annotations.Retained;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
index 37a6cf0..3d0d090 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
@@ -74,7 +74,7 @@ import com.gemstone.gemfire.internal.logging.LogService;
import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage;
import com.gemstone.gemfire.internal.logging.log4j.LogMarker;
import com.gemstone.gemfire.internal.offheap.ObjectChunk;
-import com.gemstone.gemfire.internal.offheap.ObjectStoredOffHeap;
+import com.gemstone.gemfire.internal.offheap.AddressableStoredObject;
import com.gemstone.gemfire.internal.offheap.OffHeapHelper;
import com.gemstone.gemfire.internal.offheap.OffHeapRegionEntryHelper;
import com.gemstone.gemfire.internal.offheap.ReferenceCountHelper;
@@ -1536,8 +1536,8 @@ public class EntryEventImpl
return null;
}
StoredObject result = (StoredObject) tmp;
- if (result instanceof ObjectStoredOffHeap) {
- if (!((ObjectStoredOffHeap) result).retain()) {
+ if (result instanceof AddressableStoredObject) {
+ if (!((AddressableStoredObject) result).retain()) {
return null;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RegionEntry.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RegionEntry.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RegionEntry.java
index 3b36e6b..19a0e2d 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RegionEntry.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RegionEntry.java
@@ -31,7 +31,7 @@ import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand;
import com.gemstone.gemfire.internal.cache.versions.VersionSource;
import com.gemstone.gemfire.internal.cache.versions.VersionStamp;
import com.gemstone.gemfire.internal.cache.versions.VersionTag;
-import com.gemstone.gemfire.internal.offheap.ObjectStoredOffHeap;
+import com.gemstone.gemfire.internal.offheap.AddressableStoredObject;
import com.gemstone.gemfire.internal.offheap.annotations.Released;
import com.gemstone.gemfire.internal.offheap.annotations.Retained;
import com.gemstone.gemfire.internal.offheap.annotations.Unretained;
@@ -240,7 +240,7 @@ public interface RegionEntry {
* Obtain and return the value of this entry using {@link #_getValue()}.
* If the value is a MemoryChunkWithRefCount then increment its refcount.
* WARNING: if a MemoryChunkWithRefCount is returned then the caller MUST
- * call {@link ObjectStoredOffHeap#release()}.
+ * call {@link AddressableStoredObject#release()}.
*
* This is only retained in off-heap subclasses. However, it's marked as
* Retained here so that callers are aware that the value may be retained.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/AddressableStoredObject.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/AddressableStoredObject.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/AddressableStoredObject.java
new file mode 100644
index 0000000..597eec4
--- /dev/null
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/AddressableStoredObject.java
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.gemstone.gemfire.internal.offheap;
+
+import com.gemstone.gemfire.internal.offheap.annotations.Retained;
+
+/**
+ * Represents a stored object whose stored data is also addressable.
+ * This interface provides methods that let you read and write the bytes
+ * of addressable memory used to store the bytes of the object.
+ * A reference count is used to determine if the object is still allocated.
+ * To increment the count call {@link #retain()}.
+ * To decrement the count call {@link #release()}.
+ *
+ * @author darrel
+ * @since 9.0
+ */
+public interface AddressableStoredObject extends StoredObject, Releasable {
+
+ /**
+ * Returns the address of the memory used to store this object.
+ * This address may not be to the first byte of stored data since
+ * the implementation may store some internal data in the first bytes of the memory.
+ * This address can be used with AddressableMemoryManager.
+ */
+ public long getMemoryAddress();
+ /**
+ * Returns the number of bytes of memory used by this object to store an object.
+ * This size includes any bytes used for padding and meta-information.
+ */
+ public int getSize();
+
+ /**
+ * Returns the address of the first byte of memory used to store this object.
+ * This address will not be to any padding or meta-data bytes that precede the
+ * first data byte.
+ * This address can be used with AddressableMemoryManager.
+ */
+ public long getDataAddress();
+ /**
+ * Returns the number of bytes of memory used to store the object.
+ * This size does not include any bytes used for padding.
+ */
+ public int getDataSize();
+
+ public byte readDataByte(int offset);
+ public void writeDataByte(int offset, byte value);
+
+ public void readDataBytes(int offset, byte[] bytes);
+ public void writeDataBytes(int offset, byte[] bytes);
+ public void readDataBytes(int offset, byte[] bytes, int bytesOffset, int size);
+ public void writeDataBytes(int offset, byte[] bytes, int bytesOffset, int size);
+
+ /**
+ * Call to indicate that this object's memory is in use by the caller.
+ * The memory will stay allocated until {@link #release()} is called.
+ * It is ok for a thread other than the one that called this method to call release.
+ * This method is called implicitly at the time the chunk is allocated.
+ * Note: @Retained tells you that "this" is retained by this method.
+ *
+ * @throws IllegalStateException if the max ref count is exceeded.
+ * @return true if we are able to retain this chunk; false if we need to retry
+ */
+ @Retained
+ public boolean retain();
+
+ /**
+ * Returns the number of users of this memory.
+ */
+ public int getRefCount();
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/MemoryAllocator.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/MemoryAllocator.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/MemoryAllocator.java
index d06eb21..039ca2e 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/MemoryAllocator.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/MemoryAllocator.java
@@ -29,7 +29,7 @@ public interface MemoryAllocator {
* @return the allocated chunk of memory.
* @throws IllegalStateException if the heap does not have enough memory to grant the request
*/
- public ObjectStoredOffHeap allocate(int size);
+ public AddressableStoredObject allocate(int size);
/**
* Allocates off heap memory for the given data and returns a MemoryChunk
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectChunk.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectChunk.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectChunk.java
index be45ee9..f209f51 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectChunk.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectChunk.java
@@ -43,7 +43,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Unretained;
* to it in the cache. Instead the memoryAddress is stored in a primitive field in
* the cache and if used it will then, if needed, create an instance of this class.
*/
- public class ObjectChunk extends AbstractStoredObject implements ObjectStoredOffHeap, Comparable<ObjectChunk>, MemoryBlock {
+ public class ObjectChunk extends AbstractStoredObject implements AddressableStoredObject, Comparable<ObjectChunk>, MemoryBlock {
/**
* The unsafe memory address of the first byte of this chunk
*/
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectStoredOffHeap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectStoredOffHeap.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectStoredOffHeap.java
deleted file mode 100644
index 85626f5..0000000
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/ObjectStoredOffHeap.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package com.gemstone.gemfire.internal.offheap;
-
-import com.gemstone.gemfire.internal.offheap.annotations.Retained;
-
-/**
- * Represents a stored object that uses off-heap memory.
- * This interface provides methods that let you read and write the bytes
- * of off-heap memory used to store the bytes of the object.
- * A reference count is used to determine if the object is still allocated.
- * To increment the count call {@link #retain()}.
- * To decrement the count call {@link #release()}.
- *
- * @author darrel
- * @since 9.0
- */
-public interface ObjectStoredOffHeap extends StoredObject, Releasable {
-
- /**
- * Returns the address of the memory used to store this object.
- * This address may not be to the first byte of stored data since
- * the implementation may store some internal data in the first bytes of the memory.
- * This address can be used with AddressableMemoryManager.
- */
- public long getMemoryAddress();
- /**
- * Returns the number of bytes of memory used by this object to store an object.
- * This size includes any bytes used for padding and meta-information.
- */
- public int getSize();
-
- /**
- * Returns the address of the first byte of memory used to store this object.
- * This address will not be to any padding or meta-data bytes that precede the
- * first data byte.
- * This address can be used with AddressableMemoryManager.
- */
- public long getDataAddress();
- /**
- * Returns the number of bytes of memory used to store the object.
- * This size does not include any bytes used for padding.
- */
- public int getDataSize();
-
- public byte readDataByte(int offset);
- public void writeDataByte(int offset, byte value);
-
- public void readDataBytes(int offset, byte[] bytes);
- public void writeDataBytes(int offset, byte[] bytes);
- public void readDataBytes(int offset, byte[] bytes, int bytesOffset, int size);
- public void writeDataBytes(int offset, byte[] bytes, int bytesOffset, int size);
-
- /**
- * Call to indicate that this object's memory is in use by the caller.
- * The memory will stay allocated until {@link #release()} is called.
- * It is ok for a thread other than the one that called this method to call release.
- * This method is called implicitly at the time the chunk is allocated.
- * Note: @Retained tells you that "this" is retained by this method.
- *
- * @throws IllegalStateException if the max ref count is exceeded.
- * @return true if we are able to retain this chunk; false if we need to retry
- */
- @Retained
- public boolean retain();
-
- /**
- * Returns the number of users of this memory.
- */
- public int getRefCount();
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapHelper.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapHelper.java
index 3c9c297..50944ac 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapHelper.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapHelper.java
@@ -93,8 +93,8 @@ public class OffHeapHelper {
* @return true if release was done
*/
public static boolean release(@Released Object o) {
- if (o instanceof ObjectStoredOffHeap) {
- ((ObjectStoredOffHeap) o).release();
+ if (o instanceof AddressableStoredObject) {
+ ((AddressableStoredObject) o).release();
return true;
} else {
return false;
@@ -105,9 +105,9 @@ public class OffHeapHelper {
* @return true if release was done
*/
public static boolean releaseWithNoTracking(@Released Object o) {
- if (o instanceof ObjectStoredOffHeap) {
+ if (o instanceof AddressableStoredObject) {
ReferenceCountHelper.skipRefCountTracking();
- ((ObjectStoredOffHeap) o).release();
+ ((AddressableStoredObject) o).release();
ReferenceCountHelper.unskipRefCountTracking();
return true;
} else {
@@ -120,9 +120,9 @@ public class OffHeapHelper {
* @return true if release was done
*/
public static boolean releaseAndTrackOwner(@Released final Object o, final Object owner) {
- if (o instanceof ObjectStoredOffHeap) {
+ if (o instanceof AddressableStoredObject) {
ReferenceCountHelper.setReferenceCountOwner(owner);
- ((ObjectStoredOffHeap) o).release();
+ ((AddressableStoredObject) o).release();
ReferenceCountHelper.setReferenceCountOwner(null);
return true;
} else {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelper.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelper.java
index 5a9cf70..4f5e128 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelper.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionEntryHelper.java
@@ -184,7 +184,7 @@ public class OffHeapRegionEntryHelper {
setValue(re, Token.REMOVED_PHASE2);
}
- public static void releaseEntry(@Unretained OffHeapRegionEntry re, @Released ObjectStoredOffHeap expectedValue) {
+ public static void releaseEntry(@Unretained OffHeapRegionEntry re, @Released AddressableStoredObject expectedValue) {
long oldAddress = objectToAddress(expectedValue);
final long newAddress = objectToAddress(Token.REMOVED_PHASE2);
if (re.setAddress(oldAddress, newAddress) || re.getAddress() != newAddress) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorImpl.java
index 1c03fc0..61a38a2 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorImpl.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorImpl.java
@@ -307,7 +307,7 @@ public class SimpleMemoryAllocatorImpl implements MemoryAllocator {
}
@Override
- public ObjectStoredOffHeap allocate(int size) {
+ public AddressableStoredObject allocate(int size) {
//System.out.println("allocating " + size);
ObjectChunk result = allocateChunk(size);
//("allocated off heap object of size " + size + " @" + Long.toHexString(result.getMemoryAddress()), true);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/cache30/MultiVMRegionTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/cache30/MultiVMRegionTestCase.java b/geode-core/src/test/java/com/gemstone/gemfire/cache30/MultiVMRegionTestCase.java
index 0a1253b..748c5e1 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/cache30/MultiVMRegionTestCase.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/cache30/MultiVMRegionTestCase.java
@@ -110,7 +110,7 @@ import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector;
import com.gemstone.gemfire.internal.cache.versions.VMRegionVersionVector;
import com.gemstone.gemfire.internal.cache.versions.VersionTag;
import com.gemstone.gemfire.internal.logging.LogService;
-import com.gemstone.gemfire.internal.offheap.ObjectStoredOffHeap;
+import com.gemstone.gemfire.internal.offheap.AddressableStoredObject;
import com.gemstone.gemfire.internal.offheap.SimpleMemoryAllocatorImpl;
import com.gemstone.gemfire.test.dunit.AsyncInvocation;
import com.gemstone.gemfire.test.dunit.DistributedTestCase;
@@ -2004,7 +2004,7 @@ public abstract class MultiVMRegionTestCase extends RegionTestCase {
LocalRegion reRegion;
reRegion = (LocalRegion) region;
RegionEntry re = reRegion.getRegionEntry(key2);
- ObjectStoredOffHeap so = (ObjectStoredOffHeap) re._getValue();
+ AddressableStoredObject so = (AddressableStoredObject) re._getValue();
assertEquals(1, so.getRefCount());
assertEquals(1, ma.getStats().getObjects());
}
@@ -2091,7 +2091,7 @@ public abstract class MultiVMRegionTestCase extends RegionTestCase {
assertEquals(2, ma.getStats().getObjects());
LocalRegion reRegion;
reRegion = (LocalRegion) region;
- ObjectStoredOffHeap so = (ObjectStoredOffHeap) reRegion.getRegionEntry(key)._getValue();
+ AddressableStoredObject so = (AddressableStoredObject) reRegion.getRegionEntry(key)._getValue();
assertEquals(1, so.getRefCount());
}
}
@@ -2157,7 +2157,7 @@ public abstract class MultiVMRegionTestCase extends RegionTestCase {
assertEquals(2, ma.getStats().getObjects());
LocalRegion reRegion;
reRegion = (LocalRegion) region;
- ObjectStoredOffHeap so = (ObjectStoredOffHeap) reRegion.getRegionEntry(key)._getValue();
+ AddressableStoredObject so = (AddressableStoredObject) reRegion.getRegionEntry(key)._getValue();
assertEquals(1, so.getRefCount());
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/MemoryBlockNodeJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/MemoryBlockNodeJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/MemoryBlockNodeJUnitTest.java
index 6edf11b..1b164db 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/MemoryBlockNodeJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/MemoryBlockNodeJUnitTest.java
@@ -53,7 +53,7 @@ public class MemoryBlockNodeJUnitTest {
new SlabImpl((int)OffHeapStorage.MIN_SLAB_SIZE),
new SlabImpl((int)OffHeapStorage.MIN_SLAB_SIZE * 2)
};
- private ObjectStoredOffHeap storedObject = null;
+ private AddressableStoredObject storedObject = null;
static {
ClassLoader.getSystemClassLoader().setDefaultAssertionStatus(true);
@@ -94,11 +94,11 @@ public class MemoryBlockNodeJUnitTest {
return Long.valueOf(Long.MAX_VALUE);
}
- protected ObjectStoredOffHeap createValueAsUnserializedStoredObject(Object value) {
- ObjectStoredOffHeap createdObject = createValueAsUnserializedStoredObject(value, false);
+ protected AddressableStoredObject createValueAsUnserializedStoredObject(Object value) {
+ AddressableStoredObject createdObject = createValueAsUnserializedStoredObject(value, false);
return createdObject;
}
- protected ObjectStoredOffHeap createValueAsUnserializedStoredObject(Object value, boolean isCompressed) {
+ protected AddressableStoredObject createValueAsUnserializedStoredObject(Object value, boolean isCompressed) {
byte[] valueInByteArray;
if (value instanceof Long) {
valueInByteArray = convertValueToByteArray(value);
@@ -108,7 +108,7 @@ public class MemoryBlockNodeJUnitTest {
boolean isSerialized = false;
- ObjectStoredOffHeap createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
return createdObject;
}
@@ -116,23 +116,23 @@ public class MemoryBlockNodeJUnitTest {
return ByteBuffer.allocate(Long.SIZE / Byte.SIZE).putLong((Long) value).array();
}
- private ObjectStoredOffHeap createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
- ObjectStoredOffHeap chunk = (ObjectStoredOffHeap) ma.allocateAndInitialize(v, isSerialized, isCompressed);
+ private AddressableStoredObject createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
+ AddressableStoredObject chunk = (AddressableStoredObject) ma.allocateAndInitialize(v, isSerialized, isCompressed);
return chunk;
}
- protected ObjectStoredOffHeap createValueAsSerializedStoredObject(Object value) {
- ObjectStoredOffHeap createdObject = createValueAsSerializedStoredObject(value, false);
+ protected AddressableStoredObject createValueAsSerializedStoredObject(Object value) {
+ AddressableStoredObject createdObject = createValueAsSerializedStoredObject(value, false);
return createdObject;
}
- protected ObjectStoredOffHeap createValueAsSerializedStoredObject(Object value, boolean isCompressed) {
+ protected AddressableStoredObject createValueAsSerializedStoredObject(Object value, boolean isCompressed) {
byte[] valueInSerializedByteArray = EntryEventImpl.serialize(value);
boolean isSerialized = true;
- ObjectStoredOffHeap createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
return createdObject;
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
index 0f6905b..6510ed4 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapHelperJUnitTest.java
@@ -38,7 +38,7 @@ import com.gemstone.gemfire.test.junit.categories.UnitTest;
@Category(UnitTest.class)
public class OffHeapHelperJUnitTest extends AbstractStoredObjectTestBase {
- private ObjectStoredOffHeap storedObject = null;
+ private AddressableStoredObject storedObject = null;
private Object deserializedRegionEntryValue = null;
private byte[] serializedRegionEntryValue = null;
private MemoryAllocator ma;
@@ -102,7 +102,7 @@ public class OffHeapHelperJUnitTest extends AbstractStoredObjectTestBase {
}
@Override
- protected ObjectStoredOffHeap createValueAsUnserializedStoredObject(Object value) {
+ protected AddressableStoredObject createValueAsUnserializedStoredObject(Object value) {
byte[] valueInByteArray;
if (value instanceof Long) {
valueInByteArray = convertValueToByteArray(value);
@@ -113,18 +113,18 @@ public class OffHeapHelperJUnitTest extends AbstractStoredObjectTestBase {
boolean isSerialized = false;
boolean isCompressed = false;
- ObjectStoredOffHeap createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
return createdObject;
}
@Override
- protected ObjectStoredOffHeap createValueAsSerializedStoredObject(Object value) {
+ protected AddressableStoredObject createValueAsSerializedStoredObject(Object value) {
byte[] valueInSerializedByteArray = EntryEventImpl.serialize(value);
boolean isSerialized = true;
boolean isCompressed = false;
- ObjectStoredOffHeap createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
return createdObject;
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
index b525e2e..55bacdb 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/OffHeapRegionBase.java
@@ -92,7 +92,7 @@ public abstract class OffHeapRegionBase {
assertNotNull(ma);
final long offHeapSize = ma.getFreeMemory();
assertEquals(0, ma.getUsedMemory());
- ObjectStoredOffHeap mc1 = ma.allocate(64);
+ AddressableStoredObject mc1 = ma.allocate(64);
assertEquals(64+perObjectOverhead(), ma.getUsedMemory());
assertEquals(offHeapSize-(64+perObjectOverhead()), ma.getFreeMemory());
mc1.release();
@@ -123,7 +123,7 @@ public abstract class OffHeapRegionBase {
assertNotNull(ma);
final long offHeapSize = ma.getFreeMemory();
assertEquals(0, ma.getUsedMemory());
- ObjectStoredOffHeap mc1 = ma.allocate(64);
+ AddressableStoredObject mc1 = ma.allocate(64);
assertEquals(64+perObjectOverhead(), ma.getUsedMemory());
assertEquals(offHeapSize-(64+perObjectOverhead()), ma.getFreeMemory());
mc1.release();
@@ -163,7 +163,7 @@ public abstract class OffHeapRegionBase {
final long offHeapSize = ma.getFreeMemory();
assertEquals(0, ma.getUsedMemory());
byte[] data = new byte[] {1,2,3,4,5,6,7,8};
- ObjectStoredOffHeap mc1 = (ObjectStoredOffHeap)ma.allocateAndInitialize(data, false, false);
+ AddressableStoredObject mc1 = (AddressableStoredObject)ma.allocateAndInitialize(data, false, false);
assertEquals(data.length+perObjectOverhead(), ma.getUsedMemory());
assertEquals(offHeapSize-(data.length+perObjectOverhead()), ma.getFreeMemory());
byte[] data2 = new byte[data.length];
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
index 5ff6b17..e7385e9 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/SimpleMemoryAllocatorJUnitTest.java
@@ -202,10 +202,10 @@ public class SimpleMemoryAllocatorJUnitTest {
assertEquals(TOTAL_MEM, ma.freeList.getFreeFragmentMemory());
assertEquals(0, ma.freeList.getFreeTinyMemory());
assertEquals(0, ma.freeList.getFreeHugeMemory());
- ObjectStoredOffHeap tinymc = ma.allocate(maxTiny);
+ AddressableStoredObject tinymc = ma.allocate(maxTiny);
assertEquals(TOTAL_MEM-round(TINY_MULTIPLE, maxTiny+perObjectOverhead), ma.getFreeMemory());
assertEquals(round(TINY_MULTIPLE, maxTiny+perObjectOverhead)*(BATCH_SIZE-1), ma.freeList.getFreeTinyMemory());
- ObjectStoredOffHeap hugemc = ma.allocate(minHuge);
+ AddressableStoredObject hugemc = ma.allocate(minHuge);
assertEquals(TOTAL_MEM-round(TINY_MULTIPLE, minHuge+perObjectOverhead)/*-round(BIG_MULTIPLE, maxBig+perObjectOverhead)*/-round(TINY_MULTIPLE, maxTiny+perObjectOverhead), ma.getFreeMemory());
long freeSlab = ma.freeList.getFreeFragmentMemory();
long oldFreeHugeMemory = ma.freeList.getFreeHugeMemory();
@@ -249,7 +249,7 @@ public class SimpleMemoryAllocatorJUnitTest {
hugemc = ma.allocate(minHuge);
assertEquals(round(TINY_MULTIPLE, minHuge+perObjectOverhead)*(BATCH_SIZE-1), ma.freeList.getFreeHugeMemory());
if (BATCH_SIZE > 1) {
- ObjectStoredOffHeap hugemc2 = ma.allocate(minHuge);
+ AddressableStoredObject hugemc2 = ma.allocate(minHuge);
assertEquals(round(TINY_MULTIPLE, minHuge+perObjectOverhead)*(BATCH_SIZE-2), ma.freeList.getFreeHugeMemory());
hugemc2.release();
assertEquals(round(TINY_MULTIPLE, minHuge+perObjectOverhead)*(BATCH_SIZE-1), ma.freeList.getFreeHugeMemory());
@@ -434,16 +434,16 @@ public class SimpleMemoryAllocatorJUnitTest {
SlabImpl slab = new SlabImpl(TOTAL_MEM);
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(new NullOutOfOffHeapMemoryListener(), new NullOffHeapMemoryStats(), new SlabImpl[]{slab});
- ObjectStoredOffHeap bmc = ma.allocate(BIG_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject bmc = ma.allocate(BIG_ALLOC_SIZE-perObjectOverhead);
try {
- ObjectStoredOffHeap smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
fail("Expected out of memory");
} catch (OutOfOffHeapMemoryException expected) {
}
bmc.release();
assertEquals(TOTAL_MEM, ma.freeList.getFreeMemory());
- ObjectStoredOffHeap smc1 = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
- ObjectStoredOffHeap smc2 = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject smc1 = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject smc2 = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
smc2.release();
assertEquals(TOTAL_MEM-SMALL_ALLOC_SIZE, ma.freeList.getFreeMemory());
try {
@@ -456,7 +456,7 @@ public class SimpleMemoryAllocatorJUnitTest {
bmc = ma.allocate(BIG_ALLOC_SIZE-perObjectOverhead);
bmc.release();
assertEquals(TOTAL_MEM, ma.freeList.getFreeMemory());
- ArrayList<ObjectStoredOffHeap> mcs = new ArrayList<ObjectStoredOffHeap>();
+ ArrayList<AddressableStoredObject> mcs = new ArrayList<AddressableStoredObject>();
for (int i=0; i < BIG_ALLOC_SIZE/(8+perObjectOverhead); i++) {
mcs.add(ma.allocate(8));
}
@@ -492,11 +492,11 @@ public class SimpleMemoryAllocatorJUnitTest {
assertEquals((8+perObjectOverhead)*6, ma.freeList.getFreeMemory());
checkMcs(mcs);
// At this point I should have 8*6 + perObjectOverhead*6 of free memory
- ObjectStoredOffHeap mc24 = ma.allocate(24);
+ AddressableStoredObject mc24 = ma.allocate(24);
checkMcs(mcs);
assertEquals((8+perObjectOverhead)*6 - (24+perObjectOverhead), ma.freeList.getFreeMemory());
// At this point I should have 8*3 + perObjectOverhead*5 of free memory
- ObjectStoredOffHeap mc16 = ma.allocate(16);
+ AddressableStoredObject mc16 = ma.allocate(16);
checkMcs(mcs);
assertEquals((8+perObjectOverhead)*6 - (24+perObjectOverhead) - (16+perObjectOverhead), ma.freeList.getFreeMemory());
// At this point I should have 8*1 + perObjectOverhead*4 of free memory
@@ -504,7 +504,7 @@ public class SimpleMemoryAllocatorJUnitTest {
checkMcs(mcs);
assertEquals((8+perObjectOverhead)*6 - (24+perObjectOverhead) - (16+perObjectOverhead) - (8+perObjectOverhead), ma.freeList.getFreeMemory());
// At this point I should have 8*0 + perObjectOverhead*3 of free memory
- ObjectStoredOffHeap mcDO = ma.allocate(perObjectOverhead*2);
+ AddressableStoredObject mcDO = ma.allocate(perObjectOverhead*2);
checkMcs(mcs);
// At this point I should have 8*0 + perObjectOverhead*0 of free memory
assertEquals(0, ma.freeList.getFreeMemory());
@@ -525,7 +525,7 @@ public class SimpleMemoryAllocatorJUnitTest {
assertEquals((perObjectOverhead*3)+(8+perObjectOverhead)+(16+perObjectOverhead)+(24+perObjectOverhead), ma.freeList.getFreeMemory());
long freeMem = ma.freeList.getFreeMemory();
- for (ObjectStoredOffHeap mc: mcs) {
+ for (AddressableStoredObject mc: mcs) {
mc.release();
assertEquals(freeMem+(8+perObjectOverhead), ma.freeList.getFreeMemory());
freeMem += (8+perObjectOverhead);
@@ -559,7 +559,7 @@ public class SimpleMemoryAllocatorJUnitTest {
this.expectedMemoryUsage = SMALL_ALLOC_SIZE;
this.memoryUsageEventReceived = false;
- ObjectStoredOffHeap smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
assertEquals(true, this.memoryUsageEventReceived);
this.expectedMemoryUsage = SMALL_ALLOC_SIZE * 2;
@@ -588,8 +588,8 @@ public class SimpleMemoryAllocatorJUnitTest {
SimpleMemoryAllocatorImpl.freeOffHeapMemory();
}
}
- private void checkMcs(ArrayList<ObjectStoredOffHeap> mcs) {
- for (ObjectStoredOffHeap mc: mcs) {
+ private void checkMcs(ArrayList<AddressableStoredObject> mcs) {
+ for (AddressableStoredObject mc: mcs) {
assertEquals(8+8, mc.getSize());
}
}
@@ -614,11 +614,11 @@ public class SimpleMemoryAllocatorJUnitTest {
try {
SimpleMemoryAllocatorImpl ma = SimpleMemoryAllocatorImpl.createForUnitTest(oooml, new NullOffHeapMemoryStats(), new SlabImpl[]{slab});
// make a big allocation
- ObjectStoredOffHeap bmc = ma.allocate(BIG_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject bmc = ma.allocate(BIG_ALLOC_SIZE-perObjectOverhead);
assertNull(ooom.get());
// drive the ma to ooom with small allocations
try {
- ObjectStoredOffHeap smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
+ AddressableStoredObject smc = ma.allocate(SMALL_ALLOC_SIZE-perObjectOverhead);
fail("Expected out of memory");
} catch (OutOfOffHeapMemoryException expected) {
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/63d9e08a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/TinyMemoryBlockJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/TinyMemoryBlockJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/TinyMemoryBlockJUnitTest.java
index fceb8d6..3a086ae 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/TinyMemoryBlockJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/offheap/TinyMemoryBlockJUnitTest.java
@@ -85,17 +85,17 @@ public class TinyMemoryBlockJUnitTest {
return Long.valueOf(Long.MAX_VALUE);
}
- private ObjectStoredOffHeap createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
- ObjectStoredOffHeap chunk = (ObjectStoredOffHeap) ma.allocateAndInitialize(v, isSerialized, isCompressed);
+ private AddressableStoredObject createChunk(byte[] v, boolean isSerialized, boolean isCompressed) {
+ AddressableStoredObject chunk = (AddressableStoredObject) ma.allocateAndInitialize(v, isSerialized, isCompressed);
return chunk;
}
- private ObjectStoredOffHeap createValueAsSerializedStoredObject(Object value, boolean isCompressed) {
+ private AddressableStoredObject createValueAsSerializedStoredObject(Object value, boolean isCompressed) {
byte[] valueInSerializedByteArray = EntryEventImpl.serialize(value);
boolean isSerialized = true;
- ObjectStoredOffHeap createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInSerializedByteArray, isSerialized, isCompressed);
return createdObject;
}
@@ -103,7 +103,7 @@ public class TinyMemoryBlockJUnitTest {
return ByteBuffer.allocate(Long.SIZE / Byte.SIZE).putLong((Long) value).array();
}
- private ObjectStoredOffHeap createValueAsUnserializedStoredObject(Object value, boolean isCompressed) {
+ private AddressableStoredObject createValueAsUnserializedStoredObject(Object value, boolean isCompressed) {
byte[] valueInByteArray;
if (value instanceof Long) {
valueInByteArray = convertValueToByteArray(value);
@@ -113,7 +113,7 @@ public class TinyMemoryBlockJUnitTest {
boolean isSerialized = false;
- ObjectStoredOffHeap createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
+ AddressableStoredObject createdObject = createChunk(valueInByteArray, isSerialized, isCompressed);
return createdObject;
}
@@ -180,7 +180,7 @@ public class TinyMemoryBlockJUnitTest {
Object obj = getValue();
boolean compressed = false;
- ObjectStoredOffHeap storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
+ AddressableStoredObject storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
MemoryBlock mb = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject0).getMemoryAddress(), 0);
softly.assertThat(mb.getDataType()).isEqualTo("N/A");
}
@@ -190,7 +190,7 @@ public class TinyMemoryBlockJUnitTest {
Object obj = getValue();
boolean compressed = false;
- ObjectStoredOffHeap storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
+ AddressableStoredObject storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
MemoryBlock mb = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject0).getMemoryAddress(), 0);
softly.assertThat(mb.getDataValue()).isNull();
}
@@ -200,8 +200,8 @@ public class TinyMemoryBlockJUnitTest {
Object obj = getValue();
boolean compressed = false;
- ObjectStoredOffHeap storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
- ObjectStoredOffHeap storedObject1 = createValueAsUnserializedStoredObject(obj, compressed);
+ AddressableStoredObject storedObject0 = createValueAsSerializedStoredObject(obj, compressed);
+ AddressableStoredObject storedObject1 = createValueAsUnserializedStoredObject(obj, compressed);
MemoryBlock mb0 = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject0).getMemoryAddress(), 0);
MemoryBlock mb1 = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject1).getMemoryAddress(), 0);
softly.assertThat(mb0.isSerialized()).isFalse();
@@ -212,8 +212,8 @@ public class TinyMemoryBlockJUnitTest {
public void isCompressedReturnsFalse() {
Object obj = getValue();
boolean compressed = false;
- ObjectStoredOffHeap storedObject0 = createValueAsUnserializedStoredObject(obj, compressed);
- ObjectStoredOffHeap storedObject1 = createValueAsUnserializedStoredObject(obj, compressed = true);
+ AddressableStoredObject storedObject0 = createValueAsUnserializedStoredObject(obj, compressed);
+ AddressableStoredObject storedObject1 = createValueAsUnserializedStoredObject(obj, compressed = true);
MemoryBlock mb0 = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject0).getMemoryAddress(), 0);
MemoryBlock mb1 = new TestableFreeListManager.TinyMemoryBlock(((MemoryBlock)storedObject1).getMemoryAddress(), 0);
softly.assertThat(mb0.isCompressed()).isFalse();