net.sf.ehcache.config.Configuration.isMaxBytesLocalDiskSet()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(16.3k)|赞(0)|评价(0)|浏览(62)

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

Configuration.isMaxBytesLocalDiskSet介绍

[英]Checks whether the user explicitly set the maxBytesOnDisk
[中]检查用户是否显式设置maxBytesOnDisk

代码示例

代码示例来源:origin: net.sf.ehcache/ehcache

@Override
  public void maxBytesLocalDiskChanged(final long oldValue, final long newValue) {
    if (getMaxBytesLocalDisk() > 0
      && cacheManager.getConfiguration().getCacheConfigurations().keySet().contains(getName())
      && cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      long previous = cacheManager.getOnDiskPool().getMaxSize();
      long newPoolFreeSize = previous + oldValue - newValue;
      //handle case of overallocation of cache
      //Only resize the cache manager pool cache pool resizing will be handled by cache
      if (newPoolFreeSize >= 0) {
        cacheManager.getOnDiskPool().setMaxSize(newPoolFreeSize);
      } else {
        LOG.warn("Cannot allocate local disk size more than cache disk size, " +
            "setting maxBytesLocalDisk {} to old value {}", maxBytesLocalDisk, oldValue);
        maxBytesLocalDisk = oldValue;
        throw new InvalidConfigurationException("Cannot allocate disk size more than " +
            "the cache pool size reverting to previous size " + maxBytesLocalHeap);
      }
    }
  }
}

代码示例来源:origin: net.sf.ehcache/ehcache

/**
 * {@inheritDoc}
 */
@Override
public void setMaxBytesLocalDisk(long maxBytes) {
  try {
    if (cache.getCacheManager().getConfiguration().isMaxBytesLocalDiskSet()) {
      long diskPoolSize = cache.getCacheManager().getConfiguration().getMaxBytesLocalDisk();
      if (maxBytes > diskPoolSize) {
        throw new IllegalArgumentException("Requested maxBytesLocalDisk (" + maxBytes
            + ") greater than available CacheManager disk pool size (" + diskPoolSize + ")");
      }
    }
    cache.getCacheConfiguration().setMaxBytesLocalDisk(maxBytes);
  } catch (RuntimeException e) {
    throw Utils.newPlainException(e);
  }
}

代码示例来源:origin: net.sf.ehcache/ehcache

/**
 * Validates the CacheConfiguration against the CacheManager's Configuration
 * @param configuration The CacheManager Configuration
 * @return the list of errors encountered, or an empty list
 */
List<CacheConfigError> validateCachePools(final Configuration configuration) {
  List<CacheConfigError> errors = new ArrayList<CacheConfigError>();
  if (configuration.isMaxBytesLocalHeapSet()
    && getMaxEntriesLocalHeap() > 0) {
    errors.add(new CacheConfigError("maxEntriesLocalHeap is not compatible with " +
                    "maxBytesLocalHeap set on cache manager", getName()));
  }
  if (getMaxBytesLocalHeap() > 0 && getMaxEntriesLocalHeap() > 0) {
    errors.add(new CacheConfigError("maxEntriesLocalHeap is not compatible with " +
                    "maxBytesLocalHeap set on cache", getName()));
  }
  if (isMaxBytesLocalHeapPercentageSet() && !configuration.isMaxBytesLocalHeapSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOnHeap value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  if (isMaxBytesLocalOffHeapPercentageSet() && !configuration.isMaxBytesLocalOffHeapSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOffHeap value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  if (isMaxBytesLocalDiskPercentageSet() && !configuration.isMaxBytesLocalDiskSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOnDisk value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  return errors;
}

代码示例来源:origin: net.sf.ehcache/ehcache

private boolean skipUpdateAccessStatistics(Element element) {
 if (configuration.isFrozen()) {
  boolean forLifetime = element.isEternal();
  boolean forHeap =  configuration.getMaxEntriesLocalHeap() > 0 || configuration.getMaxBytesLocalHeap() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalHeapSet();
  boolean forDisk = configuration.isOverflowToDisk() && (configuration.getMaxEntriesLocalDisk() > 0 || configuration.getMaxBytesLocalDisk() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalDiskSet());
  return !(forLifetime || forHeap || forDisk);
 } else {
  return false;
 }
}

代码示例来源:origin: net.sf.ehcache/ehcache

private void freezePoolUsages(final CacheManager cacheManager) {
  if (getMaxBytesLocalHeap() > 0) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalHeapSet()) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (getMaxBytesLocalOffHeap() > 0) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalOffHeapSet()) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (isTerracottaClustered()) {
    onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
  } else {
    if (getMaxBytesLocalDisk() > 0) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.Cache;
    } else if (cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
    } else {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
    }
  }
}

代码示例来源:origin: net.sf.ehcache/ehcache

this.onHeapPool = new BoundedPool(configuration.getMaxBytesLocalHeap(), evictor, sizeOfEngine);
if (configuration.isMaxBytesLocalDiskSet()) {
  PoolEvictor evictor = new BalancedAccessEvictor();
  this.onDiskPool = new BoundedPool(configuration.getMaxBytesLocalDisk(), evictor, null);

代码示例来源:origin: net.sf.ehcache/ehcache

registerCacheConfiguration(cacheManager);
if (cacheManager.getConfiguration().isMaxBytesLocalHeapSet() || cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
  overflowToDisk = true;
if (overflowToDisk == null && cacheManager.getConfiguration().isMaxBytesLocalDiskSet() || getMaxBytesLocalDisk() > 0) {
  if (persistenceConfiguration != null && Strategy.LOCALRESTARTABLE.equals(persistenceConfiguration.getStrategy())) {
    throw new InvalidConfigurationException("Cannot use localRestartable persistence and disk overflow in the same cache");

代码示例来源:origin: net.sf.ehcache/ehcache

PoolEvictor evictor = new FromLargestCachePoolEvictor();
  onDiskPool = new BoundedPool(configuration.getMaxBytesLocalDisk(), evictor, null);
} else if (getCacheManager() != null && getCacheManager().getConfiguration().isMaxBytesLocalDiskSet()) {
  onDiskPool = getCacheManager().getOnDiskPool();
} else {

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache

@Override
  public void maxBytesLocalDiskChanged(final long oldValue, final long newValue) {
    if (getMaxBytesLocalDisk() > 0
      && cacheManager.getConfiguration().getCacheConfigurations().keySet().contains(getName())
      && cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      long previous = cacheManager.getOnDiskPool().getMaxSize();
      cacheManager.getOnDiskPool().setMaxSize(previous + oldValue - newValue);
    }
  }
});

代码示例来源:origin: net.sf.ehcache.internal/ehcache-core

@Override
  public void maxBytesLocalDiskChanged(final long oldValue, final long newValue) {
    if (getMaxBytesLocalDisk() > 0
      && cacheManager.getConfiguration().getCacheConfigurations().keySet().contains(getName())
      && cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      long previous = cacheManager.getOnDiskPool().getMaxSize();
      long newPoolFreeSize = previous + oldValue - newValue;
      //handle case of overallocation of cache
      //Only resize the cache manager pool cache pool resizing will be handled by cache
      if (newPoolFreeSize >= 0) {
        cacheManager.getOnDiskPool().setMaxSize(newPoolFreeSize);
      } else {
        LOG.warn("Cannot allocate local disk size more than cache disk size, " +
            "setting maxBytesLocalDisk {} to old value {}", maxBytesLocalDisk, oldValue);
        maxBytesLocalDisk = oldValue;
        throw new InvalidConfigurationException("Cannot allocate disk size more than " +
            "the cache pool size reverting to previous size " + maxBytesLocalHeap);
      }
    }
  }
}

代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache

@Override
  public void maxBytesLocalDiskChanged(final long oldValue, final long newValue) {
    if (getMaxBytesLocalDisk() > 0
      && cacheManager.getConfiguration().getCacheConfigurations().keySet().contains(getName())
      && cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      long previous = cacheManager.getOnDiskPool().getMaxSize();
      long newPoolFreeSize = previous + oldValue - newValue;
      //handle case of overallocation of cache
      //Only resize the cache manager pool cache pool resizing will be handled by cache
      if (newPoolFreeSize >= 0) {
        cacheManager.getOnDiskPool().setMaxSize(newPoolFreeSize);
      } else {
        LOG.warn("Cannot allocate local disk size more than cache disk size, " +
            "setting maxBytesLocalDisk {} to old value {}", maxBytesLocalDisk, oldValue);
        maxBytesLocalDisk = oldValue;
        throw new InvalidConfigurationException("Cannot allocate disk size more than " +
            "the cache pool size reverting to previous size " + maxBytesLocalHeap);
      }
    }
  }
}

代码示例来源:origin: net.sf.ehcache.internal/ehcache-core

/**
 * {@inheritDoc}
 */
@Override
public void setMaxBytesLocalDisk(long maxBytes) {
  try {
    if (cache.getCacheManager().getConfiguration().isMaxBytesLocalDiskSet()) {
      long diskPoolSize = cache.getCacheManager().getConfiguration().getMaxBytesLocalDisk();
      if (maxBytes > diskPoolSize) {
        throw new IllegalArgumentException("Requested maxBytesLocalDisk (" + maxBytes
            + ") greater than available CacheManager disk pool size (" + diskPoolSize + ")");
      }
    }
    cache.getCacheConfiguration().setMaxBytesLocalDisk(maxBytes);
  } catch (RuntimeException e) {
    throw Utils.newPlainException(e);
  }
}

代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache

/**
 * {@inheritDoc}
 */
@Override
public void setMaxBytesLocalDisk(long maxBytes) {
  try {
    if (cache.getCacheManager().getConfiguration().isMaxBytesLocalDiskSet()) {
      long diskPoolSize = cache.getCacheManager().getConfiguration().getMaxBytesLocalDisk();
      if (maxBytes > diskPoolSize) {
        throw new IllegalArgumentException("Requested maxBytesLocalDisk (" + maxBytes
            + ") greater than available CacheManager disk pool size (" + diskPoolSize + ")");
      }
    }
    cache.getCacheConfiguration().setMaxBytesLocalDisk(maxBytes);
  } catch (RuntimeException e) {
    throw Utils.newPlainException(e);
  }
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache

/**
 * {@inheritDoc}
 */
public void setMaxBytesLocalDisk(long maxBytes) {
  try {
    if (cache.getCacheManager().getConfiguration().isMaxBytesLocalDiskSet()) {
      long diskPoolSize = cache.getCacheManager().getConfiguration().getMaxBytesLocalDisk();
      if (maxBytes > diskPoolSize) {
        throw new IllegalArgumentException("Requested maxBytesLocalDisk ("
                          + maxBytes + ") greater than available CacheManager disk pool size ("
                          + diskPoolSize + ")");
      }
    }
    cache.getCacheConfiguration().setMaxBytesLocalDisk(maxBytes);
  } catch (RuntimeException e) {
    throw Utils.newPlainException(e);
  }
}

代码示例来源:origin: net.sf.ehcache.internal/ehcache-core

/**
 * Validates the CacheConfiguration against the CacheManager's Configuration
 * @param configuration The CacheManager Configuration
 * @return the list of errors encountered, or an empty list
 */
List<CacheConfigError> validateCachePools(final Configuration configuration) {
  List<CacheConfigError> errors = new ArrayList<CacheConfigError>();
  if (configuration.isMaxBytesLocalHeapSet()
    && getMaxEntriesLocalHeap() > 0) {
    errors.add(new CacheConfigError("maxEntriesLocalHeap is not compatible with " +
                    "maxBytesLocalHeap set on cache manager", getName()));
  }
  if (getMaxBytesLocalHeap() > 0 && getMaxEntriesLocalHeap() > 0) {
    errors.add(new CacheConfigError("maxEntriesLocalHeap is not compatible with " +
                    "maxBytesLocalHeap set on cache", getName()));
  }
  if (isMaxBytesLocalHeapPercentageSet() && !configuration.isMaxBytesLocalHeapSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOnHeap value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  if (isMaxBytesLocalOffHeapPercentageSet() && !configuration.isMaxBytesLocalOffHeapSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOffHeap value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  if (isMaxBytesLocalDiskPercentageSet() && !configuration.isMaxBytesLocalDiskSet()) {
    errors.add(new CacheConfigError("Defines a percentage maxBytesOnDisk value but no CacheManager " +
                    "wide value was configured", getName()));
  }
  return errors;
}

代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache

private boolean skipUpdateAccessStatistics(Element element) {
 if (configuration.isFrozen()) {
  boolean forLifetime = element.isEternal();
  boolean forHeap =  configuration.getMaxEntriesLocalHeap() > 0 || configuration.getMaxBytesLocalHeap() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalHeapSet();
  boolean forDisk = configuration.isOverflowToDisk() && (configuration.getMaxEntriesLocalDisk() > 0 || configuration.getMaxBytesLocalDisk() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalDiskSet());
  return !(forLifetime || forHeap || forDisk);
 } else {
  return false;
 }
}

代码示例来源:origin: net.sf.ehcache.internal/ehcache-core

private boolean skipUpdateAccessStatistics(Element element) {
 if (configuration.isFrozen()) {
  boolean forLifetime = element.isEternal();
  boolean forHeap =  configuration.getMaxEntriesLocalHeap() > 0 || configuration.getMaxBytesLocalHeap() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalHeapSet();
  boolean forDisk = configuration.isOverflowToDisk() && (configuration.getMaxEntriesLocalDisk() > 0 || configuration.getMaxBytesLocalDisk() > 0
      || getCacheManager().getConfiguration().isMaxBytesLocalDiskSet());
  return !(forLifetime || forHeap || forDisk);
 } else {
  return false;
 }
}

代码示例来源:origin: net.sf.ehcache.internal/ehcache-core

private void freezePoolUsages(final CacheManager cacheManager) {
  if (getMaxBytesLocalHeap() > 0) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalHeapSet()) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (getMaxBytesLocalOffHeap() > 0) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalOffHeapSet()) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (isTerracottaClustered()) {
    onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
  } else {
    if (getMaxBytesLocalDisk() > 0) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.Cache;
    } else if (cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
    } else {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
    }
  }
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.ehcache

private void freezePoolUsages(final CacheManager cacheManager) {
  if (getMaxBytesLocalHeap() > 0) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalHeapSet()) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (getMaxBytesLocalOffHeap() > 0) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalOffHeapSet()) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (isTerracottaClustered()) {
    onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
  } else {
    if (getMaxBytesLocalDisk() > 0) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.Cache;
    } else if (cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
    } else {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
    }
  }
}

代码示例来源:origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache

private void freezePoolUsages(final CacheManager cacheManager) {
  if (getMaxBytesLocalHeap() > 0) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalHeapSet()) {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    onHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (getMaxBytesLocalOffHeap() > 0) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.Cache;
  } else if (cacheManager.getConfiguration().isMaxBytesLocalOffHeapSet()) {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
  } else {
    offHeapPoolUsage = CacheConfiguration.PoolUsage.None;
  }
  if (isTerracottaClustered()) {
    onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
  } else {
    if (getMaxBytesLocalDisk() > 0) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.Cache;
    } else if (cacheManager.getConfiguration().isMaxBytesLocalDiskSet()) {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.CacheManager;
    } else {
      onDiskPoolUsage = CacheConfiguration.PoolUsage.None;
    }
  }
}

相关文章

微信公众号

最新文章

更多

Configuration类方法