org.apache.geode.cache.RegionAttributes.getOffHeap()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(56)

本文整理了Java中org.apache.geode.cache.RegionAttributes.getOffHeap方法的一些代码示例,展示了RegionAttributes.getOffHeap的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getOffHeap方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getOffHeap

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();

相关文章

微信公众号

最新文章

更多

RegionAttributes类方法