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

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

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

RegionAttributes.isDiskSynchronous介绍

[英]Returns true if configured synchronous disk writes. Default is set to true.
[中]如果配置了同步磁盘写入，则返回true。默认设置为true。

代码示例

代码示例来源：origin: apache/geode

private void setDiskAttributes(BucketAttributesFactory factory) {
 factory.setDiskSynchronous(this.partitionedRegion.getAttributes().isDiskSynchronous());
 factory.setDiskStoreName(this.partitionedRegion.getAttributes().getDiskStoreName());
}

代码示例来源：origin: apache/geode

new Object[] {this.diskStoreName, other.getDiskStoreName()}));
if (this.isDiskSynchronous != other.isDiskSynchronous()) {
 throw new RuntimeException(
   "Disk Synchronous write is not the same.");

代码示例来源：origin: apache/geode

if (!partitionedRegion.getAttributes().isDiskSynchronous()) {

代码示例来源：origin: apache/geode

|| ((RegionAttributesCreation) attrs).hasDiskSynchronous())) {
if (generateDefaults()
  || attrs.isDiskSynchronous() != AttributesFactory.DEFAULT_DISK_SYNCHRONOUS)
 atts.addAttribute("", "", DISK_SYNCHRONOUS, "",
   String.valueOf(attrs.isDiskSynchronous()));

代码示例来源：origin: apache/geode

boolean diskSynchronus = regAttrs.isDiskSynchronous();
boolean offheap = regAttrs.getOffHeap();

代码示例来源：origin: apache/geode

factory.setDiskSynchronous(true);
RegionAttributes attrs = factory.create();
assertEquals(true, attrs.isDiskSynchronous());
assertEquals(true, attrs.getDiskWriteAttributes().isSynchronous());
factory.setDiskSynchronous(false);
RegionAttributes attrs = factory.create();
assertEquals(false, attrs.isDiskSynchronous());
assertEquals(false, attrs.getDiskWriteAttributes().isSynchronous());
RegionAttributes attrs = factory.create();
assertEquals(false, attrs.getDiskWriteAttributes().isSynchronous());
assertEquals(false, attrs.isDiskSynchronous());
RegionAttributes attrs = factory.create();
assertEquals(false, attrs.getDiskWriteAttributes().isSynchronous());
assertEquals(false, attrs.isDiskSynchronous());
RegionAttributes attrs = factory.create();
assertEquals(false, attrs.getDiskWriteAttributes().isSynchronous());
assertEquals(false, attrs.isDiskSynchronous());

代码示例来源：origin: apache/geode

this.diskSizes = null;
this.isDiskSynchronous = attrs.isDiskSynchronous();
this.indexMaintenanceSynchronous = attrs.getIndexMaintenanceSynchronous();
this.partitionAttributes = attrs.getPartitionAttributes();

代码示例来源：origin: apache/geode

protected void verify(LocalRegion lr, DiskRegionProperties drp) {
 DiskStore ds = cache.findDiskStore(lr.getDiskStoreName());
 assertTrue(ds != null);
 assertTrue(lr.getAttributes().isDiskSynchronous() == drp.isSynchronous());
 assertTrue(ds.getAutoCompact() == drp.isRolling());
 assertEquals(drp.getMaxOplogSize() / (1024 * 1024), ds.getMaxOplogSize());
 if (drp.getTimeInterval() != -1) {
  assertEquals(drp.getTimeInterval(), ds.getTimeInterval());
 } else {
  assertEquals(DiskStoreFactory.DEFAULT_TIME_INTERVAL, ds.getTimeInterval());
 }
 assertEquals((int) drp.getBytesThreshold(), ds.getQueueSize());
 int dirnum = drp.getDiskDirs().length;
 int dirnum2 = ds.getDiskDirs().length;
 int[] diskSizes = drp.getDiskDirSizes();
 int[] ds_diskSizes = ds.getDiskDirSizes();
 assertEquals(dirnum, dirnum2);
 if (diskSizes == null) {
  diskSizes = new int[dirnum];
  java.util.Arrays.fill(diskSizes, Integer.MAX_VALUE);
 }
 for (int i = 0; i < dirnum; i++) {
  assertTrue("diskSizes not matching", diskSizes[i] == ds_diskSizes[i]);
 }
 assertEquals(DiskStoreFactory.DEFAULT_DISK_USAGE_WARNING_PERCENTAGE,
   ds.getDiskUsageWarningPercentage(), 0.01);
 assertEquals(DiskStoreFactory.DEFAULT_DISK_USAGE_CRITICAL_PERCENTAGE,
   ds.getDiskUsageCriticalPercentage(), 0.01);
}

代码示例来源：origin: apache/geode

this.isDiskSynchronous = attrs.isDiskSynchronous();
if (this.diskStoreName == null) {
 this.diskWriteAttributes = attrs.getDiskWriteAttributes();

代码示例来源：origin: apache/geode

this.regionAttributes.diskSizes = regionAttributes.getDiskDirSizes();
this.regionAttributes.diskSynchronous = regionAttributes.isDiskSynchronous();
this.regionAttributes.indexMaintenanceSynchronous =
  regionAttributes.getIndexMaintenanceSynchronous();

代码示例来源：origin: apache/geode

this.cloningEnable = attr.getCloningEnabled();
this.poolName = attr.getPoolName();
this.isDiskSynchronous = attr.isDiskSynchronous();
this.gatewaySendersDescs = getDescs(attr.getGatewaySenderIds().toArray());
this.asyncEventQueueDescs = getDescs(attr.getAsyncEventQueueIds().toArray());

代码示例来源：origin: apache/geode

assertEquals(MirrorType.NONE, attrs.getMirrorType());
assertEquals(null, attrs.getDiskStoreName());
assertEquals(AttributesFactory.DEFAULT_DISK_SYNCHRONOUS, attrs.isDiskSynchronous());
assertNull(attrs.getKeyConstraint());
assertEquals(16, attrs.getInitialCapacity());

代码示例来源：origin: apache/geode

if (parentIsUserSpecified) {
 if (parentWithHas.hasDiskSynchronous()) {
  setDiskSynchronous(parent.isDiskSynchronous());
 setDiskSynchronous(parent.isDiskSynchronous());

代码示例来源：origin: org.springframework.data/spring-data-geode-test

when(mockRegionAttributes.getDataPolicy()).thenAnswer(newGetter(dataPolicy));
when(mockRegionAttributes.getDiskStoreName()).thenAnswer(newGetter(diskStoreName));
when(mockRegionAttributes.isDiskSynchronous()).thenAnswer(newGetter(diskSynchronous));
when(mockRegionAttributes.getEntryIdleTimeout()).thenAnswer(newGetter(entryIdleTimeout));
when(mockRegionAttributes.getEntryTimeToLive()).thenAnswer(newGetter(entryTimeToLive));

代码示例来源：origin: org.springframework.data/spring-data-geode-test

when(mockRegionAttributes.getDataPolicy()).thenAnswer(newGetter(dataPolicy));
when(mockRegionAttributes.getDiskStoreName()).thenAnswer(newGetter(diskStoreName));
when(mockRegionAttributes.isDiskSynchronous()).thenAnswer(newGetter(diskSynchronous));
when(mockRegionAttributes.getEnableAsyncConflation()).thenAnswer(newGetter(enableAsyncConflation));
when(mockRegionAttributes.getEnableSubscriptionConflation()).thenAnswer(newGetter(enableSubscriptionConflation));

代码示例来源：origin: org.springframework.data/spring-data-geode-test

when(mockRegionAttributes.getSubscriptionAttributes()).thenAnswer(newGetter(baseRegionAttributes::getSubscriptionAttributes));
when(mockRegionAttributes.getValueConstraint()).thenAnswer(newGetter(baseRegionAttributes::getValueConstraint));
when(mockRegionAttributes.isDiskSynchronous()).thenAnswer(newGetter(baseRegionAttributes::isDiskSynchronous));
when(mockRegionAttributes.isLockGrantor()).thenAnswer(newGetter(baseRegionAttributes::isLockGrantor));

代码示例来源：origin: org.springframework.data/spring-data-geode

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

代码示例来源：origin: org.springframework.data/spring-data-gemfire

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

代码示例来源：origin: org.springframework.data/spring-data-geode

regionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
regionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
regionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
regionFactory.setEnableAsyncConflation(regionAttributes.getEnableAsyncConflation());
regionFactory.setEnableSubscriptionConflation(regionAttributes.getEnableSubscriptionConflation());

代码示例来源：origin: org.springframework.data/spring-data-gemfire

regionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
regionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
regionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
regionFactory.setEnableAsyncConflation(regionAttributes.getEnableAsyncConflation());
regionFactory.setEnableSubscriptionConflation(regionAttributes.getEnableSubscriptionConflation());

内容来源于网络，如有侵权，请联系作者删除！

RegionAttributes

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RegionAttributes类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com