本文整理了Java中org.apache.geode.cache.RegionAttributes.getOffHeap
方法的一些代码示例,展示了RegionAttributes.getOffHeap
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getOffHeap
方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getOffHeap
[英]Returns whether or not this region uses off-heap memory.
[中]返回此区域是否使用堆外内存。
代码示例来源:origin: apache/geode
@Override
protected boolean includeLocalRegion(LocalRegion region) {
return region.getEvictionAttributes().getAlgorithm().isLRUHeap()
&& region.getAttributes().getOffHeap();
}
代码示例来源:origin: apache/geode
protected boolean includeLocalRegion(LocalRegion region) {
return region.getEvictionAttributes().getAlgorithm().isLRUHeap()
&& !region.getAttributes().getOffHeap();
}
代码示例来源:origin: apache/geode
@Override
protected boolean includePartitionedRegion(PartitionedRegion region) {
return region.getEvictionAttributes().getAlgorithm().isLRUHeap()
&& region.getDataStore() != null && region.getAttributes().getOffHeap();
}
代码示例来源:origin: apache/geode
protected boolean includePartitionedRegion(PartitionedRegion region) {
return region.getEvictionAttributes().getAlgorithm().isLRUHeap()
&& region.getDataStore() != null && !region.getAttributes().getOffHeap();
}
代码示例来源:origin: apache/geode
boolean putIfAbsentResultHasSameValue(boolean isClient, Object valueToBePut, Object result) {
if (Token.isInvalid(result) || result == null) {
return valueToBePut == null;
}
boolean isCompressedOffHeap =
isClient ? false : getAttributes().getOffHeap() && getAttributes().getCompressor() != null;
return ValueComparisonHelper.checkEquals(valueToBePut, result, isCompressedOffHeap, getCache());
}
代码示例来源:origin: apache/geode
private void getRegionLiveChunks(Region<?, ?> r, List<OffHeapStoredObject> result) {
if (r.getAttributes().getOffHeap()) {
if (r instanceof PartitionedRegion) {
PartitionedRegionDataStore prs = ((PartitionedRegion) r).getDataStore();
if (prs != null) {
Set<BucketRegion> brs = prs.getAllLocalBucketRegions();
if (brs != null) {
for (BucketRegion br : brs) {
if (br != null && !br.isDestroyed()) {
this.basicGetRegionLiveChunks(br, result);
}
}
}
}
} else {
this.basicGetRegionLiveChunks((InternalRegion) r, result);
}
}
}
代码示例来源:origin: apache/geode
private boolean mustEvict() {
LocalRegion owner = _getOwner();
InternalResourceManager resourceManager = owner.getCache().getInternalResourceManager();
boolean offheap = owner.getAttributes().getOffHeap();
return resourceManager.getMemoryMonitor(offheap).getState().isEviction() && this.sizeInVM() > 0;
}
代码示例来源:origin: apache/geode
throw new RuntimeException("Compressors are not the same.");
if (this.offHeap != other.getOffHeap()) {
throw new RuntimeException(
"EnableOffHeapMemory is not the same");
代码示例来源:origin: apache/geode
public static boolean checkExpectedOldValue(@Unretained Object expectedOldValue,
@Unretained Object actualValue, InternalRegion region) {
if (Token.isInvalid(expectedOldValue)) {
return actualValue == null || Token.isInvalid(actualValue);
} else {
boolean isCompressedOffHeap =
region.getAttributes().getOffHeap() && region.getAttributes().getCompressor() != null;
return ValueComparisonHelper
.checkEquals(expectedOldValue, actualValue, isCompressedOffHeap, region.getCache());
}
}
代码示例来源:origin: apache/geode
boolean bridgePutIfAbsentResultHasSameValue(byte[] valueToBePut, boolean isValueToBePutObject,
Object result) {
if (Token.isInvalid(result) || result == null) {
return valueToBePut == null;
}
boolean isCompressedOffHeap =
getAttributes().getOffHeap() && getAttributes().getCompressor() != null;
if (isValueToBePutObject) {
return ValueComparisonHelper.checkEquals(EntryEventImpl.deserialize(valueToBePut), result,
isCompressedOffHeap, getCache());
}
return ValueComparisonHelper.checkEquals(valueToBePut, result, isCompressedOffHeap, getCache());
}
代码示例来源:origin: apache/geode
final boolean otherIsOffHeap = rgn.getAttributes().getOffHeap();
代码示例来源:origin: apache/geode
/**
* Okay, deep breath. Instead of basing the LRU calculation on the number of entries in the region
* or on their "size" (which turned out to be incorrectly estimated in the general case), we use
* the amount of memory currently in use. If the amount of memory current in use
* {@linkplain Runtime#maxMemory} - {@linkplain Runtime#freeMemory} is greater than the overflow
* threshold, then we evict the LRU entry.
*/
@Override
public boolean mustEvict(EvictionCounters stats, InternalRegion region, int delta) {
InternalCache cache = (InternalCache) region.getRegionService();
boolean offheap = region.getAttributes().getOffHeap();
boolean shouldEvict =
cache.getInternalResourceManager().getMemoryMonitor(offheap).getState().isEviction();
if (region instanceof BucketRegion) {
return shouldEvict && ((BucketRegion) region).getSizeForEviction() > 0;
}
return shouldEvict && ((LocalRegion) region).getRegionMap().sizeInVM() > 0;
}
代码示例来源:origin: apache/geode
public IndexManager(InternalCache cache, Region region) {
this.cache = cache;
this.region = region;
// must be a SortedMap to ensure the indexes are iterated over in fixed
// order
// to avoid deadlocks when acquiring locks
// indexes = Collections.synchronizedSortedMap(new TreeMap());
indexMaintenanceSynchronous = region.getAttributes().getIndexMaintenanceSynchronous();
isOverFlowToDisk =
region.getAttributes().getEvictionAttributes().getAction().isOverflowToDisk();
this.offHeap = region.getAttributes().getOffHeap();
if (!indexMaintenanceSynchronous) {
updater = new IndexUpdaterThread(this.INDEX_MAINTENANCE_BUFFER,
"OqlIndexUpdater:" + region.getFullPath());
updater.start();
}
}
代码示例来源:origin: apache/geode
offHeap = ra.getOffHeap();
代码示例来源:origin: apache/geode
boolean offheap = regAttrs.getOffHeap();
代码示例来源:origin: apache/geode
this.offHeap = attrs.getOffHeap();
if (attrs instanceof UserSpecifiedRegionAttributes) {
UserSpecifiedRegionAttributes nonDefault = (UserSpecifiedRegionAttributes) attrs;
代码示例来源:origin: apache/geode
myName = internalRegionArgs.getPartitionedRegion().getFullPath();
this.offHeap = attrs.getOffHeap() || Boolean.getBoolean(myName + ":OFF_HEAP");
if (getOffHeap()) {
if (cache.getOffHeapStore() == null) {
代码示例来源:origin: apache/geode
this.scope = attrs.getScope();
this.offHeap = attrs.getOffHeap();
代码示例来源:origin: apache/geode
this.regionAttributes.offHeap = regionAttributes.getOffHeap();
代码示例来源:origin: apache/geode
this.asyncEventQueueDescs = getDescs(attr.getAsyncEventQueueIds().toArray());
this.compressorDesc = getDesc(attr.getCompressor());
this.offHeap = attr.getOffHeap();
内容来源于网络,如有侵权,请联系作者删除!