> it = ratios.values().iterator(); it.hasNext();) {
- if (it.next().expire(expiryTime)) {
- it.remove();
- }
- }
- return expired & compounds.isEmpty() & ratios.isEmpty();
- }
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/CounterImpl.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/CounterImpl.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/CounterImpl.java (revision 0)
@@ -1,97 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.util.counter;
-
-import java.io.Serializable;
-import java.util.concurrent.atomic.AtomicLong;
-
-/**
- * A simple counter implementation
- *
- * @author Abhishek Sanoujam
- * @since 1.7
- *
- */
-public class CounterImpl implements Counter, Serializable {
- private AtomicLong value;
-
- /**
- * Default Constructor
- */
- public CounterImpl() {
- this(0L);
- }
-
- /**
- * Constructor with initial value
- *
- * @param initialValue
- */
- public CounterImpl(long initialValue) {
- this.value = new AtomicLong(initialValue);
- }
-
- /**
- * {@inheritDoc}
- */
- public long increment() {
- return value.incrementAndGet();
- }
-
- /**
- * {@inheritDoc}
- */
- public long decrement() {
- return value.decrementAndGet();
- }
-
- /**
- * {@inheritDoc}
- */
- public long getAndSet(long newValue) {
- return value.getAndSet(newValue);
- }
-
- /**
- * {@inheritDoc}
- */
- public long getValue() {
- return value.get();
- }
-
- /**
- * {@inheritDoc}
- */
- public long increment(long amount) {
- return value.addAndGet(amount);
- }
-
- /**
- * {@inheritDoc}
- */
- public long decrement(long amount) {
- return value.addAndGet(amount * -1);
- }
-
- /**
- * {@inheritDoc}
- */
- public void setValue(long newValue) {
- value.set(newValue);
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/MemorySizeParser.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/MemorySizeParser.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/MemorySizeParser.java (revision 0)
@@ -1,114 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.util;
-
-/**
- * Memory size parser using the letter k or K to indicate kilobytes, the letter m or M to indicate megabytes,
- * the letter g or G to indicate gigabytes and the letter t or T to indicate terabytes.
- *
- * @author Ludovic Orban
- */
-public class MemorySizeParser {
- private static final long BYTE = 1;
- private static final long KILOBYTE = 1024;
- private static final long MEGABYTE = 1024 * KILOBYTE;
- private static final long GIGABYTE = 1024 * MEGABYTE;
- private static final long TERABYTE = 1024 * GIGABYTE;
-
- /**
- * Parse a String containing a human-readable memory size.
- *
- * @param configuredMemorySize the String containing a human-readable memory size.
- * @return the memory size in bytes.
- * @throws IllegalArgumentException thrown when the configured memory size cannot be parsed.
- */
- public static long parse(String configuredMemorySize) throws IllegalArgumentException {
- MemorySize size = parseIncludingUnit(configuredMemorySize);
- return size.calculateMemorySizeInBytes();
- }
-
- private static MemorySize parseIncludingUnit(String configuredMemorySize) throws IllegalArgumentException {
- if (configuredMemorySize == null || "".equals(configuredMemorySize)) {
- return new MemorySize("0", BYTE);
- }
-
- char unit = configuredMemorySize.charAt(configuredMemorySize.length() - 1);
- MemorySize memorySize;
-
- switch (unit) {
- case 'k':
- case 'K':
- memorySize = toMemorySize(configuredMemorySize, KILOBYTE);
- break;
- case 'm':
- case 'M':
- memorySize = toMemorySize(configuredMemorySize, MEGABYTE);
- break;
- case 'g':
- case 'G':
- memorySize = toMemorySize(configuredMemorySize, GIGABYTE);
- break;
- case 't':
- case 'T':
- memorySize = toMemorySize(configuredMemorySize, TERABYTE);
- break;
- default:
- try {
- Integer.parseInt("" + unit);
- } catch (NumberFormatException e) {
- throw new IllegalArgumentException("invalid format for memory size [" + configuredMemorySize + "]");
- }
- memorySize = new MemorySize(configuredMemorySize, BYTE);
- }
-
- return memorySize;
- }
-
- private static MemorySize toMemorySize(String configuredMemorySize, long unitMultiplier) {
- if (configuredMemorySize.length() < 2) {
- throw new IllegalArgumentException("invalid format for memory size [" + configuredMemorySize + "]");
- }
- return new MemorySize(configuredMemorySize.substring(0, configuredMemorySize.length() - 1), unitMultiplier);
- }
-
- /**
- * Memory size calculator.
- */
- private static final class MemorySize {
- private String configuredMemorySizeWithoutUnit;
- private long multiplicationFactor;
-
- private MemorySize(String configuredMemorySizeWithoutUnit, long multiplicationFactor) {
- this.configuredMemorySizeWithoutUnit = configuredMemorySizeWithoutUnit;
- this.multiplicationFactor = multiplicationFactor;
- }
-
- public long calculateMemorySizeInBytes() throws IllegalArgumentException {
- try {
- long memorySizeLong = Long.parseLong(configuredMemorySizeWithoutUnit);
- long result = memorySizeLong * multiplicationFactor;
- if (result < 0) {
- throw new IllegalArgumentException("memory size cannot be negative");
- }
- return result;
- } catch (NumberFormatException e) {
- throw new IllegalArgumentException("invalid format for memory size");
- }
- }
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/RMICacheReplicatorWithLargePayloadIT.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/RMICacheReplicatorWithLargePayloadIT.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/RMICacheReplicatorWithLargePayloadIT.java (revision 0)
@@ -1,269 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.distribution;
-
-import static net.sf.ehcache.util.RetryAssert.assertBy;
-import static org.hamcrest.collection.IsCollectionWithSize.hasSize;
-import static org.hamcrest.core.Is.is;
-import static org.hamcrest.core.IsNull.notNullValue;
-import static org.hamcrest.core.IsNull.nullValue;
-import static org.hamcrest.number.OrderingComparison.greaterThan;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.fail;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.Callable;
-import java.util.concurrent.TimeUnit;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import net.sf.ehcache.AbstractCacheTest;
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.config.Configuration;
-import net.sf.ehcache.util.RetryAssert;
-
-import org.hamcrest.collection.IsEmptyCollection;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-/**
- * Tests replication of Cache events with large payloads exceeding MTU
- *
- * Note these tests need a live network interface running in multicast mode to work
- *
- *
- * @author Abhishek Sanoujam
- */
-public class RMICacheReplicatorWithLargePayloadIT extends AbstractRMITest {
-
- private static final Logger LOG = Logger.getLogger(RMICacheReplicatorWithLargePayloadIT.class.getName());
-
- private static int MB = 1024 * 1024;
-
- /**
- * {@inheritDoc} Sets up two caches: cache1 is local. cache2 is to be receive updates
- *
- * @throws Exception
- */
- @Before
- public void setUp() throws Exception {
- failFastInsufficientMemory();
- assertThat(getActiveReplicationThreads(), IsEmptyCollection.empty());
- }
-
- private void failFastInsufficientMemory() {
- // fail fast if running with insufficient heap
- long totalMemory = Runtime.getRuntime().totalMemory();
- if (totalMemory < 200 * MB) {
- String msg = "Insufficient heap (approx. " + (totalMemory / MB) + " MB detected), this test requires at least 256 MB to run.\n";
- msg += "Steps to take:\n";
- msg += " 1) If you are running with eclipse: specify \"-Xms256m -Xmx256m\" as VM arguments in the \"Run Confuguration\" for this test\n";
- msg += " 2) If you are running using mvn with \"mvn test -Dtest=" + this.getClass().getSimpleName()
- + "\", add this in the command line: -DargLine=\"-Xms256m -Xmx256m\"\n";
- msg += " Run the test like: mvn test -Dtest=" + this.getClass().getSimpleName() + " -DargLine=\"-Xms256m -Xmx256m\"";
- LOG.log(Level.WARNING, msg);
- fail(msg);
- }
- }
-
- @After
- public void noReplicationThreads() throws Exception {
- RetryAssert.assertBy(30, TimeUnit.SECONDS, new Callable>() {
- @Override
- public Set call() throws Exception {
- return getActiveReplicationThreads();
- }
- }, IsEmptyCollection.empty());
- }
-
- private static List createCluster(int size, String ... caches){
- LOG.info("Creating Cluster");
- Collection required = Arrays.asList(caches);
- List configurations = new ArrayList(size);
- for (int i = 1; i <= size; i++) {
- Configuration config = getConfiguration(AbstractCacheTest.TEST_CONFIG_DIR + "distribution/ehcache-distributed-big-payload-" + i + ".xml").name("cm" + i);
- if (!required.isEmpty()) {
- for (Iterator> it = config.getCacheConfigurations().entrySet().iterator(); it.hasNext(); ) {
- if (!required.contains(it.next().getKey())) {
- it.remove();
- }
- }
- }
- configurations.add(config);
- }
- LOG.info("Created Configurations");
-
- List members = startupManagers(configurations);
- try {
- LOG.info("Created Managers");
- if (required.isEmpty()) {
- waitForClusterMembership(10, TimeUnit.SECONDS, members);
- LOG.info("Cluster Membership Complete");
- emptyCaches(10, TimeUnit.SECONDS, members);
- LOG.info("Caches Emptied");
- } else {
- waitForClusterMembership(10, TimeUnit.SECONDS, required, members);
- emptyCaches(10, TimeUnit.SECONDS, required, members);
- }
- return members;
- } catch (RuntimeException e) {
- destroyCluster(members);
- throw e;
- } catch (Error e) {
- destroyCluster(members);
- throw e;
- }
- }
-
- private static void destroyCluster(List members) {
- for (CacheManager manager : members) {
- if (manager != null) {
- manager.shutdown();
- }
- }
- }
-
- @Test
- public void testAssertBigPayload() {
- List cluster = createCluster(3);
- try {
- for (CacheManager manager : cluster) {
- List localPeers = cluster.get(0).getCachePeerListener("RMI").getBoundCachePeers();
- List payloadList = PayloadUtil.createCompressedPayloadList(localPeers, 150);
- assertThat(manager.getName(), payloadList, hasSize(greaterThan(1)));
- }
-
- cluster.add(new CacheManager(AbstractCacheTest.TEST_CONFIG_DIR + "distribution/ehcache-distributed-big-payload-4.xml"));
-
- List localPeers = cluster.get(3).getCachePeerListener("RMI").getBoundCachePeers();
- List payloadList = PayloadUtil.createCompressedPayloadList(localPeers, 150);
- assertThat(payloadList, hasSize(greaterThan(1)));
- } finally {
- destroyCluster(cluster);
- }
- }
-
- /**
- * Does a new cache manager in the cluster get detected?
- */
- @Test
- public void testRemoteCachePeersDetectsNewCacheManager() throws InterruptedException {
- List cluster = createCluster(3);
- try {
- //Add new CacheManager to cluster
- cluster.add(new CacheManager(AbstractCacheTest.TEST_CONFIG_DIR + "distribution/ehcache-distributed-big-payload-4.xml"));
-
- //Allow detection to occur
- waitForClusterMembership(10020, TimeUnit.MILLISECONDS, cluster);
- } finally {
- destroyCluster(cluster);
- }
- }
-
- /**
- * Does a down cache manager in the cluster get removed?
- */
- @Test
- public void testRemoteCachePeersDetectsDownCacheManager() throws InterruptedException {
- List cluster = createCluster(3);
- try {
- MulticastKeepaliveHeartbeatSender.setHeartBeatStaleTime(3000);
- //Drop a CacheManager from the cluster
- cluster.remove(2).shutdown();
- assertThat(cluster, hasSize(2));
-
- //Allow change detection to occur. Heartbeat 1 second and is not stale until 5000
- waitForClusterMembership(11020, TimeUnit.MILLISECONDS, cluster);
- } finally {
- destroyCluster(cluster);
- }
- }
-
- /**
- * Does a down cache manager in the cluster get removed?
- */
- @Test
- public void testRemoteCachePeersDetectsDownCacheManagerSlow() throws InterruptedException {
- List cluster = createCluster(3);
- try {
- CacheManager manager = cluster.get(0);
-
- Thread.sleep(2000);
-
- //Drop a CacheManager from the cluster
- cluster.remove(2).shutdown();
-
- //Insufficient time for it to timeout
- CacheManagerPeerProvider provider = manager.getCacheManagerPeerProvider("RMI");
- for (String cacheName : manager.getCacheNames()) {
- List remotePeersOfCache1 = provider.listRemoteCachePeers(manager.getCache(cacheName));
- assertThat((List) remotePeersOfCache1, hasSize(2));
- }
- } finally {
- destroyCluster(cluster);
- }
- }
-
- /**
- * Tests put and remove initiated from cache1 in a cluster
- *
- * This test goes into an infinite loop if the chain of notifications is not somehow broken.
- */
- @Test
- public void testPutProgagatesFromAndToEveryCacheManagerAndCache() throws CacheException, InterruptedException {
- final List cluster = createCluster(3);
- try {
- final CacheManager manager0 = cluster.get(0);
- //Put
- final String[] cacheNames = manager0.getCacheNames();
- Arrays.sort(cacheNames);
- for (int i = 0; i < cacheNames.length; i++) {
- String name = cacheNames[i];
- manager0.getCache(name).put(new Element(Integer.toString(i), Integer.valueOf(i)));
- //Add some non serializable elements that should not get propagated
- manager0.getCache(name).put(new Element("nonSerializable" + i, new Object()));
- }
-
- assertBy(10, TimeUnit.SECONDS, new Callable() {
-
- public Boolean call() throws Exception {
- for (int i = 0; i < cacheNames.length; i++) {
- String name = cacheNames[i];
- for (CacheManager manager : cluster.subList(1, cluster.size())) {
- assertThat("Cache : " + name, manager.getCache(name).get(Integer.toString(i)), notNullValue());
- assertThat(manager.getCache(name).get("nonSerializable" + i), nullValue());
- }
- }
- return Boolean.TRUE;
- }
- }, is(Boolean.TRUE));
- } finally {
- destroyCluster(cluster);
- }
-
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/AggregateCacheRegionStats.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/AggregateCacheRegionStats.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/AggregateCacheRegionStats.java (revision 0)
@@ -1,62 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.hibernate.management.impl;
-
-/**
- * @author gkeim
- *
- */
-public class AggregateCacheRegionStats extends CacheRegionStats {
- private int nodeCount;
-
- /**
- * @param region
- */
- public AggregateCacheRegionStats(String region) {
- super(region);
- }
-
- /**
- * @param stats
- */
- public void aggregate(CacheRegionStats stats) {
- nodeCount++;
- hitCount += stats.getHitCount();
- missCount += stats.getMissCount();
- putCount += stats.getPutCount();
- hitRatio = determineHitRatio();
-
- // just add the in memory count together, an average will be returned when the getter is used
- elementCountInMemory += stats.getElementCountInMemory();
-
- // the largest element count on disk is the one that is the most correct
- if (stats.getElementCountOnDisk() > elementCountOnDisk) {
- elementCountOnDisk = stats.getElementCountOnDisk();
- }
- // elementCountTotal is the same for each node, since it's the total count in the cluster
- // no real aggregation is needed, just use the same total count
- elementCountTotal = stats.getElementCountTotal();
- }
-
- /**
- * @see net.sf.ehcache.hibernate.management.impl.CacheRegionStats#getElementCountInMemory()
- */
- @Override
- public long getElementCountInMemory() {
- return elementCountInMemory / nodeCount;
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/event/NullCacheEventListenerFactory.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/event/NullCacheEventListenerFactory.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/event/NullCacheEventListenerFactory.java (revision 0)
@@ -1,40 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.event;
-
-import java.util.Properties;
-
-/**
- * A factory for NullCacheEventListener
- *
- * @author Greg Luck
- * @version $Id: NullCacheEventListenerFactory.java 5594 2012-05-07 16:04:31Z cdennis $
- */
-public class NullCacheEventListenerFactory extends CacheEventListenerFactory {
-
- /**
- * Create a CacheEventListener
- *
- * @param properties implementation specific properties. These are configured as comma
- * separated name value pairs in ehcache.xml
- * @return a constructed CacheEventListener
- */
- public CacheEventListener createCacheEventListener(Properties properties) {
- return new NullCacheEventListener();
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/ElementIdAssigningStore.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/ElementIdAssigningStore.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/ElementIdAssigningStore.java (revision 0)
@@ -1,477 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.store;
-
-import java.io.IOException;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.ElementIdHelper;
-import net.sf.ehcache.Status;
-import net.sf.ehcache.search.Attribute;
-import net.sf.ehcache.search.Results;
-import net.sf.ehcache.search.SearchException;
-import net.sf.ehcache.search.attribute.AttributeExtractor;
-import net.sf.ehcache.terracotta.TerracottaNotRunningException;
-import net.sf.ehcache.util.LongSequence;
-import net.sf.ehcache.writer.CacheWriterManager;
-import org.terracotta.context.annotations.ContextChild;
-
-/**
- * Store wrapper that assigns sequential IDs to elements as they are added to the underlying store
- *
- * @author teck
- */
-public class ElementIdAssigningStore implements Store {
-
- @ContextChild
- private final Store delegate;
- private final LongSequence elementIdSequence;
-
- /**
- * Constructor
- *
- * @param delegate underlying Store
- * @param sequence id sequence
- */
- public ElementIdAssigningStore(Store delegate, LongSequence sequence) {
- this.delegate = delegate;
- this.elementIdSequence = sequence;
- }
-
- private void setId(Element element) {
- long id = elementIdSequence.next();
- if (id <= 0) {
- throw new CacheException("Element ID must be > 0");
- }
-
- ElementIdHelper.setId(element, id);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void addStoreListener(StoreListener listener) {
- delegate.addStoreListener(listener);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void removeStoreListener(StoreListener listener) {
- delegate.removeStoreListener(listener);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean put(Element element) throws CacheException {
- setId(element);
- return delegate.put(element);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void putAll(Collection elements) throws CacheException {
- for (Element e : elements) {
- setId(e);
- }
- delegate.putAll(elements);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean putWithWriter(Element element, CacheWriterManager writerManager) throws CacheException {
- setId(element);
- return delegate.putWithWriter(element, writerManager);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element get(Object key) {
- return delegate.get(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element getQuiet(Object key) {
- return delegate.getQuiet(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public List getKeys() {
- return delegate.getKeys();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element remove(Object key) {
- return delegate.remove(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void removeAll(Collection keys) {
- delegate.removeAll(keys);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element removeWithWriter(Object key, CacheWriterManager writerManager) throws CacheException {
- return delegate.removeWithWriter(key, writerManager);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void removeAll() throws CacheException {
- delegate.removeAll();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element putIfAbsent(Element element) throws NullPointerException {
- setId(element);
- return delegate.putIfAbsent(element);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element removeElement(Element element, ElementValueComparator comparator) throws NullPointerException {
- return delegate.removeElement(element, comparator);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean replace(Element old, Element element, ElementValueComparator comparator) throws NullPointerException,
- IllegalArgumentException {
- setId(element);
- return delegate.replace(old, element, comparator);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element replace(Element element) throws NullPointerException {
- setId(element);
- return delegate.replace(element);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void dispose() {
- delegate.dispose();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getSize() {
- return delegate.getSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getInMemorySize() {
- return delegate.getInMemorySize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getOffHeapSize() {
- return delegate.getOffHeapSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getOnDiskSize() {
- return delegate.getOnDiskSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getTerracottaClusteredSize() {
- return delegate.getTerracottaClusteredSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getInMemorySizeInBytes() {
- return delegate.getInMemorySizeInBytes();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOffHeapSizeInBytes() {
- return delegate.getOffHeapSizeInBytes();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOnDiskSizeInBytes() {
- return delegate.getOnDiskSizeInBytes();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean hasAbortedSizeOf() {
- return delegate.hasAbortedSizeOf();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Status getStatus() {
- return delegate.getStatus();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean containsKey(Object key) {
- return delegate.containsKey(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean containsKeyOnDisk(Object key) {
- return delegate.containsKeyOnDisk(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean containsKeyOffHeap(Object key) {
- return delegate.containsKeyOffHeap(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean containsKeyInMemory(Object key) {
- return delegate.containsKeyInMemory(key);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void expireElements() {
- delegate.expireElements();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void flush() throws IOException {
- delegate.flush();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean bufferFull() {
- return delegate.bufferFull();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Policy getInMemoryEvictionPolicy() {
- return delegate.getInMemoryEvictionPolicy();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setInMemoryEvictionPolicy(Policy policy) {
- delegate.setInMemoryEvictionPolicy(policy);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Object getInternalContext() {
- return delegate.getInternalContext();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isCacheCoherent() {
- return delegate.isCacheCoherent();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isClusterCoherent() throws TerracottaNotRunningException {
- return delegate.isClusterCoherent();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isNodeCoherent() throws TerracottaNotRunningException {
- return delegate.isNodeCoherent();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setNodeCoherent(boolean coherent) throws UnsupportedOperationException, TerracottaNotRunningException {
- delegate.setNodeCoherent(coherent);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void waitUntilClusterCoherent() throws UnsupportedOperationException, TerracottaNotRunningException, InterruptedException {
- delegate.waitUntilClusterCoherent();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Object getMBean() {
- return delegate.getMBean();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setAttributeExtractors(Map extractors) {
- delegate.setAttributeExtractors(extractors);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Results executeQuery(StoreQuery query) throws SearchException {
- return delegate.executeQuery(query);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Attribute getSearchAttribute(String attributeName) {
- return delegate.getSearchAttribute(attributeName);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Set getSearchAttributes() {
- return delegate.getSearchAttributes();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Map getAllQuiet(Collection keys) {
- return delegate.getAllQuiet(keys);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Map getAll(Collection keys) {
- return delegate.getAll(keys);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void recalculateSize(Object key) {
- delegate.recalculateSize(key);
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/modules/ehcache/l1bm/L1BMCacheManagerRecreateTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/modules/ehcache/l1bm/L1BMCacheManagerRecreateTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/modules/ehcache/l1bm/L1BMCacheManagerRecreateTest.java (revision 0)
@@ -1,55 +0,0 @@
-/*
- * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved.
- */
-package org.terracotta.modules.ehcache.l1bm;
-
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.Element;
-
-import org.junit.Assert;
-import org.terracotta.toolkit.Toolkit;
-import org.terracotta.ehcache.tests.AbstractCacheTestBase;
-import org.terracotta.ehcache.tests.ClientBase;
-
-import com.tc.test.config.model.TestConfig;
-
-public class L1BMCacheManagerRecreateTest extends AbstractCacheTestBase {
-
- public L1BMCacheManagerRecreateTest(TestConfig testConfig) {
- super(testConfig, App.class);
- }
-
- public static class App extends ClientBase {
- private Cache cache;
-
- public App(String[] args) {
- super(args);
- }
-
- @Override
- protected void runTest(Cache testcache, Toolkit clusteringToolkit) throws Throwable {
- cache = testcache;
- for (int i = 0; i < 100; i++) {
- cache.put(new Element("key" + i, "value" + i));
- }
- cleanup();
-
- setup();
- for (int i = 0; i < 100; i++) {
- Element e = cache.get("key" + i);
- Assert.assertNotNull(e);
- Assert.assertEquals("value" + i, e.getObjectValue());
- }
- cleanup();
- }
-
- private void setup() {
- setupCacheManager();
- cache = getCache();
- }
-
- private void cleanup() {
- getCacheManager().shutdown();
- }
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/terracotta/ClusteredInstanceFactoryWrapper.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/terracotta/ClusteredInstanceFactoryWrapper.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/terracotta/ClusteredInstanceFactoryWrapper.java (revision 0)
@@ -1,165 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.terracotta;
-
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.cluster.CacheCluster;
-import net.sf.ehcache.config.Configuration;
-import net.sf.ehcache.event.CacheEventListener;
-import net.sf.ehcache.management.event.ManagementEventSink;
-import net.sf.ehcache.store.Store;
-import net.sf.ehcache.store.TerracottaStore;
-import net.sf.ehcache.transaction.SoftLockManager;
-import net.sf.ehcache.transaction.TransactionIDFactory;
-import net.sf.ehcache.writer.writebehind.WriteBehind;
-
-import java.util.concurrent.Callable;
-
-/**
- * A {@link ClusteredInstanceFactory} implementation that delegates all operations to an underlying delegate except for the following
- * operations:
- *
- * - {@link #getTopology()} : Delegates to the {@link TerracottaClient#getCacheCluster()}
- *
- *
- * @author Abhishek Sanoujam
- *
- */
-public class ClusteredInstanceFactoryWrapper implements ClusteredInstanceFactory {
-
- private final TerracottaClient client;
- private final ClusteredInstanceFactory delegate;
-
- /**
- * Constructor accepting the TerracottaClient and the actual factory
- *
- * @param client
- * @param delegate
- */
- public ClusteredInstanceFactoryWrapper(TerracottaClient client, ClusteredInstanceFactory delegate) {
- this.client = client;
- this.delegate = delegate;
-
- }
-
- /**
- * Returns the actual underlying factory
- *
- * @return the actual underlying factory
- */
- protected ClusteredInstanceFactory getActualFactory() {
- return delegate;
- }
-
- /**
- * {@inheritDoc}
- */
- public CacheCluster getTopology() {
- return client.getCacheCluster();
- }
-
- // all methods below delegate to the real factory
-
- /**
- * {@inheritDoc}
- */
- public String getUUID() {
- return delegate.getUUID();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void enableNonStopForCurrentThread(boolean enable) {
- delegate.enableNonStopForCurrentThread(enable);
- }
-
- /**
- * {@inheritDoc}
- */
- public CacheEventListener createEventReplicator(Ehcache cache) {
- return delegate.createEventReplicator(cache);
- }
-
- /**
- * {@inheritDoc}
- */
- public Store createStore(Ehcache cache) {
- return delegate.createStore(cache);
- }
-
- /**
- * {@inheritDoc}
- */
- public TransactionIDFactory createTransactionIDFactory(String uuid, String cacheManagerName) {
- return delegate.createTransactionIDFactory(uuid, cacheManagerName);
- }
-
- /**
- * {@inheritDoc}
- */
- public WriteBehind createWriteBehind(Ehcache cache) {
- return delegate.createWriteBehind(cache);
- }
-
- /**
- * {@inheritDoc}
- */
- public SoftLockManager getOrCreateSoftLockManager(Ehcache cache) {
- return delegate.getOrCreateSoftLockManager(cache);
- }
-
- /**
- * {@inheritDoc}
- */
- public void shutdown() {
- delegate.shutdown();
- }
-
- @Override
- public TerracottaStore createNonStopStore(Callable store, Ehcache cache) {
- return delegate.createNonStopStore(store, cache);
- }
-
- @Override
- public boolean destroyCache(final String cacheManagerName, final String cacheName) {
- return delegate.destroyCache(cacheManagerName, cacheName);
- }
-
- @Override
- public void linkClusteredCacheManager(String cacheManagerName, Configuration configuration) {
- delegate.linkClusteredCacheManager(cacheManagerName, configuration);
- }
-
- @Override
- public void unlinkCache(String cacheName) {
- delegate.unlinkCache(cacheName);
- }
-
- @Override
- public ManagementEventSink createEventSink() {
- return delegate.createEventSink();
- }
-
- /**
- * {@inheritDoc}
- */
- public void waitForOrchestrator(String cacheManagerName) {
- delegate.waitForOrchestrator(cacheManagerName);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/management-ehcache-impl/management-ehcache-impl-v1/src/main/java/net/sf/ehcache/management/service/impl/CacheManagerEntityBuilder.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/management-ehcache-impl/management-ehcache-impl-v1/src/main/java/net/sf/ehcache/management/service/impl/CacheManagerEntityBuilder.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/management-ehcache-impl/management-ehcache-impl-v1/src/main/java/net/sf/ehcache/management/service/impl/CacheManagerEntityBuilder.java (revision 0)
@@ -1,85 +0,0 @@
-/*
- * All content copyright (c) 2003-2012 Terracotta, Inc., except as may otherwise be noted in a separate copyright
- * notice. All rights reserved.
- */
-package net.sf.ehcache.management.service.impl;
-
-import net.sf.ehcache.management.resource.CacheManagerEntity;
-import net.sf.ehcache.management.sampled.CacheManagerSampler;
-import net.sf.ehcache.management.service.AccessorPrefix;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.management.resource.AgentEntity;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Set;
-
-/**
- * @author brandony
- */
-final class CacheManagerEntityBuilder extends ConstrainableEntityBuilderSupport {
- private static final Logger LOG = LoggerFactory.getLogger(CacheManagerEntityBuilder.class);
-
- private static final String CM_NAME_ACCESSOR = AccessorPrefix.get + "Name";
-
- private final List cmSamplers = new ArrayList();
-
- static CacheManagerEntityBuilder createWith(CacheManagerSampler sampler) {
- return new CacheManagerEntityBuilder(sampler);
- }
-
- CacheManagerEntityBuilder(CacheManagerSampler sampler) {
- addSampler(sampler);
- }
-
- CacheManagerEntityBuilder add(CacheManagerSampler sampler) {
- addSampler(sampler);
- return this;
- }
-
- CacheManagerEntityBuilder add(Set constraintAttributes) {
- addConstraints(constraintAttributes);
- return this;
- }
-
- Collection build() {
- Collection cmes = new ArrayList(cmSamplers.size());
-
- for (CacheManagerSampler cms : cmSamplers) {
- CacheManagerEntity cme = new CacheManagerEntity();
- cme.setName(cms.getName());
- cme.setAgentId(AgentEntity.EMBEDDED_AGENT_ID);
- cme.setVersion(this.getClass().getPackage().getImplementationVersion());
-
- if (getAttributeConstraints() != null && !getAttributeConstraints().isEmpty() && getAttributeConstraints()
- .size() < CacheManagerSampler.class.getMethods().length) {
- buildAttributeMapByAttribute(CacheManagerSampler.class, cms, cme.getAttributes(), getAttributeConstraints(),
- CM_NAME_ACCESSOR);
- } else {
- buildAttributeMapByApi(CacheManagerSampler.class, cms, cme.getAttributes(), getAttributeConstraints(),
- CM_NAME_ACCESSOR);
- }
-
- cmes.add(cme);
- }
-
- return cmes;
- }
-
- Logger getLog() {
- return LOG;
- }
-
- @Override
- protected Set getExcludedAttributeNames(CacheManagerSampler cacheManagerSampler) {
- return Collections.emptySet();
- }
-
- private void addSampler(CacheManagerSampler sampler) {
- if (sampler == null) throw new IllegalArgumentException("sampler == null");
- cmSamplers.add(sampler);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/provider/package.html
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/provider/package.html (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/provider/package.html (revision 0)
@@ -1,8 +0,0 @@
-
-
-
-
-This package contains classes related to MBeanRegistrationProvider and its implementation.
-
-
-
Index: rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/store/TerracottaStoreInitializationService.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/store/TerracottaStoreInitializationService.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/store/TerracottaStoreInitializationService.java (revision 0)
@@ -1,101 +0,0 @@
-/*
- * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved.
- */
-package org.terracotta.modules.ehcache.store;
-
-import net.sf.ehcache.config.NonstopConfiguration;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.toolkit.cluster.ClusterInfo;
-
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
-import java.util.concurrent.atomic.AtomicInteger;
-
-public class TerracottaStoreInitializationService {
- private static final Logger LOGGER = LoggerFactory.getLogger(TerracottaStoreInitializationService.class);
- private final ExecutorService threadPool;
- private final ClusterInfo clusterInfo;
-
-
- public TerracottaStoreInitializationService(ClusterInfo clusterInfo) {
- this.clusterInfo = clusterInfo;
- this.threadPool = getThreadPool();
- }
-
- /**
- * This method should be called when the associated CacheManager is shutdown. Once shutdowm, the initialization
- * service cannot be started again.
- */
- public void shutdown() {
- threadPool.shutdownNow();
- }
-
- public void initialize(Runnable runnable, NonstopConfiguration nonStopConfiguration) {
-
- // Submit the Thread for execution
- Future future = threadPool.submit(runnable);
-
- // wait for initialization to complete (until operations are enabled)
- waitForInitialization(future, nonStopConfiguration.getTimeoutMillis());
- }
-
- /**
- * This method holds the calling thread until the given Future returns the result or the Cluster operations get/are
- * disabled. In case the Cluster operations get disabled while waiting, the method call returns honoring the nonstop
- * timeout.
- *
- */
- private void waitForInitialization(Future future, long nonStopTimeOutInMillis) {
- boolean interrupted = false;
- boolean initializationCompleted = false;
- try {
- do {
- try {
- future.get(nonStopTimeOutInMillis, TimeUnit.MILLISECONDS);
- initializationCompleted = true;
- } catch (InterruptedException e) {
- interrupted = true;
- } catch (ExecutionException e) {
- throw new RuntimeException(e.getCause());
- } catch (TimeoutException e) {
- // Retry if operations are enabled
- }
- } while (!initializationCompleted && areOperationsEnabled());
-
- } finally {
- if (interrupted) Thread.currentThread().interrupt();
- }
-
- if (!initializationCompleted) {
- LOGGER.debug("Returning without completing TerracottaStore initialization. Operations Enabled = {}",
- areOperationsEnabled());
- }
- }
-
- private boolean areOperationsEnabled() {
- return clusterInfo.areOperationsEnabled();
- }
-
- private ExecutorService getThreadPool() {
- ThreadFactory daemonThreadFactory = new ThreadFactory() {
- private final AtomicInteger threadID = new AtomicInteger();
-
- @Override
- public Thread newThread(Runnable runnable) {
- Thread thread = new Thread(runnable, "TerracottaStoreInitializationThread_" + threadID.incrementAndGet());
- thread.setDaemon(true);
- return thread;
- }
- };
-
- return Executors.newCachedThreadPool(daemonThreadFactory);
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/ElementEntity.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/ElementEntity.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/ElementEntity.java (revision 0)
@@ -1,35 +0,0 @@
-/*
- * All content copyright (c) 2003-2012 Terracotta, Inc., except as may otherwise be noted in a separate copyright
- * notice. All rights reserved.
- */
-
-package net.sf.ehcache.management.resource;
-
-import org.terracotta.management.resource.VersionedEntity;
-
-/**
- * @author brandony
- */
-public class ElementEntity extends VersionedEntity {
- private String agentId;
-
- private String cacheName;
-
- @Override
- public String getAgentId() {
- return agentId;
- }
-
- @Override
- public void setAgentId(String agentId) {
- this.agentId = agentId;
- }
-
- public String getCacheName() {
- return cacheName;
- }
-
- public void setCacheName(String cacheName) {
- this.cacheName = cacheName;
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/query/QueryManagerBuilder.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/query/QueryManagerBuilder.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/query/QueryManagerBuilder.java (revision 0)
@@ -1,121 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.search.query;
-
-import java.lang.reflect.Constructor;
-import java.util.ArrayList;
-import java.util.Collection;
-
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Ehcache;
-
-import java.lang.reflect.Constructor;
-import java.util.ArrayList;
-import java.util.Collection;
-
-/**
- * A {@link net.sf.ehcache.search.query.QueryManager Query Manager} builder providing methods to add caches which
- * can be queried.
- * The Query Manager instance returned by this builder can be used to execute
- * search queries expressed as Big Memory Structured Query Language (BMSQL) statements.
- *
- * @author dkumar
- */
-public final class QueryManagerBuilder {
-
- private final Collection caches = new ArrayList();
- private final Class defaultClass;
-
-
- private QueryManagerBuilder() {
- this(getImplementationClass());
- }
-
- /**
- * Package-local constructor for testing purposes.
- *
- * @param implementationClass a concrete implementation of the {@link net.sf.ehcache.search.query.QueryManager Query Manager} interface
- */
- QueryManagerBuilder(Class implementationClass) {
- this.defaultClass = implementationClass;
- }
-
- private static Class getImplementationClass() {
- try {
- return (Class)Class.forName("net.sf.ehcache.search.parser.QueryManagerImpl");
- } catch (ClassNotFoundException e) {
- throw new CacheException(e);
- }
- }
-
- /**
- * Creates a new {@link net.sf.ehcache.search.query.QueryManager Query Manager} builder.
- *
- * @return this for the builder pattern
- */
- public static QueryManagerBuilder newQueryManagerBuilder() {
- return new QueryManagerBuilder();
- }
-
- /**
- * Adds a {@link net.sf.ehcache.Ehcache Cache} to the internal state and allows it to be used as a target in a
- * BMSQL statement's FROM clause.
- *
- * @param cache a {@link net.sf.ehcache.Ehcache cache} instance to be added
- * @return this for the builder pattern
- */
- public QueryManagerBuilder addCache(Ehcache cache) {
- this.caches.add(cache);
- return this;
- }
-
- /**
- * Adds all {@link net.sf.ehcache.Ehcache Caches} present in a {@link net.sf.ehcache.CacheManager Cache Manager} to
- * the internal state of the query manager.
- * The added caches can be used in a BMSQL statement's FROM clause.
- *
- * @param cacheManager a {@link net.sf.ehcache.CacheManager Cache Manager} whose
- * {@link net.sf.ehcache.Ehcache caches} need to be added
- * @return this for the builder pattern
- */
- public QueryManagerBuilder addAllCachesCurrentlyIn(CacheManager cacheManager) {
- for (String s : cacheManager.getCacheNames()) {
- final Ehcache cache = cacheManager.getEhcache(s);
- if (cache != null) {
- this.caches.add(cache);
- }
- }
- return this;
- }
-
- /**
- * Returns a new {@link net.sf.ehcache.search.query.QueryManager Query Manager} using the options supplied during the building
- * process.
- *
- * @return the fully constructed {@link net.sf.ehcache.search.query.QueryManager Query Manager}
- */
- public QueryManager build() {
- try {
- final Constructor constructor = defaultClass.getConstructor(Collection.class);
- return constructor.newInstance(this.caches);
- } catch (Exception e) {
- throw new CacheException(e);
- }
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-disk.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-disk.xml (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-disk.xml (revision 0)
@@ -1,75 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
Index: rctags/ehcache-2.10.9.1.15/distribution/colorcache/src/assemble/jetty6.1/9081/conf.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/distribution/colorcache/src/assemble/jetty6.1/9081/conf.xml (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/distribution/colorcache/src/assemble/jetty6.1/9081/conf.xml (revision 0)
@@ -1,63 +0,0 @@
-
-
-
-
-
-
-
-
- -
-
-
-
-
-
-
-
-
-
-
-
- -
-
-
- -
-
-
- -
-
-
-
-
-
-
-
-
-
-
- -
-
-
-
-
-
-
-
-
-
-
-
- -
-
-
- -
-
-
- -
-
-
-
-
-
-
-
-
-
-
-
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element get(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during get(Object key)");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element getQuiet(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getQuiet(Object key)");
- }
-
- /**
- * {@inheritDoc}
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Map getAllQuiet(Collection keys) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getAllQuiet(Collection keys)");
- }
-
- /**
- * {@inheritDoc}
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Map getAll(Collection keys) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getAll(Collection keys)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public List getKeys() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getKeys()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean put(Element element) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during put(Element element)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void putAll(Collection elements) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during putAll(Collection elements)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element remove(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during remove(Object key)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void removeAll(Collection keys) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during removeAll(Collection keys)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void removeAll() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during removeAll()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void flush() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during flush()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Object getInternalContext() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getInternalContext()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public int getSize() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getSize()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element putIfAbsent(Element element) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during putIfAbsent(Element element)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element replace(Element element) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during replace(Element element)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void addStoreListener(StoreListener listener) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during addStoreListener(StoreListener listener)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean bufferFull() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during bufferFull()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean containsKey(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during containsKey(Object key)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean containsKeyInMemory(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during containsKeyInMemory(Object key)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean containsKeyOffHeap(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during containsKeyOffHeap(Object key)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean containsKeyOnDisk(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during containsKeyOnDisk(Object key)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void dispose() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during dispose()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Results executeQuery(StoreQuery query) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during executeQuery(StoreQuery query)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void expireElements() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during expireElements()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Policy getInMemoryEvictionPolicy() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getInMemoryEvictionPolicy()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public int getInMemorySize() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getInMemorySize()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public long getInMemorySizeInBytes() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getInMemorySizeInBytes()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Object getMBean() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getMBean()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public int getOffHeapSize() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getOffHeapSize()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public long getOffHeapSizeInBytes() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getOffHeapSizeInBytes()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public int getOnDiskSize() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getOnDiskSize()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public long getOnDiskSizeInBytes() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getOnDiskSizeInBytes()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean hasAbortedSizeOf() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during hasAbortedSizeOf()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Status getStatus() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getStatus()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public int getTerracottaClusteredSize() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getTerracottaClusteredSize()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean isCacheCoherent() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during isCacheCoherent()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean isClusterCoherent() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during isClusterCoherent()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean isNodeCoherent() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during isNodeCoherent()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean putWithWriter(Element element, CacheWriterManager writerManager) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during putWithWriter(Element element, CacheWriterManager writerManager)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element removeElement(Element element, ElementValueComparator comparator) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during removeElement(Element element, ElementValueComparator comparator)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void removeStoreListener(StoreListener listener) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during removeStoreListener(StoreListener listener)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Element removeWithWriter(Object key, CacheWriterManager writerManager) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during removeWithWriter(Object key, CacheWriterManager writerManager)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public boolean replace(Element old, Element element, ElementValueComparator comparator) throws NullPointerException,
- IllegalArgumentException {
- throw new RejoinCacheException("Client started rejoin during replace(Element old, Element element, ElementValueComparator comparator)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void setAttributeExtractors(Map extractors) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during setAttributeExtractors(Map extractors)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void setInMemoryEvictionPolicy(Policy policy) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during setInMemoryEvictionPolicy(Policy policy)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void setNodeCoherent(boolean coherent) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during setNodeCoherent(boolean coherent)");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public void waitUntilClusterCoherent() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during waitUntilClusterCoherent()");
- }
-
- @Override
- public Set getSearchAttributes() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getSearchAttributes()");
- }
-
- /**
- * {@inheritDoc}.
- *
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Attribute getSearchAttribute(String attributeName) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getSearchAttribute(String attributeName)");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Set getLocalKeys() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getLocalKeys()");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public CacheConfiguration.TransactionalMode getTransactionalMode() throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during getTransactionalMode()");
- }
-
- /**
- * {@inheritDoc}
- */
- public Element unlockedGet(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during unlockedGet(Object key)");
- }
-
- /**
- * {@inheritDoc}
- */
- public Element unlockedGetQuiet(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during unlockedGetQuiet(Object key)");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Element unsafeGet(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during unsafeGet(Object key)");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void quickClear() {
- throw new RejoinCacheException("Client started rejoin during quickClear()");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int quickSize() {
- throw new RejoinCacheException("Client started rejoin during quickSize()");
- }
-
- /**
- * {@inheritDoc}
- */
- public Element unsafeGetQuiet(Object key) throws RejoinCacheException {
- throw new RejoinCacheException("Client started rejoin during unsafeGetQuiet(Object key)");
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void recalculateSize(Object key) {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public WriteBehind createWriteBehind() {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void notifyCacheEventListenersChanged() {
- throw new RejoinCacheException("Client started rejoin during notifyCacheEventListenersChanged()");
- }
-}
Index: rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/event/NonStopEventReplicator.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/event/NonStopEventReplicator.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/terracotta/bootstrap/src/main/java/org/terracotta/modules/ehcache/event/NonStopEventReplicator.java (revision 0)
@@ -1,141 +0,0 @@
-/*
- * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved.
- */
-package org.terracotta.modules.ehcache.event;
-
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.config.NonstopConfiguration;
-import net.sf.ehcache.constructs.nonstop.NonStopCacheException;
-import net.sf.ehcache.event.CacheEventListener;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.modules.ehcache.ToolkitInstanceFactory;
-import org.terracotta.modules.ehcache.store.ToolkitNonStopExceptionOnTimeoutConfiguration;
-import org.terracotta.toolkit.ToolkitFeatureType;
-import org.terracotta.toolkit.feature.NonStopFeature;
-import org.terracotta.toolkit.nonstop.NonStopException;
-
-public class NonStopEventReplicator implements CacheEventListener {
-
- private static final Logger LOGGER = LoggerFactory
- .getLogger(NonStopEventReplicator.class);
- private final CacheEventListener delegate;
- private final NonStopFeature nonStop;
- private final ToolkitNonStopExceptionOnTimeoutConfiguration toolkitNonStopConfiguration;
- private final NonstopConfiguration ehcacheNonStopConfiguration;
-
- public NonStopEventReplicator(CacheEventListener delegate, ToolkitInstanceFactory toolkitInstanceFactory,
- NonstopConfiguration nonStopConfiguration) {
- this.delegate = delegate;
- this.ehcacheNonStopConfiguration = nonStopConfiguration;
- this.toolkitNonStopConfiguration = new ToolkitNonStopExceptionOnTimeoutConfiguration(
- this.ehcacheNonStopConfiguration);
- this.nonStop = toolkitInstanceFactory.getToolkit().getFeature(ToolkitFeatureType.NONSTOP);
- }
-
- private void handleNonStopException(NonStopException e, String eventType, Ehcache cache, Element element) {
- final String cacheName = cache == null ? null : cache.getName();
- final String msg = "Terracotta clustered event notification timed out: operation: " + eventType + ", cache: "
- + cacheName + ", element: " + element;
- switch (ehcacheNonStopConfiguration.getTimeoutBehavior().getTimeoutBehaviorType()) {
- case EXCEPTION:
- throw new NonStopCacheException(msg);
- default:
- LOGGER.info(msg);
- }
- }
-
- @Override
- public void notifyElementRemoved(Ehcache cache, Element element) throws CacheException {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyElementRemoved(cache, element);
- } catch (NonStopException e) {
- handleNonStopException(e, "REMOVED", cache, element);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public void notifyElementPut(Ehcache cache, Element element) throws CacheException {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyElementPut(cache, element);
- } catch (NonStopException e) {
- handleNonStopException(e, "PUT", cache, element);
- } finally {
- nonStop.finish();
- }
-
- }
-
- @Override
- public void notifyElementUpdated(Ehcache cache, Element element) throws CacheException {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyElementUpdated(cache, element);
- } catch (NonStopException e) {
- handleNonStopException(e, "UPDATED", cache, element);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public void notifyElementExpired(Ehcache cache, Element element) {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyElementExpired(cache, element);
- } catch (NonStopException e) {
- handleNonStopException(e, "EXPIRED", cache, element);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public void notifyElementEvicted(Ehcache cache, Element element) {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyElementEvicted(cache, element);
- } catch (NonStopException e) {
- handleNonStopException(e, "EVICTED", cache, element);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public void notifyRemoveAll(Ehcache cache) {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.notifyRemoveAll(cache);
- } catch (NonStopException e) {
- handleNonStopException(e, "REMOVEALL", cache, null);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public void dispose() {
- nonStop.start(toolkitNonStopConfiguration);
- try {
- this.delegate.dispose();
- } catch (NonStopException e) {
- handleNonStopException(e, "DISPOSE", null, null);
- } finally {
- nonStop.finish();
- }
- }
-
- @Override
- public NonStopEventReplicator clone() throws CloneNotSupportedException {
- return (NonStopEventReplicator) super.clone();
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/services/CacheStatisticSamplesResourceServiceImpl.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/services/CacheStatisticSamplesResourceServiceImpl.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/management-ehcache-v1/src/main/java/net/sf/ehcache/management/resource/services/CacheStatisticSamplesResourceServiceImpl.java (revision 0)
@@ -1,75 +0,0 @@
-/*
- * All content copyright (c) 2003-2012 Terracotta, Inc., except as may otherwise be noted in a separate copyright
- * notice. All rights reserved.
- */
-package net.sf.ehcache.management.resource.services;
-
-import net.sf.ehcache.management.resource.CacheStatisticSampleEntity;
-import net.sf.ehcache.management.service.EntityResourceFactory;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.management.ServiceExecutionException;
-import org.terracotta.management.ServiceLocator;
-import org.terracotta.management.resource.exceptions.ResourceRuntimeException;
-import org.terracotta.management.resource.services.validator.RequestValidator;
-
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.Context;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.Response;
-import javax.ws.rs.core.UriInfo;
-
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.HashSet;
-import java.util.Set;
-
-/**
- * @author brandony
- */
-@Path("/agents/cacheManagers/caches/statistics/samples")
-public final class CacheStatisticSamplesResourceServiceImpl {
- private static final Logger LOG = LoggerFactory.getLogger(CacheStatisticSamplesResourceServiceImpl.class);
- private final EntityResourceFactory entityResourceFactory;
-
- private final RequestValidator validator;
-
- public CacheStatisticSamplesResourceServiceImpl() {
- this.entityResourceFactory = ServiceLocator.locate(EntityResourceFactory.class);
- this.validator = ServiceLocator.locate(RequestValidator.class);
- }
-
- /**
- *
- * @param info
- * @return
- */
- @GET
- @Produces(MediaType.APPLICATION_JSON)
- public Collection getCacheStatisticSamples(@Context UriInfo info) {
- LOG.debug(String.format("Invoking CacheStatisticSamplesResourceServiceImpl.getCacheStatisticSamples: %s",
- info.getRequestUri()));
-
- validator.validateSafe(info);
-
- String cacheManagerNames = info.getPathSegments().get(1).getMatrixParameters().getFirst("names");
- Set cmNames = cacheManagerNames == null ? null : new HashSet(
- Arrays.asList(cacheManagerNames.split(",")));
-
- String cacheNames = info.getPathSegments().get(2).getMatrixParameters().getFirst("names");
- Set cNames = cacheNames == null ? null : new HashSet(Arrays.asList(cacheNames.split(",")));
-
- String sampleNames = info.getPathSegments().get(4).getMatrixParameters().getFirst("names");
- Set sNames = sampleNames == null ? null : new HashSet(Arrays.asList(sampleNames.split(",")));
-
- try {
- return entityResourceFactory.createCacheStatisticSampleEntity(cmNames, cNames, sNames);
- } catch (ServiceExecutionException e) {
- throw new ResourceRuntimeException("Failed to get cache statistics sample", e,
- Response.Status.BAD_REQUEST.getStatusCode());
- }
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/writer/writebehind/WriteBehindQueueManager.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/writer/writebehind/WriteBehindQueueManager.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/writer/writebehind/WriteBehindQueueManager.java (revision 0)
@@ -1,166 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.writer.writebehind;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.locks.ReentrantReadWriteLock;
-
-import net.sf.ehcache.CacheEntry;
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.config.CacheWriterConfiguration;
-import net.sf.ehcache.writer.CacheWriter;
-
-/**
- * @author Alex Snaps
- */
-public class WriteBehindQueueManager implements WriteBehind {
-
- private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
- private final ReentrantReadWriteLock.ReadLock readLock = rwLock.readLock();
- private final ReentrantReadWriteLock.WriteLock writeLock = rwLock.writeLock();
-
- private final List queues = new ArrayList();
-
- /**
- * Create the write behind queue manager with queues created via the passed in {@link WriteBehindQueueFactory}
- *
- * @param config configuration for the cache this write behind queue manager is working with
- * @param queueFactory factory used to create the write behind queues.
- */
- protected WriteBehindQueueManager(CacheConfiguration config, WriteBehindQueueFactory queueFactory) {
- CacheWriterConfiguration cacheWriterConfiguration = config.getCacheWriterConfiguration();
- int writeBehindConcurrency = cacheWriterConfiguration.getWriteBehindConcurrency();
- for (int i = 0; i < writeBehindConcurrency; i++) {
- this.queues.add(queueFactory.createQueue(i, config));
- }
- }
-
- /**
- * Create a new write behind queue manager. Which in turn will create as many queues as
- * required by the {@link net.sf.ehcache.config.CacheWriterConfiguration#getWriteBehindConcurrency}
- *
- * @param config the configuration for the queue
- */
- public WriteBehindQueueManager(CacheConfiguration config) {
- this(config, new WriteBehindQueueFactory());
- }
-
- /**
- * {@inheritDoc}
- */
- public void start(final CacheWriter writer) throws CacheException {
- writeLock.lock();
- try {
- for (WriteBehind queue : queues) {
- queue.start(writer);
- }
- } finally {
- writeLock.unlock();
- }
- }
-
- /**
- * {@inheritDoc}
- */
- public void write(final Element element) {
- readLock.lock();
- try {
- getQueue(element.getKey()).write(element);
- } finally {
- readLock.unlock();
- }
- }
-
- private WriteBehind getQueue(final Object key) {
- return queues.get(Math.abs(key.hashCode() % queues.size()));
- }
-
- /**
- * {@inheritDoc}
- */
- public void delete(final CacheEntry entry) {
- readLock.lock();
- try {
- getQueue(entry.getKey()).delete(entry);
- } finally {
- readLock.unlock();
- }
- }
-
- /**
- * {@inheritDoc}
- */
- public void setOperationsFilter(final OperationsFilter filter) {
- readLock.lock();
- try {
- for (WriteBehind queue : queues) {
- queue.setOperationsFilter(filter);
- }
- } finally {
- readLock.unlock();
- }
- }
-
- /**
- * {@inheritDoc}
- */
- public void stop() throws CacheException {
- writeLock.lock();
- try {
- for (WriteBehind queue : queues) {
- queue.stop();
- }
- } finally {
- writeLock.unlock();
- }
- }
-
- /**
- * {@inheritDoc}
- */
- public long getQueueSize() {
- int size = 0;
- readLock.lock();
- try {
- for (WriteBehind queue : queues) {
- size += queue.getQueueSize();
- }
- } finally {
- readLock.unlock();
- }
- return size;
- }
-
- /**
- * Factory used to create write behind queues.
- */
- protected static class WriteBehindQueueFactory {
- /**
- * Create a write behind queue stripe.
- *
- * @param index index of the stripe
- * @param config cache configuration for the cache this queue will be associated with.
- * @return a write behind queue
- */
- protected WriteBehind createQueue(int index, CacheConfiguration config) {
- return new WriteBehindQueue(config);
- }
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/pool/PoolAccessor.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/pool/PoolAccessor.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/pool/PoolAccessor.java (revision 0)
@@ -1,123 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.pool;
-
-/**
- * PoolAccessors are used by stores to tell the pools about their resource consumption
- *
- * @param Type representing this "other" side of this accessor (i.e. a store), so the evictor can interact with it
- *
- * @author Ludovic Orban
- * @author Alex Snaps
- *
- */
-public interface PoolAccessor {
-
- /**
- * Add an element to the pool.
- *
- * @param key the key of the element
- * @param value the value of the element
- * @param container the element-container object
- * @param force true if the pool should accept adding the element, even if it's out of resources
- * @return how many bytes have been added to the pool or -1 if add failed.
- */
- long add(Object key, Object value, Object container, boolean force);
-
- /**
- * Check if there is enough room in the pool to add an element without provoking any eviction
- * @param key the key of the element
- * @param value the value of the element
- * @param container the element-container object
- * @return true if there is enough room left
- */
- boolean canAddWithoutEvicting(Object key, Object value, Object container);
-
- /**
- * Delete a fixed number of bytes from the pool.
- *
- * @param size number of bytes
- * @return how many bytes have been freed from the pool.
- * @throws IllegalArgumentException when sizeOf is negative
- */
- long delete(long size) throws IllegalArgumentException;
-
- /**
- * Delete a fixed number of bytes from the pool with the given objects.
- *
- * @param currentSize the size of the object(s) being replaced
- * @param key the key of the element
- * @param value the value of the element
- * @param container the element-container object
- * @param force true if the pool should accept replacing the element, even if it's out of resources
- * @return the change in size of the pool, or {@link Long#MIN_VALUE} if replace failed.
- */
- long replace(long currentSize, Object key, Object value, Object container, boolean force);
-
- /**
- * Return how many bytes this accessor consumes from the pool.
- *
- * @return how many bytes this accessor consumes from the pool.
- */
- long getSize();
-
- /**
- * unlink this PoolAccessor from its pool.
- */
- void unlink();
-
- /**
- * Free resources used by this accessor.
- */
- void clear();
-
- /**
- * Return the store that uses this accessor
- *
- * @return store using this accessor
- */
- T getParticipant();
-
- /**
- * Sets the max size for this pool
- *
- * @param newValue the value in bytes
- */
- void setMaxSize(long newValue);
-
- /**
- * Returns the occupied size for this pool.
- *
- * @return occupied pool size
- */
- long getPoolOccupancy();
-
- /**
- * Returns the size of this pool.
- *
- * @return pool size
- */
- long getPoolSize();
-
- /**
- * Check if the store may contain elements which the SizeOf engine could not fully size.
- *
- * @return true if the store may contain partially sized objects
- */
- boolean hasAbortedSizeOf();
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/SearchableConfigurationElement.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/SearchableConfigurationElement.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/SearchableConfigurationElement.java (revision 0)
@@ -1,62 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.config.generator.model.elements;
-
-import net.sf.ehcache.config.SearchAttribute;
-import net.sf.ehcache.config.Searchable;
-import net.sf.ehcache.config.generator.model.NodeElement;
-import net.sf.ehcache.config.generator.model.SimpleNodeAttribute;
-import net.sf.ehcache.config.generator.model.SimpleNodeElement;
-
-/**
- * {@link NodeElement} representing a {@link Searchable} config element
- *
- * @author teck
- */
-public class SearchableConfigurationElement extends SimpleNodeElement {
-
- private final Searchable searchable;
-
- /**
- * Constructor accepting the parent and the {@link Searchable}
- *
- * @param parent
- * @param searchable
- */
- public SearchableConfigurationElement(NodeElement parent, Searchable searchable) {
- super(parent, "searchable");
-
- if (searchable == null) {
- throw new NullPointerException();
- }
-
- this.searchable = searchable;
- init();
- }
-
- private void init() {
- for (SearchAttribute sa : searchable.getUserDefinedSearchAttributes().values()) {
- addChildElement(sa.asConfigElement(this));
- }
-
- addAttribute(new SimpleNodeAttribute("keys", searchable.keys()).optional(true).defaultValue(Searchable.KEYS_DEFAULT));
- addAttribute(new SimpleNodeAttribute("values", searchable.values()).optional(true).defaultValue(Searchable.VALUES_DEFAULT));
- addAttribute(new SimpleNodeAttribute("allowDynamicIndexing", searchable.isDynamicIndexingAllowed()).optional(true)
- .defaultValue(Searchable.DYNAMIC_INDEXING_DEFAULT));
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/nonstop/basic-cache-test.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/nonstop/basic-cache-test.xml (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/nonstop/basic-cache-test.xml (revision 0)
@@ -1,17 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/loader/CacheLoaderTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/loader/CacheLoaderTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/loader/CacheLoaderTest.java (revision 0)
@@ -1,193 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.loader;
-
-
-import net.sf.ehcache.AbstractCacheTest;
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.Status;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.extension.TestCacheExtension;
-import org.junit.After;
-
-import static org.hamcrest.CoreMatchers.equalTo;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-import org.junit.Before;
-import org.junit.Test;
-
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-
-/**
- * @author Greg Luck
- * @version $Id: CacheLoaderTest.java 5594 2012-05-07 16:04:31Z cdennis $
- */
-public class CacheLoaderTest {
-
- /**
- * manager
- */
- protected CacheManager manager;
-
-
- /**
- * {@inheritDoc}
- *
- * @throws Exception
- */
- @Before
- public void setUp() throws Exception {
- manager = CacheManager.create(AbstractCacheTest.TEST_CONFIG_DIR + "ehcache-loaderinteractions.xml");
- }
-
-
- /**
- * {@inheritDoc}
- *
- * @throws Exception
- */
- @After
- public void tearDown() throws Exception {
- if (!manager.getStatus().equals(Status.STATUS_SHUTDOWN)) {
- manager.shutdown();
- }
- }
-
- @Test
- public void testWorksWithTransactionalCaches() {
- Cache cache = new Cache(new CacheConfiguration("txLoaderCache", 100)
- .transactionalMode(CacheConfiguration.TransactionalMode.LOCAL));
- manager.addCache(cache);
- manager.getTransactionController().begin();
- final Element element = cache.getWithLoader(10, new CountingCacheLoader(), null);
- assertThat((Integer) element.getValue(), equalTo(0));
- manager.getTransactionController().commit();
- }
-
- @Test
- public void testGetAllWithLoaderExpiredKey() throws Exception {
- Cache cache = manager.getCache("CCache");
- cache.put(new Element(1, "one"));
- Thread.sleep(1100); // make Element 1 expire, see EHC-809
- cache.put(new Element(2, "two"));
- cache.put(new Element(3, null));
-
- Map cachedObjects = cache.getAllWithLoader(Arrays.asList(1, 2, 3), null);
-
- assertTrue(cachedObjects.get(1).toString().equals("C(1)"));
- assertTrue(cachedObjects.get(2).toString().equals("two"));
- assertNull(cachedObjects.get(3));
- assertTrue(cachedObjects.containsKey(3));
- }
-
- @Test
- public void testLoaderChainNullFirst() {
- Cache cache = manager.getCache("NullLoaderFirstCache");
- assertNotNull(cache.getWithLoader("key", null, null));
- NullCountingCacheLoader nullCountingCacheLoader = getNullCountingCacheLoader(cache);
- assertEquals(1, nullCountingCacheLoader.getLoadCounter());
- CountingCacheLoader countingCacheLoader = getCountingCacheLoader(cache);
- assertEquals(1, countingCacheLoader.getLoadCounter());
- }
-
- @Test
- public void testLoaderChainNullLast() {
- Cache cache = manager.getCache("NullLoaderLastCache");
- assertNotNull(cache.getWithLoader("key", null, null));
- CountingCacheLoader countingCacheLoader = getCountingCacheLoader(cache);
- assertEquals(1, countingCacheLoader.getLoadCounter());
- NullCountingCacheLoader nullCountingCacheLoader = getNullCountingCacheLoader(cache);
- assertEquals(0, nullCountingCacheLoader.getLoadCounter());
- }
-
- @Test
- public void testLoaderChainNullBoth() {
- Cache cache = manager.getCache("NullLoaderTwiceCache");
- Element element = cache.getWithLoader("key", null, null);
- assertNull(element);
- NullCountingCacheLoader nullCountingCacheLoader = getNullCountingCacheLoader(cache);
- List list = cache.getRegisteredCacheLoaders();
- assertEquals(2, list.size());
- for (CacheLoader cacheLoader : list) {
- if (cacheLoader instanceof NullCountingCacheLoader) {
- nullCountingCacheLoader = (NullCountingCacheLoader) cacheLoader;
- assertEquals(1, nullCountingCacheLoader.getLoadCounter());
- }
- }
-
- }
-
- private CountingCacheLoader getCountingCacheLoader(Cache cache) {
- List list = cache.getRegisteredCacheLoaders();
- for (CacheLoader cacheLoader : list) {
- if (cacheLoader instanceof CountingCacheLoader) {
- return (CountingCacheLoader) cacheLoader;
- }
- }
- return null;
- }
-
- private NullCountingCacheLoader getNullCountingCacheLoader(Cache cache) {
- List list = cache.getRegisteredCacheLoaders();
- for (CacheLoader cacheLoader : list) {
- if (cacheLoader instanceof NullCountingCacheLoader) {
- return (NullCountingCacheLoader) cacheLoader;
- }
- }
- return null;
- }
-
-
- /**
- * Tests the put listener.
- */
- @Test
- public void testExtensionDirectly() {
-
- manager.addCache("test");
- TestCacheExtension testCacheExtension = new TestCacheExtension(manager.getCache("test"), "valueA");
- assertEquals(Status.STATUS_UNINITIALISED, testCacheExtension.getStatus());
- assertEquals("valueA", testCacheExtension.getPropertyA());
-
- testCacheExtension.init();
- assertEquals(Status.STATUS_ALIVE, testCacheExtension.getStatus());
-
- testCacheExtension.dispose();
- assertEquals(Status.STATUS_SHUTDOWN, testCacheExtension.getStatus());
-
- }
-
-
- /**
- * We need to make sure that cloning a default cache results in a new cache with its own
- * set of cache extensions.
- */
- @Test
- public void testClone() {
-
- //just test it does not blow up
- manager.addCache("clonedCache");
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/sampled/SampledCounterConfig.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/sampled/SampledCounterConfig.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/util/counter/sampled/SampledCounterConfig.java (revision 0)
@@ -1,95 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.util.counter.sampled;
-
-import net.sf.ehcache.util.counter.Counter;
-import net.sf.ehcache.util.counter.CounterConfig;
-
-/**
- * Config for a {@link SampledCounter}
- *
- * @author Abhishek Sanoujam
- * @since 1.7
- *
- */
-public class SampledCounterConfig extends CounterConfig {
- private final int intervalSecs;
- private final int historySize;
- private final boolean isReset;
-
- /**
- * Make a new timed counter config (duh)
- *
- * @param intervalSecs
- * the interval (in seconds) between sampling
- * @param historySize
- * number of counter samples that will be retained in memory
- * @param isResetOnSample
- * true if the counter should be reset to 0 upon each sample
- * @param initialValue
- * the initial value given to this counter
- */
- public SampledCounterConfig(int intervalSecs, int historySize, boolean isResetOnSample, long initialValue) {
- super(initialValue);
- if (intervalSecs < 1) {
- throw new IllegalArgumentException("Interval (" + intervalSecs + ") must be greater than or equal to 1");
- }
- if (historySize < 1) {
- throw new IllegalArgumentException("History size (" + historySize + ") must be greater than or equal to 1");
- }
-
- this.intervalSecs = intervalSecs;
- this.historySize = historySize;
- this.isReset = isResetOnSample;
- }
-
- /**
- * Returns the history size
- *
- * @return The history size
- */
- public int getHistorySize() {
- return historySize;
- }
-
- /**
- * Returns the interval time (seconds)
- *
- * @return Interval of the sampling thread in seconds
- */
- public int getIntervalSecs() {
- return intervalSecs;
- }
-
- /**
- * Returns true if counters created from this config will reset on each
- * sample
- *
- * @return true if values are reset to the initial value after each sample
- */
- public boolean isResetOnSample() {
- return this.isReset;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Counter createCounter() {
- return new SampledCounterImpl(this);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/EhcacheHibernateMbeanNames.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/EhcacheHibernateMbeanNames.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/hibernate/management/impl/EhcacheHibernateMbeanNames.java (revision 0)
@@ -1,77 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.hibernate.management.impl;
-
-import javax.management.MalformedObjectNameException;
-import javax.management.ObjectName;
-
-/**
- * Utility class used for getting {@link ObjectName}'s for ehcache hibernate MBeans
- *
- *
- *
- * @author Abhishek Sanoujam
- * @since 1.7
- *
- */
-public abstract class EhcacheHibernateMbeanNames {
-
- /**
- * Group id for all sampled mbeans registered
- */
- public static final String GROUP_ID = "net.sf.ehcache.hibernate";
-
- /**
- * Type for the ehcache backed hibernate second level cache statistics mbean
- */
- public static final String EHCACHE_HIBERNATE_TYPE = "EhcacheHibernateStats";
-
- /**
- * Filter out invalid ObjectName characters from s.
- *
- * @param s
- * @return A valid JMX ObjectName attribute value.
- */
- public static String mbeanSafe(String s) {
- return s == null ? "" : s.replaceAll(",|:|=|\n", ".");
- }
-
- /**
- * Returns an ObjectName for the passed name
- *
- * @param name
- * @return An {@link ObjectName} using the input name of cache manager
- * @throws MalformedObjectNameException
- */
- public static ObjectName getCacheManagerObjectName(String cacheManagerClusterUUID, String name) throws MalformedObjectNameException {
- ObjectName objectName = new ObjectName(GROUP_ID + ":type=" + EHCACHE_HIBERNATE_TYPE + ",name=" + mbeanSafe(name)
- + getBeanNameSuffix(cacheManagerClusterUUID));
- return objectName;
- }
-
- private static String getBeanNameSuffix(String cacheManagerClusterUUID) {
- String suffix = "";
- if (!isBlank(cacheManagerClusterUUID)) {
- suffix = ",node=" + cacheManagerClusterUUID;
- }
- return suffix;
- }
-
- private static boolean isBlank(String param) {
- return param == null || "".equals(param.trim());
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/management/sampled/CacheManagerSamplerImplTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/management/sampled/CacheManagerSamplerImplTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/management/sampled/CacheManagerSamplerImplTest.java (revision 0)
@@ -1,44 +0,0 @@
-package net.sf.ehcache.management.sampled;
-
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.search.SearchException;
-import net.sf.ehcache.search.query.QueryManagerBuilder;
-import net.sf.ehcache.search.query.TestQueryManagerBuilder;
-import org.junit.Test;
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-/**
- * @author Anthony Dahanne
- */
-public class CacheManagerSamplerImplTest {
- @Test(expected = SearchException.class)
- public void testExecuteQuery__no_caches() throws Exception {
-
- CacheManager cacheManager = mock(CacheManager.class);
- String[] emptyCacheNamesArray = new String[0];
- when(cacheManager.getCacheNames()).thenReturn(emptyCacheNamesArray);
- CacheManagerSamplerImpl cacheManagerSampler = new CacheManagerSamplerImpl(cacheManager);
- QueryManagerBuilder qmb = TestQueryManagerBuilder.getQueryManagerBuilder();
- cacheManagerSampler.executeQuery("bogus query", qmb);
- }
-
- @Test(expected = SearchException.class)
- public void testExecuteQuery__no_searchable_caches() throws Exception {
-
- CacheManager cacheManager = mock(CacheManager.class);
- String[] emptyCacheNamesArray = new String[]{"pif"};
- when(cacheManager.getCacheNames()).thenReturn(emptyCacheNamesArray);
- CacheConfiguration cacheConfiguration = new CacheConfiguration().name("pif");
- Ehcache cache = new Cache(cacheConfiguration);
- when(cacheManager.getEhcache("pif")).thenReturn(cache);
-
- CacheManagerSamplerImpl cacheManagerSampler = new CacheManagerSamplerImpl(cacheManager);
- QueryManagerBuilder qmb = TestQueryManagerBuilder.getQueryManagerBuilder();
- cacheManagerSampler.executeQuery("bogus query", qmb);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/ManualRMIPeerProviderIT.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/ManualRMIPeerProviderIT.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/distribution/ManualRMIPeerProviderIT.java (revision 0)
@@ -1,89 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.distribution;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.TimeUnit;
-
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.config.Configuration;
-import net.sf.ehcache.config.FactoryConfiguration;
-
-import org.junit.Before;
-
-import static net.sf.ehcache.distribution.AbstractRMITest.createAsynchronousCache;
-
-/**
- * @author Greg Luck
- * @version $Id: ManualRMIPeerProviderIT.java 8870 2014-04-03 20:27:43Z cdennis $
- */
-public class ManualRMIPeerProviderIT extends MulticastRMIPeerProviderIT {
-
- /**
- * {@inheritDoc}
- */
- @Override
- @Before
- public void setUp() throws Exception {
- List configurations = new ArrayList();
- configurations.add(new Configuration()
- .cacheManagerPeerListenerFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory")
- .properties("hostName=localhost, port=5011, socketTimeoutMillis=2000"))
- .cacheManagerPeerProviderFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory")
- .properties("peerDiscovery=manual,rmiUrls=//localhost:5012/asynchronousCache|//localhost:5013/asynchronousCache"))
- .cache(createAsynchronousCache().name("asynchronousCache"))
- .name("ManualRMIPeerProviderTest-1"));
-
- configurations.add(new Configuration()
- .cacheManagerPeerListenerFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory")
- .properties("hostName=localhost, port=5012, socketTimeoutMillis=2000"))
- .cacheManagerPeerProviderFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory")
- .properties("peerDiscovery=manual,rmiUrls=//localhost:5011/asynchronousCache|//localhost:5013/asynchronousCache"))
- .cache(createAsynchronousCache().name("asynchronousCache"))
- .name("ManualRMIPeerProviderTest-2"));
-
- configurations.add(new Configuration()
- .cacheManagerPeerListenerFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory")
- .properties("hostName=localhost, port=5013, socketTimeoutMillis=2000"))
- .cacheManagerPeerProviderFactory(new FactoryConfiguration()
- .className("net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory")
- .properties("peerDiscovery=manual"))
- .cache(createAsynchronousCache().name("asynchronousCache"))
- .name("ManualRMIPeerProviderTest-3"));
-
- List managers = startupManagers(configurations);
- manager1 = managers.get(0);
- manager2 = managers.get(1);
- manager3 = managers.get(2);
-
- /* manager3 has an empty manual configuration, which is topped up by adding manual entries.
- * The sampleCache1 from manager3 is added to the rmiUrls list for manager1 and manager2
- */
- CacheManagerPeerProvider peerProvider = manager3.getCacheManagerPeerProvider("RMI");
- peerProvider.registerPeer("//localhost:5011/asynchronousCache");
- peerProvider.registerPeer("//localhost:5012/asynchronousCache");
-
- //Allow cluster setup
- waitForClusterMembership(10, TimeUnit.SECONDS, manager1, manager2, manager3);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/package.html
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/package.html (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/generator/model/elements/package.html (revision 0)
@@ -1,5 +0,0 @@
-
-
- This package contains utility classes encapsulating ideas of Elements and Attributes from the ehcache.xsd
-
-
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/hibernate/HibernateAPIUsageTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/hibernate/HibernateAPIUsageTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/hibernate/HibernateAPIUsageTest.java (revision 0)
@@ -1,654 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.hibernate;
-
-import net.sf.ehcache.AbstractCacheTest;
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.store.disk.DiskStoreHelper;
-
-import org.hamcrest.CoreMatchers;
-import org.hibernate.cfg.Environment;
-import org.junit.After;
-
-import static org.hamcrest.number.OrderingComparison.greaterThan;
-import static org.hamcrest.number.OrderingComparison.lessThanOrEqualTo;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
-import java.io.IOException;
-import java.io.Serializable;
-import java.lang.reflect.Field;
-import java.util.Map;
-import java.util.Properties;
-import java.util.concurrent.ExecutionException;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.test.categories.CheckShorts;
-
-
-/**
- * Tests for a Cache
- *
- * @author Greg Luck, Claus Ibsen
- * @version $Id: HibernateAPIUsageTest.java 10789 2018-04-26 02:08:13Z adahanne $
- */
-@Category(CheckShorts.class)
-public class HibernateAPIUsageTest extends AbstractCacheTest {
- private static final Logger LOG = LoggerFactory.getLogger(HibernateAPIUsageTest.class.getName());
-
- /**
- * teardown
- */
- @Override
- @After
- public void tearDown() throws Exception {
- super.tearDown();
- for (CacheManager cacheManager : CacheManager.ALL_CACHE_MANAGERS) {
- cacheManager.shutdown();
- }
- }
-
- @Override
- @Before
- public void setUp() {
- // Do not setup a cachemanager here!
- }
-
-
- /**
- * Make sure ehcache works with one of the main projects using it: Hibernate-2.1.8
- */
- @Test
- public void testAPIAsUsedByHibernate2() throws Exception {
- super.setUp();
- net.sf.hibernate.cache.EhCacheProvider provider = new net.sf.hibernate.cache.EhCacheProvider();
- provider.start(null);
- net.sf.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
- assertNotNull(manager.getCache("sampleCache1"));
-
- Serializable key = "key";
- Serializable value = "value";
- cache.put(key, value);
- assertEquals(value, cache.get(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
- }
-
-
- /**
- * Make sure ehcache works with one of the main projects using it: Hibernate-3.1.3 and Hibernate 3.2
- * Note this test was updated to Hibernate3.2cr2 9 May 2006
- *
- * Note that getElementCountInMemory() is broken. It reports the total cache size rather than the memory size. Fixed in Hibernate 3.2
- * getTimeout appears to be broken. It returns 4096 minutes!
- */
- @Test
- public void testAPIAsUsedByHibernate3() throws InterruptedException, ExecutionException {
-
- org.hibernate.cache.EhCacheProvider provider = new org.hibernate.cache.EhCacheProvider();
- provider.start(null);
- final org.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
- final Serializable key = "key";
- final Serializable value = "value";
- assertThat(cache.getSizeInMemory(), CoreMatchers.is(0L));
- cache.put(key, value);
- final long EMPTY_ELEMENT_SIZE = cache.getSizeInMemory();
- cache.clear();
-
- //Check created and name
- assertNotNull(cache.getRegionName());
- assertEquals("sampleCache1", cache.getRegionName());
-
- cache.put(key, value);
- assertEquals(value, cache.get(key));
- assertEquals(value, cache.read(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
-
- //Behaves like a put
- cache.update(key, value);
- assertEquals(value, cache.get(key));
- cache.remove(key);
-
- //Check counts and stats
- for (int i = 0; i < 10010; i++) {
- cache.put("" + i, value);
- }
- DiskStoreHelper.flushAllEntriesToDisk(getBackingCache((org.hibernate.cache.EhCache)cache)).get();
- //this is now fixed
- assertThat(cache.getElementCountInMemory(), lessThanOrEqualTo(10000L));
- // TODO Lower tier will _never_ be smaller than higher ones now
-// RetryAssert.assertBy(1, SECONDS, new Callable() {
-// public Long call() throws Exception {
-// return cache.getElementCountOnDisk();
-// }
-// }, lessThan(1002L));
- assertThat(cache.getElementCountOnDisk(), greaterThan(999L));
-
- //clear
- cache.clear();
- assertEquals(0, cache.getElementCountInMemory());
- cache.put(key, value);
- assertEquals(EMPTY_ELEMENT_SIZE, cache.getSizeInMemory());
-
- //locks
- //timeout. This seems strange
- assertEquals(245760000, cache.getTimeout());
- cache.lock(key);
- cache.unlock(key);
-
- //toMap
- Map map = cache.toMap();
- assertEquals(1, map.size());
- assertEquals(value, map.get(key));
-
- long time1 = cache.nextTimestamp();
- long time2 = cache.nextTimestamp();
- assertTrue(time2 > time1);
-
- cache.clear();
-
- cache.destroy();
- try {
- cache.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- provider.stop();
-
- }
-
- private Cache getBackingCache(final org.hibernate.cache.EhCache cache) {
- try {
- final Field cacheField = cache.getClass().getDeclaredField("cache");
- cacheField.setAccessible(true);
- return (Cache)cacheField.get(cache);
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
-
-
- /**
- * Test new features:
- *
- * - Support for Object signatures
- *
- support for multiple SessionFactory objects in Hibernate, which presumably mean multiple providers.
- * We can have two caches of the same name in different providers and interact with both
- *
- */
- @Test
- public void testNewHibernate32CacheAndProviderNewFeatures() {
-
- org.hibernate.cache.EhCacheProvider provider = new org.hibernate.cache.EhCacheProvider();
- provider.start(null);
- org.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
-
- //start up second provider pointing to ehcache-failsage.xml because it is there
- org.hibernate.cache.EhCacheProvider provider2 = new org.hibernate.cache.EhCacheProvider();
-
- //Fire up a second provider, CacheManager and cache concurrently
- Properties properties = new Properties();
-
- properties.setProperty(Environment.CACHE_PROVIDER_CONFIG, "ehcache-2.xml");
- provider2.start(properties);
- org.hibernate.cache.Cache cache2 = provider.buildCache("sampleCache1", null);
-
- //Check created and name
- assertNotNull(cache.getRegionName());
- assertEquals("sampleCache1", cache.getRegionName());
-
- //Test with Object rather than Serializable
- Object key = new Object();
- Object value = new Object();
-
- cache.put(key, value);
- assertEquals(value, cache.get(key));
- assertEquals(value, cache.read(key));
- cache2.put(key, value);
- assertEquals(value, cache2.get(key));
- assertEquals(value, cache2.read(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
- cache2.remove(key);
- assertEquals(null, cache2.get(key));
-
- //Behaves like a put
- cache.update(key, value);
- assertEquals(value, cache.get(key));
- cache.remove(key);
- cache2.update(key, value);
- assertEquals(value, cache2.get(key));
- cache2.remove(key);
-
- //Check counts and stats
- for (int i = 0; i < 10010; i++) {
- cache.put("" + i, value);
- }
- assertEquals(10000, cache.getElementCountInMemory());
- //objects don't overflow, only Serializable
- assertEquals(0, cache.getElementCountOnDisk());
-
- //clear
- cache.clear();
- assertEquals(0, cache.getElementCountInMemory());
- cache.put(key, value);
-
- //locks
- //timeout. This seems strange
- assertEquals(245760000, cache.getTimeout());
- cache.lock(key);
- cache.unlock(key);
-
- //toMap - broken in Hibernate 3.2
-// Map map = cache.toMap();
-// assertEquals(1, map.size());
-// assertEquals(value, map.get(key));
-
- long time1 = cache.nextTimestamp();
- long time2 = cache.nextTimestamp();
- assertTrue(time2 > time1);
-
- cache.destroy();
- try {
- cache.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- cache2.destroy();
- try {
- cache2.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- provider.stop();
- provider2.stop();
- }
-
-
- /**
- * Test ehcache packaged provider and EhCache with Hibernate-3.1.3
- * Leave broken timeout until get clarification from Emmanuel
- */
- @Test
- public void testNewHibernateEhcacheAndProviderBackwardCompatible() {
-
- net.sf.ehcache.hibernate.EhCacheProvider provider = new net.sf.ehcache.hibernate.EhCacheProvider();
-
- //Fire up a second provider, CacheManager and cache concurrently
- Properties properties = new Properties();
-
- properties.setProperty("net.sf.ehcache.configurationResourceName", "ehcache-2.xml");
- provider.start(properties);
- final org.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
- final Serializable key = "key";
- final Serializable value = "value";
- assertThat(cache.getSizeInMemory(), CoreMatchers.is(0L));
- cache.put(key, value);
- final long EMPTY_ELEMENT_SIZE = cache.getSizeInMemory();
- cache.clear();
-
- //Check created and name
- assertNotNull(cache.getRegionName());
- assertEquals("sampleCache1", cache.getRegionName());
-
- cache.put(key, value);
- assertEquals(value, cache.get(key));
- assertEquals(value, cache.read(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
-
- //Behaves like a put
- cache.update(key, value);
- assertEquals(value, cache.get(key));
- cache.remove(key);
-
- //Check counts and stats
- for (int i = 0; i < 10010; i++) {
- cache.put("" + i, value);
- }
- assertEquals(10010, cache.getElementCountInMemory());
-
- //clear
- cache.clear();
- assertEquals(0, cache.getElementCountInMemory());
- cache.put(key, value);
- assertEquals(EMPTY_ELEMENT_SIZE, cache.getSizeInMemory());
-
- //locks
- //timeout. This seems strange
- assertEquals(245760000, cache.getTimeout());
- cache.lock(key);
- cache.unlock(key);
-
- //toMap
- Map map = cache.toMap();
- assertEquals(1, map.size());
- assertEquals(value, map.get(key));
-
- long time1 = cache.nextTimestamp();
- long time2 = cache.nextTimestamp();
- assertTrue(time2 > time1);
-
- cache.destroy();
- try {
- cache.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- provider.stop();
- }
-
-
- /**
- * An integration test, at the CacheManager level, to make sure persistence works
- */
- @Test
- public void testPersistentStoreFromCacheManager() throws IOException, InterruptedException, CacheException, ExecutionException {
-
- //initialise
- CacheManager manager = CacheManager.create(AbstractCacheTest.TEST_CONFIG_DIR + "ehcache.xml");
- Ehcache cache = manager.getCache("persistentLongExpiryIntervalCache");
-
- cache.removeAll();
- DiskStoreHelper.flushAllEntriesToDisk((Cache)cache).get();
- for (int i = 0; i < 100; i++) {
- byte[] data = new byte[1024];
- cache.put(new Element("key" + (i + 100), data));
- }
- assertEquals(100, cache.getSize());
-
- manager.shutdown();
-
- net.sf.ehcache.hibernate.EhCacheProvider provider = new net.sf.ehcache.hibernate.EhCacheProvider();
- provider.start(null);
- org.hibernate.cache.Cache hibernateCache = provider.buildCache("persistentLongExpiryIntervalCache", null);
-
- for (int i = 0; i < 100; i++) {
- assertNotNull(hibernateCache.get("key" + (i + 100)));
- }
-
- assertEquals(100, hibernateCache.getElementCountInMemory());
-
- provider.stop();
-
-
- }
-
-
- /**
- * An integration test, at the CacheManager level, to make sure persistence works
- */
- @Test
- public void testPersistentStoreFromCacheManagerUsingHibernate321Provider() throws Exception {
-
- //initialise
- CacheManager manager = CacheManager.create(AbstractCacheTest.TEST_CONFIG_DIR + "ehcache.xml");
- Ehcache cache = manager.getCache("persistentLongExpiryIntervalCache");
- cache.removeAll();
-
- for (int i = 0; i < 100; i++) {
- byte[] data = new byte[1024];
- cache.put(new Element("key" + (i + 100), data));
- }
- assertEquals(100, cache.getSize());
-
- manager.shutdown();
-
- //Create hibernate using ehcache
- org.hibernate.cache.EhCacheProvider provider = new org.hibernate.cache.EhCacheProvider();
- provider.start(null);
- org.hibernate.cache.Cache hibernateCache = provider.buildCache("persistentLongExpiryIntervalCache", null);
-
- assertEquals(100, hibernateCache.getElementCountInMemory() + hibernateCache.getElementCountOnDisk());
-
- provider.stop();
-
- }
-
- /**
- * Test ehcache packaged provider and EhCache with Hibernate-3.1.3
- * Leave broken timeout until get clarification from Emmanuel
- *
- * Test new features:
- *
- * - Support for Object signatures
- *
- support for multiple SessionFactory objects in Hibernate, which presumably mean multiple providers.
- * We can have two caches of the same name in different providers and interact with both
- *
- */
- @Test
- public void testNewHibernateEhcacheAndProviderNewFeatures() {
-
- net.sf.ehcache.hibernate.EhCacheProvider provider = new net.sf.ehcache.hibernate.EhCacheProvider();
- provider.start(null);
- org.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
-
- //start up second provider pointing to ehcache-failsafe.xml because it is there
- net.sf.ehcache.hibernate.EhCacheProvider provider2 = new net.sf.ehcache.hibernate.EhCacheProvider();
-
- //Fire up a second provider, CacheManager and cache concurrently
- Properties properties = new Properties();
- properties.setProperty(EhCacheProvider.NET_SF_EHCACHE_CONFIGURATION_RESOURCE_NAME, "ehcache-2.xml");
- provider2.start(properties);
- org.hibernate.cache.Cache cache2 = provider.buildCache("sampleCache1", null);
-
- //Check created and name
- assertNotNull(cache.getRegionName());
- assertEquals("sampleCache1", cache.getRegionName());
-
- //Test with Object rather than Serializable
- Object key = new Object();
- Object value = new Object();
-
- cache.put(key, value);
- assertEquals(value, cache.get(key));
- assertEquals(value, cache.read(key));
- cache2.put(key, value);
- assertEquals(value, cache2.get(key));
- assertEquals(value, cache2.read(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
- cache2.remove(key);
- assertEquals(null, cache2.get(key));
-
- //Behaves like a put
- cache.update(key, value);
- assertEquals(value, cache.get(key));
- cache.remove(key);
- cache2.update(key, value);
- assertEquals(value, cache2.get(key));
- cache2.remove(key);
-
- //Check counts and stats
- for (int i = 0; i < 10010; i++) {
- cache.put("" + i, value);
- }
- assertEquals(10010, cache.getElementCountInMemory());
-
- //clear
- cache.clear();
- assertEquals(0, cache.getElementCountInMemory());
- cache.put(key, value);
- // elements don't need to be serializable anymore to be measured
- assertTrue(cache.getSizeInMemory() > 0);
-
- //locks
- //timeout. This seems strange
- assertEquals(245760000, cache.getTimeout());
- cache.lock(key);
- cache.unlock(key);
-
- //toMap
- Map map = cache.toMap();
- assertEquals(1, map.size());
- assertEquals(value, map.get(key));
-
- long time1 = cache.nextTimestamp();
- long time2 = cache.nextTimestamp();
- assertTrue(time2 > time1);
-
- cache.destroy();
- try {
- cache.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- cache2.destroy();
- try {
- cache2.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- provider.stop();
- provider2.stop();
- }
-
- /**
- * Test ehcache packaged provider and EhCache with Hibernate-3.1.3
- * Leave broken timeout until get clarification from Emmanuel
- *
- * Test new features:
- *
- * - Support for Object signatures
- *
- */
- @Test
- public void testNewHibernateSingletonEhcacheAndProviderNewFeatures() {
-
- net.sf.ehcache.hibernate.SingletonEhCacheProvider provider = new net.sf.ehcache.hibernate.SingletonEhCacheProvider();
- provider.start(null);
- org.hibernate.cache.Cache cache = provider.buildCache("sampleCache1", null);
-
- net.sf.ehcache.hibernate.SingletonEhCacheProvider provider2 = new net.sf.ehcache.hibernate.SingletonEhCacheProvider();
- provider2.start(null);
- org.hibernate.cache.Cache cache2 = provider.buildCache("sampleCache1", null);
-
- //Check created and name
- assertNotNull(cache.getRegionName());
- assertEquals("sampleCache1", cache.getRegionName());
-
- //Test with Object rather than Serializable
- Object key = new Object();
- Object value = new Object();
-
- cache.put(key, value);
- assertEquals(value, cache2.get(key));
- assertEquals(value, cache.read(key));
- cache2.put(key, value);
- assertEquals(value, cache.get(key));
- assertEquals(value, cache2.read(key));
-
- cache.remove(key);
- assertEquals(null, cache.get(key));
- cache2.remove(key);
- assertEquals(null, cache2.get(key));
-
- //Behaves like a put
- cache.update(key, value);
- assertEquals(value, cache.get(key));
- cache.remove(key);
- cache2.update(key, value);
- assertEquals(value, cache2.get(key));
- cache2.remove(key);
-
- //Check counts and stats
- for (int i = 0; i < 10010; i++) {
- cache.put("" + i, value);
- }
- assertEquals(10010, cache.getElementCountInMemory());
-
- //clear
- cache.clear();
- assertEquals(0, cache.getElementCountInMemory());
- cache.put(key, value);
- // elements don't need to be serializable anymore to be measured
- assertTrue(cache.getSizeInMemory() > 0);
-
- //locks
- //timeout. This seems strange
- assertEquals(245760000, cache.getTimeout());
- cache.lock(key);
- cache.unlock(key);
-
- //toMap
- Map map = cache.toMap();
- assertEquals(1, map.size());
- assertEquals(value, map.get(key));
-
- long time1 = cache.nextTimestamp();
- long time2 = cache.nextTimestamp();
- assertTrue(time2 > time1);
-
- cache.destroy();
- try {
- cache.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
- cache2.destroy();
- //second destroy ok
- cache2.destroy();
-
- try {
- cache2.get(key);
- fail();
- } catch (IllegalStateException e) {
- //expected
- }
-
-
- ((net.sf.ehcache.hibernate.EhCache) cache).getBackingCache().getCacheManager().shutdown();
- ((net.sf.ehcache.hibernate.EhCache) cache).getBackingCache().getCacheManager().shutdown();
- ((net.sf.ehcache.hibernate.EhCache) cache2).getBackingCache().getCacheManager().shutdown();
-
- //Spring and Hibernate together can call destroy after the CacheManager has been shutdown
- //See bug 1901094. We need to deal with this as "normal".
- cache2.destroy();
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/readthrough/ReadThroughCacheConfiguration.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/readthrough/ReadThroughCacheConfiguration.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/readthrough/ReadThroughCacheConfiguration.java (revision 0)
@@ -1,176 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.constructs.readthrough;
-
-import java.util.Properties;
-
-/**
- * This classed is used to programmatically configure a {@link ReadThroughCache}.
- *
- * @author cschanck
- *
- */
-public class ReadThroughCacheConfiguration implements Cloneable {
-
- /**
- * Properties key for the name attribute
- */
- public static final String NAME_KEY = "name";
-
- /**
- * Properties key for the get() proxy attribute
- */
- public static final String GET_KEY = "get";
-
- private boolean modeGet = true;
- private String name = null;
- private volatile boolean valid = false;
-
- /**
- * Create default, valid configuration.
- */
- public ReadThroughCacheConfiguration() {
- validate();
- }
-
- /**
- * Create a configuration object from a properties object. Validate before returning.
- *
- * @param properties
- * @return
- */
- public ReadThroughCacheConfiguration fromProperties(Properties properties) {
- valid = false;
- if (properties != null) {
- for (String property : properties.stringPropertyNames()) {
- String stringValue = properties.getProperty(property).trim();
- if (GET_KEY.equals(property)) {
- setModeGet(Boolean.parseBoolean(stringValue));
- } else if (NAME_KEY.equals(property)) {
- setName(stringValue);
- } else {
- throw new IllegalArgumentException("Unrecognized ReadThrough cache config key: " + property);
- }
- }
- }
- return build();
- }
-
- /**
- * Return a properties version of this configuration object.
- *
- * @return
- */
- public Properties toProperties() {
- Properties p = new Properties();
- p.setProperty(NAME_KEY, getName());
- p.setProperty(GET_KEY, Boolean.toString(isModeGet()));
- return p;
- }
-
- /**
- * Validate this configuration, mark it valid if it passes.
- *
- * @return
- */
- public ReadThroughCacheConfiguration build() {
- validate();
- return this;
- }
-
- private void validate() {
- // not much here.
- // removing the decorator.
- valid = true;
- }
-
- private void checkValid() {
- if (!valid) {
- throw new IllegalStateException("RefreshAheadCacheConfig not built yet");
- }
- }
-
- /**
- * Set whether get() methods will be transparently proxied.
- *
- * @param modeGet true to proxy get methods
- * @return
- */
- public ReadThroughCacheConfiguration modeGet(boolean modeGet) {
- setModeGet(modeGet);
- return this;
- }
-
- /**
- * Return whether the get() method is proxied.
- *
- * @return true if proxied
- */
- public boolean isModeGet() {
- checkValid();
- return modeGet;
- }
-
- /**
- * Set whether get() methods will be transparently proxied.
- *
- * @param modeGet true t pxoy the get() methods
- */
- public void setModeGet(boolean modeGet) {
- valid = false;
- this.modeGet = modeGet;
- }
-
- /**
- * Get the name to set for this cache decorator. May be null.
- *
- * @return the name
- */
- public String getName() {
- return name;
- }
-
- /**
- * Set the name to set for this cache decorator. May be null.
- *
- * @param name name to use, may be null
- * @return this config
- */
- public ReadThroughCacheConfiguration setName(String name) {
- valid = false;
- this.name = name;
- return this;
- }
-
- /**
- * Set the name to set for this cache decorator. May be null.
- *
- * @param name name to use, may be null
- * @return this config
- */
- public ReadThroughCacheConfiguration name(String name) {
- setName(name);
- return this;
- }
-
- @Override
- public String toString() {
- return toProperties().toString();
- }
-
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/ConcurrencyProblemCachePerfTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/ConcurrencyProblemCachePerfTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/ConcurrencyProblemCachePerfTest.java (revision 0)
@@ -1,88 +0,0 @@
-package net.sf.ehcache;
-
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.List;
-
-import net.sf.ehcache.AbstractCacheTest.Executable;
-import net.sf.ehcache.config.Configuration;
-import static org.junit.Assert.assertTrue;
-
-/**
- * @author Alex Snaps
- */
-public class ConcurrencyProblemCachePerfTest {
-
- private static final Logger LOG = LoggerFactory.getLogger(ConcurrencyProblemCachePerfTest.class.getName());
-
- @Test
- public void testContinuousThrashProgrammatic() throws Exception {
- CacheManager manager = new CacheManager(new Configuration().name("testContinuousThrashConfiguration"));
- try {
- Cache cache = new Cache("thrashcache", 5, false, false, 2, 5);
- manager.addCache(cache);
- for (int i = 0; i < 5; i++) {
- thrashCache(cache, 1500L);
- LOG.info("Finished run.");
-
- }
- } finally {
- manager.shutdown();
- }
- }
-
- /**
- * This method tries to get the cache to slow up.
- * It creates 10 threads, does gets and puts.
- */
- private long thrashCache(final Cache cache, final long retrievalTime)
- throws Exception {
- StopWatch stopWatch = new StopWatch();
-
- // Create threads that do gets
- final List executables = new ArrayList();
- for (int i = 0; i < 10; i++) {
- final Executable executable = new Executable() {
- public void execute() throws Exception {
- for (int i = 0; i < 10; i++) {
- final String key = "key" + i;
- Object value = cache.get(key);
- if (value == null) {
- cache.put(new Element(key, "value" + i));
- }
- //The key will be in. Now check we can get it quickly
- checkRetrievalOnKnownKey(cache, retrievalTime, key);
- }
- }
- };
- executables.add(executable);
- }
-
- AbstractCacheTest.runThreads(executables);
- cache.removeAll();
- return stopWatch.getElapsedTime();
- }
-
-
- /**
- * Checks that the liveness method returns in less than a given amount of time.
- * liveness() is a method that simply returns a String. It should be very fast. It can be
- * delayed because it is a synchronized method, and must acquire
- * an object lock before continuing. The old blocking cache was taking up to several minutes in production
- *
- * @param cache a BlockingCache
- */
- private void checkRetrievalOnKnownKey(Cache cache, long requiredRetrievalTime, Serializable key) {
- StopWatch stopWatch = new StopWatch();
- cache.get(key);
- long measuredRetrievalTime = stopWatch.getElapsedTime();
- assertTrue("Retrieval time on known key is " + measuredRetrievalTime
- + " but should be less than " + requiredRetrievalTime + "ms",
- measuredRetrievalTime < requiredRetrievalTime);
- }
-}
-
Index: rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/net/sf/ehcache/osgi/EvenCacheLoader.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/net/sf/ehcache/osgi/EvenCacheLoader.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/net/sf/ehcache/osgi/EvenCacheLoader.java (revision 0)
@@ -1,12 +0,0 @@
-/*
- * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved.
- */
-package net.sf.ehcache.osgi;
-
-public class EvenCacheLoader extends IncrementingCacheLoader {
-
- public EvenCacheLoader() {
- super(true, 20000);
- }
-
-}
\ No newline at end of file
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/RecalculateSizeTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/RecalculateSizeTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/RecalculateSizeTest.java (revision 0)
@@ -1,346 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Random;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicLong;
-import java.util.concurrent.atomic.AtomicReference;
-
-import junit.framework.Assert;
-import junit.framework.TestCase;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.config.Configuration;
-import net.sf.ehcache.config.MemoryUnit;
-import net.sf.ehcache.pool.SizeOfEngine;
-import net.sf.ehcache.pool.impl.DefaultSizeOfEngine;
-
-public class RecalculateSizeTest extends TestCase {
- private static final Random random;
-
- static {
- final long seed = System.currentTimeMillis();
- System.out.println("*** RANDOM SEEDED WITH " + seed + " ***");
- random = new Random(seed);
- }
-
- private final SizeOfEngine engine = new DefaultSizeOfEngine(1000, true);
-
- public void testCustomValue() {
- DynamicSizedValue value = new DynamicSizedValue('A');
-
- value.shrinkSize();
- long shrinkedSize = engine.sizeOf(value, null, null).getCalculated();
-
- value.expandSize();
- long expandedSize = engine.sizeOf(value, null, null).getCalculated();
-
- System.out.println("Shrinked size: " + shrinkedSize + ", expanded size: " + expandedSize);
-
- Assert.assertTrue(expandedSize > shrinkedSize);
- // consumes 6mb, assert diff is at least 5mb
- Assert.assertTrue(expandedSize - shrinkedSize > MemoryUnit.MEGABYTES.toBytes(5));
-
- value.shrinkSize();
- long shrinkedSize2 = engine.sizeOf(value, null, null).getCalculated();
-
- value.expandSize();
- long expandedSize2 = engine.sizeOf(value, null, null).getCalculated();
- System.out.println("Shrinked size2: " + shrinkedSize2 + ", expanded size2: " + expandedSize2);
-
- Assert.assertEquals(shrinkedSize, shrinkedSize2);
- Assert.assertEquals(expandedSize, expandedSize2);
-
- value.shrinkSize();
- value = null;
- }
-
- public void testRecalculateSizeGrowing() {
- CacheManager cm = createCacheManager();
- cm.addCache(createCache("test-cache-growing"));
-
- Cache cache = cm.getCache("test-cache-growing");
- Assert.assertEquals(0, cache.getStatistics().getLocalHeapSizeInBytes());
-
- DynamicSizedValue value = new DynamicSizedValue('A');
- value.shrinkSize();
- long valueShrinkedSize = engine.sizeOf(value, null, null).getCalculated();
- value.expandSize();
- long valueExpandedSize = engine.sizeOf(value, null, null).getCalculated();
- long valueSizeDiff = valueExpandedSize - valueShrinkedSize;
-
- value.shrinkSize();
- cache.put(new Element("key", value));
- long shrinkedSize = cache.getStatistics().getLocalHeapSizeInBytes();
-
- value.expandSize();
- long expandedSizeBeforeRecalculate = cache.getStatistics().getLocalHeapSizeInBytes();
-
- cache.recalculateSize("key");
- long expandedSize = cache.getStatistics().getLocalHeapSizeInBytes();
-
- long expectedExpandedSize = shrinkedSize + valueSizeDiff;
-
- System.out.println("Shrinked size: " + shrinkedSize + ", expandedSizeBeforeRecalculate: " + expandedSizeBeforeRecalculate
- + ", expandedSize: " + expandedSize + ", expectedExpandedSize: " + expectedExpandedSize + ", valueShrinkedSize: "
- + valueShrinkedSize + ", valueExpandedSize: " + valueExpandedSize);
- Assert.assertEquals(shrinkedSize, expandedSizeBeforeRecalculate);
- Assert.assertTrue(expandedSize > shrinkedSize);
- Assert.assertEquals(valueSizeDiff, expandedSize - expandedSizeBeforeRecalculate);
- Assert.assertEquals(expectedExpandedSize, expandedSize);
-
- cache.remove("key");
- cm.shutdown();
- }
-
- public void testRecalculateSizeShrinking() {
- CacheManager cm = createCacheManager();
- cm.addCache(createCache("test-cache-shrinking"));
-
- Cache cache = cm.getCache("test-cache-shrinking");
- Assert.assertEquals(0, cache.getStatistics().getLocalHeapSizeInBytes());
-
- DynamicSizedValue value = new DynamicSizedValue('A');
- value.shrinkSize();
- long valueShrinkedSize = engine.sizeOf(value, null, null).getCalculated();
- value.expandSize();
- long valueExpandedSize = engine.sizeOf(value, null, null).getCalculated();
- long valueSizeDiff = valueExpandedSize - valueShrinkedSize;
-
- value.expandSize();
- cache.put(new Element("key", value));
- long expandedSize = cache.getStatistics().getLocalHeapSizeInBytes();
-
- value.shrinkSize();
- long shrinkedSizeBeforeRecalculate = cache.getStatistics().getLocalHeapSizeInBytes();
-
- cache.recalculateSize("key");
- long shrinkedSize = cache.getStatistics().getLocalHeapSizeInBytes();
-
- long expectedShrinkedSize = expandedSize - valueSizeDiff;
-
- System.out.println("Shrinked size: " + shrinkedSize + ", shrinkedSizeBeforeRecalculate: " + shrinkedSizeBeforeRecalculate
- + ", expandedSize: " + expandedSize + ", expectedShrinkedSize: " + expectedShrinkedSize + ", valueShrinkedSize: "
- + valueShrinkedSize + ", valueExpandedSize: " + valueExpandedSize);
- Assert.assertEquals(expandedSize, shrinkedSizeBeforeRecalculate);
- Assert.assertTrue(expandedSize > shrinkedSize);
- Assert.assertEquals(valueSizeDiff, expandedSize - shrinkedSize);
- Assert.assertEquals(expectedShrinkedSize, shrinkedSize);
-
- cache.remove("key");
- cm.shutdown();
- }
-
- private Cache createCache(String name) {
- return new Cache(new CacheConfiguration().name(name));
- }
-
- private CacheManager createCacheManager() {
- return CacheManager.create(new Configuration().name("test-cm").maxBytesLocalHeap(40, MemoryUnit.MEGABYTES));
- }
-
- public void testMultipleRecalculates() throws Exception {
- System.out.println("Testing multiple recalculates...");
- final CacheManager cacheManager = createCacheManager();
- cacheManager.addCache(createCache("test-cache"));
- final Cache cache = cacheManager.getCache("test-cache");
- final AtomicBoolean stop = new AtomicBoolean(false);
- final AtomicReference error = new AtomicReference();
- final AtomicLong numRecalculates = new AtomicLong();
-
- final String key = "the-key";
- DynamicSizedValue value = new DynamicSizedValue('A');
- value.setSize(random.nextInt(100000) + 100000);
- cache.put(new Element(key, value));
- long initialInMemorySizeBytes = cache.getStatistics().getLocalHeapSizeInBytes();
- System.out.println("Initial: inMemorySizeBytes: " + initialInMemorySizeBytes);
-
- final int numThreads = 50;
- final Thread[] threads = new Thread[numThreads];
- for (int i = 0; i < numThreads; i++) {
- threads[i] = new Thread(new Runnable() {
-
- public void run() {
- try {
- while (!stop.get()) {
- cache.recalculateSize(key);
- numRecalculates.incrementAndGet();
- }
- } catch (Throwable e) {
- error.set(e);
- stop.set(true);
- }
- }
-
- }, "Test thread - " + i);
-
- threads[i].setDaemon(true);
- threads[i].start();
- }
-
- for (int i = 0; i < 10; i++) {
- cache.recalculateSize(key);
- long inMemorySizeBytes = cache.getStatistics().getLocalHeapSizeInBytes();
- System.out.println("initialInMemorySizeBytes: " + initialInMemorySizeBytes + ", calculatedInMemorySizeBytes: "
- + inMemorySizeBytes + ", numRecalculates: " + numRecalculates.get());
- Assert.assertEquals(initialInMemorySizeBytes, cache.getStatistics().getLocalHeapSizeInBytes());
- Thread.sleep(1000);
- }
-
- stop.set(true);
- for (Thread t : threads) {
- t.join();
- }
-
- Assert.assertEquals(initialInMemorySizeBytes, cache.getStatistics().getLocalHeapSizeInBytes());
-
- cacheManager.shutdown();
- }
-
- public void testMultipleRecalculatesAndMutates() throws Exception {
- System.out.println("Testing multiple recalculates with mutation...");
- final CacheManager cacheManager = createCacheManager();
- cacheManager.addCache(createCache("test-cache"));
- final Cache cache = cacheManager.getCache("test-cache");
- final AtomicBoolean stop = new AtomicBoolean(false);
- final AtomicReference error = new AtomicReference();
- final AtomicLong numRecalculates = new AtomicLong();
-
- final String key = "the-key";
- DynamicSizedValue value = new DynamicSizedValue('A');
- value.setSize(random.nextInt(100000));
- cache.put(new Element(key, value));
-
- final int numThreads = 50;
- final Thread[] threads = new Thread[numThreads];
- for (int i = 0; i < numThreads; i++) {
- threads[i] = new Thread(new Runnable() {
-
- public void run() {
- try {
- while (!stop.get()) {
- cache.recalculateSize(key);
- numRecalculates.incrementAndGet();
- }
- } catch (Throwable e) {
- error.set(e);
- stop.set(true);
- }
- }
-
- }, "Test thread - " + i);
-
- threads[i].setDaemon(true);
- threads[i].start();
- }
- int numChanges = 1;
- final int maxNumChanges = 100;
- int lastValueSize = 0;
- List valueSizeToCalculatedSizeList = new ArrayList();
- while (numChanges <= maxNumChanges && !stop.get()) {
- lastValueSize = random.nextInt((int) MemoryUnit.KILOBYTES.toBytes(30));
- value = new DynamicSizedValue('A');
- value.setSize(lastValueSize);
- cache.put(new Element(key, value));
- long calculatedInMemorySizeBytes = cache.getStatistics().getLocalHeapSizeInBytes();
- if (numChanges % 10 == 0) {
- System.out.println("numChanges: " + numChanges + ", numRecalculates: " + numRecalculates.get() + ", InMemorySizeBytes: "
- + calculatedInMemorySizeBytes + ", lastValueSize: " + lastValueSize);
- }
- valueSizeToCalculatedSizeList.add(new ValueSizeToCalculatedSizeTuple(lastValueSize, calculatedInMemorySizeBytes));
- numChanges++;
- }
-
- for (int i = 0; i < 3; i++) {
- cache.recalculateSize(key);
- long calculatedMemorySizeBytes = cache.getStatistics().getLocalHeapSizeInBytes();
- System.out.println("calculatedMemorySizeBytes: " + calculatedMemorySizeBytes + ", lastValueSize: " + lastValueSize
- + ", numRecalculates: " + numRecalculates.get());
- valueSizeToCalculatedSizeList.add(new ValueSizeToCalculatedSizeTuple(lastValueSize, calculatedMemorySizeBytes));
- Thread.sleep(1000);
- }
-
- System.out.println("Done with changing size randomly. Waiting for all test threads to finish");
-
- stop.set(true);
- for (Thread t : threads) {
- t.join();
- }
-
- cache.remove(key);
- long sizeAfterRemove = cache.getStatistics().getLocalHeapSizeInBytes();
- Assert.assertEquals(0, sizeAfterRemove);
-
- for (ValueSizeToCalculatedSizeTuple tuple : valueSizeToCalculatedSizeList) {
- int valueSize = tuple.valueSize;
- long calculatedMemorySizeBytes = tuple.calculatedInMemorySizeBytes;
-
- Assert.assertEquals(0, cache.getStatistics().getLocalHeapSizeInBytes());
- DynamicSizedValue v = new DynamicSizedValue('A');
- v.setSize(valueSize);
- cache.put(new Element(key, v));
- long actualCaculatedInMemorySize = cache.getStatistics().getLocalHeapSizeInBytes();
- System.out.println("valueSize: " + valueSize + ", expectedCalculatedMemorySizeBytes: " + calculatedMemorySizeBytes
- + ", actual: " + actualCaculatedInMemorySize);
- Assert.assertEquals(calculatedMemorySizeBytes, actualCaculatedInMemorySize);
-
- cache.remove(key);
- }
-
- cacheManager.shutdown();
- }
-
- private static class ValueSizeToCalculatedSizeTuple {
- final int valueSize;
- final long calculatedInMemorySizeBytes;
-
- public ValueSizeToCalculatedSizeTuple(int valueSize, long calculatedInMemorySizeBytes) {
- this.valueSize = valueSize;
- this.calculatedInMemorySizeBytes = calculatedInMemorySizeBytes;
- }
-
- }
-
- public static class DynamicSizedValue {
- private volatile char[] chars;
- private final char singleChar;
-
- public DynamicSizedValue(char singleChar) {
- this.singleChar = singleChar;
- }
-
- public void shrinkSize() {
- this.chars = null;
- }
-
- public void expandSize() {
- setSize((int) MemoryUnit.MEGABYTES.toBytes(3));
- }
-
- private void setSize(int bytes) {
- this.chars = null;
- this.chars = new char[bytes];
- for (int i = 0; i < chars.length; i++) {
- chars[i] = singleChar;
- }
- }
-
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/expression/LessThanOrEqual.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/expression/LessThanOrEqual.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/search/expression/LessThanOrEqual.java (revision 0)
@@ -1,64 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.search.expression;
-
-/**
- * Less than or equal criteria
- *
- * @author teck
- */
-public class LessThanOrEqual extends ComparableValue {
-
- private final Comparable comparableValue;
-
- /**
- * Constructor
- *
- * @param attributeName attribute name
- * @param value
- */
- public LessThanOrEqual(String attributeName, Object value) {
- super(attributeName, value);
- this.comparableValue = (Comparable) value;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- protected boolean executeComparable(Comparable attributeValue) {
- return attributeValue.compareTo(comparableValue) <= 0;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- protected boolean executeComparableString(Comparable attributeValue) {
- return luceneStringCompare(attributeValue.toString(), comparableValue.toString()) <= 0;
- }
-
- /**
- * Comparable value.
- *
- * @return value
- */
- public Comparable getComparableValue() {
- return comparableValue;
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/distribution/events/src/assemble/bin/package.bat
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/distribution/events/src/assemble/bin/package.bat (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/distribution/events/src/assemble/bin/package.bat (revision 0)
@@ -1,66 +0,0 @@
-@echo off
-
-if not defined JAVA_HOME (
- echo JAVA_HOME is not defined
- exit /b 1
-)
-
-setlocal
-
-set JAVA_HOME="%JAVA_HOME:"=%"
-set bin_dir="%~d0%~p0"
-set root=%~d0%~p0..
-set root="%root:"=%"
-set jetty1=%root%\jetty6.1\9081\webapps
-set jetty2=%root%\jetty6.1\9082\webapps
-
-cd %bin_dir%
-for /f "tokens=*" %%a in ('call relative-paths.bat ehcache_jars_dir') do set ehcache_jars_dir=%%a
-pushd
-cd %ehcache_jars_dir%
-set ehcache_jars_dir=%CD%
-set ehcache_jars_dir="%ehcache_jars_dir:"=%"
-popd
-
-cd %bin_dir%
-for /f "tokens=*" %%a in ('call relative-paths.bat tc_install_dir') do set tc_install_dir=%%a
-pushd
-cd %tc_install_dir%
-set tc_install_dir=%CD%
-set tc_install_dir="%tc_install_dir:"=%"
-popd
-
-set appname=events
-
-cd %root%
-set webapp_lib=webapps\%appname%\WEB-INF\lib
-
-rem package ehcache-core and ehcache-terracotta
-xcopy /y /q %ehcache_jars_dir%\lib\ehcache*.jar %webapp_lib% 1> NUL
-
-if exist %tc_install_dir%\common\terracotta-toolkit*-runtime*.jar (
- set toolkit_runtime=%tc_install_dir%\common\terracotta-toolkit*-runtime*.jar
-)
-
-if exist %ehcache_jars_dir%\lib\terracotta-toolkit*-runtime*.jar (
- set toolkit_runtime=%ehcache_jars_dir%\lib\terracotta-toolkit*-runtime*.jar
-)
-
-if not exist %toolkit_runtime% (
- echo Couldn't locate toolkit runtime jar
- exit /b 1
-)
-
-xcopy /y /q %toolkit_runtime% %webapp_lib% 1> NUL
-
-if %errorlevel% == 0 (
- echo Deploying demo...
- xcopy /y /q /e webapps %jetty1% 1> NUL
- xcopy /y /q /e webapps %jetty2% 1> NUL
- echo Done.
-) else (
- echo Error packaging sample
- exit /b 1
-)
-
-endlocal
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/CacheSamplerImpl.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/CacheSamplerImpl.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/CacheSamplerImpl.java (revision 0)
@@ -1,2134 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.management.sampled;
-
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.CacheOperationOutcomes;
-import net.sf.ehcache.CacheOperationOutcomes.ClusterEventOutcomes;
-import net.sf.ehcache.CacheOperationOutcomes.NonStopOperationOutcomes;
-import net.sf.ehcache.CacheStoreHelper;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.config.CacheConfigurationListener;
-import net.sf.ehcache.config.PersistenceConfiguration;
-import net.sf.ehcache.config.PinningConfiguration;
-import net.sf.ehcache.config.SearchAttribute;
-import net.sf.ehcache.config.TerracottaConfiguration.Consistency;
-import net.sf.ehcache.search.Attribute;
-import net.sf.ehcache.store.Store;
-import net.sf.ehcache.store.TerracottaStore;
-import net.sf.ehcache.util.CacheTransactionHelper;
-import net.sf.ehcache.util.counter.sampled.SampledCounter;
-import net.sf.ehcache.util.counter.sampled.SampledRateCounter;
-import net.sf.ehcache.util.counter.sampled.TimeStampedCounterValue;
-import net.sf.ehcache.writer.writebehind.WriteBehindManager;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.statistics.archive.Timestamped;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * An implementation of {@link CacheSampler}
- *
- * @author Abhishek Sanoujam
- * @author byoukste
- *
- * There is stupid here -- *Sample() is the same as *Rate()
- */
-public class CacheSamplerImpl implements CacheSampler, CacheConfigurationListener {
- private static final double ONE_HUNDRED = 100.0d;
-
- private static final int PERCENTAGE_DIVISOR = 100;
-
- private static final Logger LOG = LoggerFactory.getLogger(CacheSamplerImpl.class);
-
- private final Ehcache cache;
-
- /**
- * Constructor accepting the backing {@link Ehcache}
- *
- * @param cache the cache object to use in initializing this sampled representation
- */
- public CacheSamplerImpl(Ehcache cache) {
- this.cache = cache;
- cache.getCacheConfiguration().addConfigurationListener(this);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isEnabled() {
- return !cache.isDisabled();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setEnabled(boolean enabled) {
- try {
- cache.setDisabled(!enabled);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isClusterBulkLoadEnabled() {
- try {
- return cache.isClusterBulkLoadEnabled();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isNodeBulkLoadEnabled() {
- return cache.getCacheConfiguration().isTerracottaClustered() && cache.isNodeBulkLoadEnabled();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setNodeBulkLoadEnabled(boolean bulkLoadEnabled) {
- if (bulkLoadEnabled && getTransactional()) {
- LOG.warn("a transactional cache cannot be put into bulk-load mode");
- return;
- }
- cache.setNodeBulkLoadEnabled(bulkLoadEnabled);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void flush() {
- try {
- cache.flush();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getCacheName() {
- return cache.getName();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getStatus() {
- return cache.getStatus().toString();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void removeAll() {
- if (cache instanceof Cache) {
- Store store = new CacheStoreHelper((Cache)cache).getStore();
- if (store instanceof TerracottaStore) {
- ((TerracottaStore)store).quickClear();
- cache.getCacheEventNotificationService().notifyRemoveAll(false);
- PinningConfiguration pinningConfiguration = cache.getCacheConfiguration().getPinningConfiguration();
- if (pinningConfiguration != null && PinningConfiguration.Store.INCACHE.equals(pinningConfiguration.getStore())) {
- LOG.warn("Data availability impacted:\n" +
- "****************************************************************************************\n" +
- "************************** removeAll called on a pinned cache **************************\n" +
- "****************************************************************************************");
- }
- return;
- }
- }
-
- CacheTransactionHelper.beginTransactionIfNeeded(cache);
- try {
- cache.removeAll();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- } finally {
- try {
- CacheTransactionHelper.commitTransactionIfNeeded(cache);
- } catch (RuntimeException e2) {
- throw Utils.newPlainException(e2);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getAverageGetTimeNanosMostRecentSample() {
- return getAverageGetTimeNanos();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheEvictionRate() {
- return cache.getStatistics().cacheEvictionOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheElementEvictedMostRecentSample() {
- return getCacheEvictionRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheExpirationRate() {
- return cache.getStatistics().cacheExpiredOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheElementExpiredMostRecentSample() {
- return getCacheExpirationRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCachePutRate() {
- return cache.getStatistics().cachePutOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheElementPutMostRecentSample() {
- return getCachePutRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheRemoveRate() {
- return cache.getStatistics().cacheRemoveOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheElementRemovedMostRecentSample() {
- return getCacheRemoveRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheUpdateRate() {
- return cache.getStatistics().cachePutReplacedOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheElementUpdatedMostRecentSample() {
- return getCacheUpdateRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheInMemoryHitRate() {
- return cache.getStatistics().localHeapHitOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitInMemoryMostRecentSample() {
- return getCacheInMemoryHitRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheOffHeapHitRate() {
- return cache.getStatistics().localOffHeapHitOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitOffHeapMostRecentSample() {
- return getCacheOffHeapHitRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitRate() {
- return cache.getStatistics().cacheHitOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitMostRecentSample() {
- return getCacheHitRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheOnDiskHitRate() {
- return cache.getStatistics().localDiskHitOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitOnDiskMostRecentSample() {
- return getCacheOnDiskHitRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissExpiredMostRecentSample() {
- return cache.getStatistics().cacheMissExpiredOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissRate() {
- return cache.getStatistics().cacheMissOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissMostRecentSample() {
- return getCacheMissRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheInMemoryMissRate() {
- return cache.getStatistics().localHeapMissOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissInMemoryMostRecentSample() {
- return getCacheInMemoryMissRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheOffHeapMissRate() {
- return cache.getStatistics().localOffHeapMissOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissOffHeapMostRecentSample() {
- return getCacheOffHeapMissRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheOnDiskMissRate() {
- return cache.getStatistics().localDiskMissOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissOnDiskMostRecentSample() {
- return getCacheOnDiskMissRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissNotFoundMostRecentSample() {
- return cache.getStatistics().cacheMissNotFoundOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void dispose() {
- cache.getCacheConfiguration().removeConfigurationListener(this);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isTerracottaClustered() {
- return this.cache.getCacheConfiguration().isTerracottaClustered();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getTerracottaConsistency() {
- Consistency consistency = this.cache.getCacheConfiguration().getTerracottaConsistency();
- return consistency != null ? consistency.name() : "na";
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getAverageGetTime() {
- try {
- return cache.getStatistics().cacheGetOperation().latency().average().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Long getMaxGetTimeNanos() {
- try {
- return (Long)cache.getStatistics().cacheGetOperation().latency().maximum().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Long getMinGetTimeNanos() {
- try {
- return (Long)cache.getStatistics().cacheGetOperation().latency().minimum().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getXaCommitCount() {
- try {
- return cache.getStatistics().xaCommitCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getXaRollbackCount() {
- try {
- return cache.getStatistics().xaRollbackCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getXaRecoveredCount() {
- try {
- return cache.getStatistics().xaRecoveryCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean getHasWriteBehindWriter() {
- return cache.getWriterManager() instanceof WriteBehindManager && cache.getRegisteredCacheWriter() != null;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getWriterQueueLength() {
- try {
- return cache.getStatistics().getWriterQueueLength();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getWriterMaxQueueSize() {
- return cache.getCacheConfiguration().getCacheWriterConfiguration().getWriteBehindMaxQueueSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getWriterConcurrency() {
- return cache.getCacheConfiguration().getCacheWriterConfiguration().getWriteBehindConcurrency();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheHitCount() {
- try {
- return cache.getStatistics().cacheHitCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissCount() {
- try {
- return cache.getStatistics().cacheMissCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getInMemoryMissCount() {
- try {
- return cache.getStatistics().localHeapMissCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOffHeapMissCount() {
- try {
- return cache.getStatistics().localOffHeapMissCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOnDiskMissCount() {
- try {
- return cache.getStatistics().localDiskMissCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheMissCountExpired() {
- try {
- return cache.getStatistics().cacheMissExpiredCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getDiskExpiryThreadIntervalSeconds() {
- return cache.getCacheConfiguration().getDiskExpiryThreadIntervalSeconds();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setDiskExpiryThreadIntervalSeconds(long seconds) {
- if (getDiskExpiryThreadIntervalSeconds() != seconds) {
- try {
- cache.getCacheConfiguration().setDiskExpiryThreadIntervalSeconds(seconds);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxEntriesLocalHeap() {
- return cache.getCacheConfiguration().getMaxEntriesLocalHeap();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxEntriesLocalHeap(long maxEntries) {
- if (getMaxEntriesLocalHeap() != maxEntries) {
- try {
- cache.getCacheConfiguration().setMaxEntriesLocalHeap(maxEntries);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxBytesLocalHeap() {
- return cache.getCacheConfiguration().getMaxBytesLocalHeap();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxBytesLocalHeap(long maxBytes) {
- try {
- if (cache.getCacheManager().getConfiguration().isMaxBytesLocalHeapSet()) {
- long heapPoolSize = cache.getCacheManager().getConfiguration().getMaxBytesLocalHeap();
- if (maxBytes > heapPoolSize) {
- throw new IllegalArgumentException("Requested maxBytesLocalHeap (" + maxBytes
- + ") greater than available CacheManager heap pool size (" + heapPoolSize + ")");
- }
- }
- cache.getCacheConfiguration().setMaxBytesLocalHeap(maxBytes);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxBytesLocalHeapAsString(String maxBytes) {
- try {
- cache.getCacheConfiguration().setMaxBytesLocalHeap(maxBytes);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
-
- if (cache.getCacheConfiguration().isMaxBytesLocalHeapPercentageSet()) {
- long cacheAssignedMem = cache.getCacheManager().getConfiguration().getMaxBytesLocalHeap()
- * cache.getCacheConfiguration().getMaxBytesLocalHeapPercentage() / PERCENTAGE_DIVISOR;
- setMaxBytesLocalHeap(cacheAssignedMem);
- }
-
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getMaxBytesLocalHeapAsString() {
- return cache.getCacheConfiguration().getMaxBytesLocalHeapAsString();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxEntriesLocalDisk() {
- return cache.getCacheConfiguration().getMaxEntriesLocalDisk();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxEntriesLocalDisk(long maxEntries) {
- if (getMaxEntriesLocalDisk() != maxEntries) {
- try {
- cache.getCacheConfiguration().setMaxEntriesLocalDisk(maxEntries);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@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);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxBytesLocalDiskAsString(String maxBytes) {
- try {
- cache.getCacheConfiguration().setMaxBytesLocalDisk(maxBytes);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
-
- if (cache.getCacheConfiguration().isMaxBytesLocalDiskPercentageSet()) {
- long cacheAssignedMem = cache.getCacheManager().getConfiguration().getMaxBytesLocalDisk()
- * cache.getCacheConfiguration().getMaxBytesLocalDiskPercentage() / PERCENTAGE_DIVISOR;
- setMaxBytesLocalDisk(cacheAssignedMem);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getMaxBytesLocalDiskAsString() {
- return cache.getCacheConfiguration().getMaxBytesLocalDiskAsString();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getMaxElementsOnDisk() {
- return cache.getCacheConfiguration().getMaxElementsOnDisk();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxEntriesInCache() {
- return cache.getCacheConfiguration().getMaxEntriesInCache();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxElementsOnDisk(int maxElements) {
- if (getMaxElementsOnDisk() != maxElements) {
- try {
- cache.getCacheConfiguration().setMaxElementsOnDisk(maxElements);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMaxEntriesInCache(long maxEntries) {
- if (getMaxEntriesInCache() != maxEntries) {
- try {
- cache.getCacheConfiguration().setMaxEntriesInCache(maxEntries);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxBytesLocalDisk() {
- return cache.getCacheConfiguration().getMaxBytesLocalDisk();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getMaxBytesLocalOffHeap() {
- return cache.getCacheConfiguration().getMaxBytesLocalOffHeap();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getMaxBytesLocalOffHeapAsString() {
- return cache.getCacheConfiguration().getMaxBytesLocalOffHeapAsString();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getMemoryStoreEvictionPolicy() {
- return cache.getCacheConfiguration().getMemoryStoreEvictionPolicy().toString();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setMemoryStoreEvictionPolicy(String evictionPolicy) {
- if (!getMemoryStoreEvictionPolicy().equals(evictionPolicy)) {
- try {
- cache.getCacheConfiguration().setMemoryStoreEvictionPolicy(evictionPolicy);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getTimeToIdleSeconds() {
- return cache.getCacheConfiguration().getTimeToIdleSeconds();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setTimeToIdleSeconds(long tti) {
- if (getTimeToIdleSeconds() != tti) {
- try {
- cache.getCacheConfiguration().setTimeToIdleSeconds(tti);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getTimeToLiveSeconds() {
- return cache.getCacheConfiguration().getTimeToLiveSeconds();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setTimeToLiveSeconds(long ttl) {
- if (getTimeToLiveSeconds() != ttl) {
- try {
- cache.getCacheConfiguration().setTimeToLiveSeconds(ttl);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isDiskPersistent() {
- return cache.getCacheConfiguration().isDiskPersistent();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getPersistenceStrategy() {
- PersistenceConfiguration pc = cache.getCacheConfiguration().getPersistenceConfiguration();
- return pc != null ? pc.getStrategy().name() : "";
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setDiskPersistent(boolean diskPersistent) {
- if (isDiskPersistent() != diskPersistent) {
- try {
- cache.getCacheConfiguration().setDiskPersistent(diskPersistent);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isOverflowToOffHeap() {
- return cache.getCacheConfiguration().isOverflowToOffHeap();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isEternal() {
- return cache.getCacheConfiguration().isEternal();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setEternal(boolean eternal) {
- if (isEternal() != eternal) {
- try {
- cache.getCacheConfiguration().setEternal(eternal);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isOverflowToDisk() {
- return cache.getCacheConfiguration().isOverflowToDisk();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setOverflowToDisk(boolean overflowToDisk) {
- if (isOverflowToDisk() != overflowToDisk) {
- try {
- cache.getCacheConfiguration().setOverflowToDisk(overflowToDisk);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isLoggingEnabled() {
- return cache.getCacheConfiguration().getLogging();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void setLoggingEnabled(boolean enabled) {
- if (isLoggingEnabled() != enabled) {
- try {
- cache.getCacheConfiguration().setLogging(enabled);
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isPinned() {
- return cache.getCacheConfiguration().getPinningConfiguration() != null;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public String getPinnedToStore() {
- PinningConfiguration pinningConfig = cache.getCacheConfiguration().getPinningConfiguration();
- return pinningConfig != null ? pinningConfig.getStore().name() : "na";
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getEvictedCount() {
- try {
- return cache.getStatistics().cacheEvictedCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getExpiredCount() {
- try {
- return cache.getStatistics().cacheExpiredCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getInMemoryHitCount() {
- try {
- return cache.getStatistics().localHeapHitCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOffHeapHitCount() {
- try {
- return cache.getStatistics().localOffHeapHitCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- *
- * @deprecated use {@link #getLocalOffHeapSize()}
- */
- @Deprecated
- @Override
- public long getOffHeapSize() {
- return getLocalOffHeapSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getOnDiskHitCount() {
- try {
- return cache.getStatistics().localDiskHitCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- *
- * @deprecated use {@link #getLocalDiskSize()}
- */
- @Deprecated
- @Override
- public long getOnDiskSize() {
- return getLocalDiskSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalDiskSize() {
- try {
- return cache.getStatistics().getLocalDiskSize();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalHeapSize() {
- try {
- return cache.getStatistics().getLocalHeapSize();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalOffHeapSize() {
- try {
- return cache.getStatistics().getLocalOffHeapSize();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalDiskSizeInBytes() {
- try {
- return cache.getStatistics().getLocalDiskSizeInBytes();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalHeapSizeInBytes() {
- try {
- return cache.getStatistics().getLocalHeapSizeInBytes();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getLocalOffHeapSizeInBytes() {
- try {
- return cache.getStatistics().getLocalOffHeapSizeInBytes();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getPutCount() {
- try {
- return cache.getStatistics().cachePutCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getRemovedCount() {
- try {
- return cache.getStatistics().cacheRemoveCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getSize() {
- if (cache.getCacheConfiguration().isTerracottaClustered()) {
- return getRemoteSizeSample().getMostRecentSample().getCounterValue();
- }
- CacheTransactionHelper.beginTransactionIfNeeded(cache);
- try {
- return cache.getStatistics().getSize();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- } finally {
- try {
- CacheTransactionHelper.commitTransactionIfNeeded(cache);
- } catch (RuntimeException re) {
- throw Utils.newPlainException(re);
- }
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getInMemorySize() {
- return getLocalHeapSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getUpdateCount() {
- try {
- return cache.getStatistics().cachePutUpdatedCount();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceOneArgSuccessCount() {
- try {
- return cache.getStatistics().getExtended().replaceOneArg().component(CacheOperationOutcomes.ReplaceOneArgOutcome.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceOneArgSuccessRate() {
- try {
- return cache.getStatistics().getExtended().replaceOneArg().component(CacheOperationOutcomes.ReplaceOneArgOutcome.SUCCESS).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceOneArgMissCount() {
- try {
- return cache.getStatistics().getExtended().replaceOneArg().component(CacheOperationOutcomes.ReplaceOneArgOutcome.FAILURE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceOneArgMissRate() {
- try {
- return cache.getStatistics().getExtended().replaceOneArg().component(CacheOperationOutcomes.ReplaceOneArgOutcome.FAILURE).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceTwoArgSuccessCount() {
- try {
- return cache.getStatistics().getExtended().replaceTwoArg().component(CacheOperationOutcomes.ReplaceTwoArgOutcome.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceTwoArgSuccessRate() {
- try {
- return cache.getStatistics().getExtended().replaceTwoArg().component(CacheOperationOutcomes.ReplaceTwoArgOutcome.SUCCESS).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceTwoArgMissCount() {
- try {
- return cache.getStatistics().getExtended().replaceTwoArg().component(CacheOperationOutcomes.ReplaceTwoArgOutcome.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getReplaceTwoArgMissRate() {
- try {
- return cache.getStatistics().getExtended().replaceTwoArg().component(CacheOperationOutcomes.ReplaceTwoArgOutcome.FAILURE).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getPutIfAbsentSuccessCount() {
- try {
- return cache.getStatistics().getExtended().putIfAbsent().component(CacheOperationOutcomes.PutIfAbsentOutcome.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getPutIfAbsentSuccessRate() {
- try {
- return cache.getStatistics().getExtended().putIfAbsent().component(CacheOperationOutcomes.PutIfAbsentOutcome.SUCCESS).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getPutIfAbsentMissCount() {
- try {
- return cache.getStatistics().getExtended().putIfAbsent().component(
- CacheOperationOutcomes.PutIfAbsentOutcome.FAILURE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getPutIfAbsentMissRate() {
- try {
- return cache.getStatistics().getExtended().putIfAbsent().component(CacheOperationOutcomes.PutIfAbsentOutcome.FAILURE).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getRemoveElementSuccessCount() {
- try {
- return cache.getStatistics().getExtended().removeElement().component(
- CacheOperationOutcomes.RemoveElementOutcome.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getRemoveElementSuccessRate() {
- try {
- return cache.getStatistics().getExtended().removeElement().component(CacheOperationOutcomes.RemoveElementOutcome.SUCCESS).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getRemoveElementMissCount() {
- try {
- return cache.getStatistics().getExtended().removeElement().component(
- CacheOperationOutcomes.RemoveElementOutcome.FAILURE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getRemoveElementMissRate() {
- try {
- return cache.getStatistics().getExtended().removeElement().component(CacheOperationOutcomes.RemoveElementOutcome.FAILURE).rate().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void deregistered(CacheConfiguration config) {
- /**/
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void maxBytesLocalHeapChanged(final long oldValue, final long newValue) {
- if (oldValue != newValue) {
- setMaxBytesLocalHeap(newValue);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void maxBytesLocalDiskChanged(final long oldValue, final long newValue) {
- if (oldValue != newValue) {
- setMaxBytesLocalDisk(newValue);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void diskCapacityChanged(int oldCapacity, int newCapacity) {
- if (oldCapacity != newCapacity) {
- setMaxElementsOnDisk(newCapacity);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void maxEntriesInCacheChanged(long oldCapacity, long newCapacity) {
- if (oldCapacity != newCapacity) {
- setMaxEntriesInCache(newCapacity);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void loggingChanged(boolean oldValue, boolean newValue) {
- if (oldValue != newValue) {
- setLoggingEnabled(newValue);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void memoryCapacityChanged(int oldCapacity, int newCapacity) {
- if (oldCapacity != newCapacity) {
- setMaxEntriesLocalHeap(newCapacity);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void registered(CacheConfiguration config) {
- /**/
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void timeToIdleChanged(long oldTimeToIdle, long newTimeToIdle) {
- if (oldTimeToIdle != newTimeToIdle) {
- setTimeToIdleSeconds(newTimeToIdle);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public void timeToLiveChanged(long oldTimeToLive, long newTimeToLive) {
- if (oldTimeToLive != newTimeToLive) {
- setTimeToLiveSeconds(newTimeToLive);
- }
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getAverageSearchTime() {
- return cache.getStatistics().cacheSearchOperation().latency().average().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getSearchesPerSecond() {
- return getCacheSearchRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean getTransactional() {
- return cache.getCacheConfiguration().getTransactionalMode().isTransactional();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean getSearchable() {
- return cache.getCacheConfiguration().getSearchable() != null;
- }
-
- @Override
- public Map getSearchAttributes() {
- Map result = new HashMap();
-
- if (cache != null && cache.getCacheConfiguration().getSearchable() != null) {
- Map attrMap = new HashMap();
-
- for (Attribute attr : cache.getSearchAttributes()) {
- attrMap.put(attr.getAttributeName(), attr);
- }
-
- for (SearchAttribute sa : cache.getCacheConfiguration().getSearchAttributes().values()) {
- String saName = sa.getName();
- String typeName = sa.getTypeName();
-
- if (attrMap.containsKey(saName) && typeName != null) {
- result.put(saName, typeName);
- }
- }
- }
- return result;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheSearchRate() {
- return cache.getStatistics().cacheSearchOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getTransactionCommitRate() {
- return cache.getStatistics().xaRecoveryOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheXaCommitsMostRecentSample() {
- return getTransactionCommitRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getTransactionRollbackRate() {
- return cache.getStatistics().xaRollbackOperation().rate().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public long getCacheXaRollbacksMostRecentSample() {
- return getTransactionRollbackRate();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public boolean isLocalHeapCountBased() {
- return cache.getCacheConfiguration()
- .getMaxBytesLocalHeap() <= 0 && !(cache.getCacheManager() != null && cache.getCacheManager()
- .getConfiguration()
- .isMaxBytesLocalHeapSet());
- }
-
- /**
- * A package friendly method to allow dependants access to the underlying {@link Ehcache} object. This is available
- * in order to allow {@link SampledCache} objects to continue to provide deprecated methods on the {@link SampledCacheMBean} interface,
- * rather than burdening {@link CacheSampler} with these now irrelevant methods. This helper method
- * should be removed if we are ever able to discontinue support for the deprecated methods on dependant interfaces.
- *
- * @return the underlying {@code Ehcache} object
- */
- Ehcache getCache() {
- return cache;
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getCacheHitRatio() {
- return (int) (cache.getStatistics().getExtended().cacheHitRatio().value().doubleValue() * ONE_HUNDRED);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public int getCacheHitRatioMostRecentSample() {
- return getCacheHitRatio();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheHitRatioSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().cacheHitRatio()) {
-
- @Override
- public TimeStampedCounterValue getMostRecentSample() {
- return new TimeStampedCounterValue(System.currentTimeMillis(), getValue());
- }
-
- @Override
- public TimeStampedCounterValue[] getAllSampleValues() {
- ArrayList arr = new ArrayList();
- for (Timestamped ts : rate.history()) {
- arr.add(new TimeStampedCounterValue(ts.getTimestamp(), (int) (ts.getSample().doubleValue() * ONE_HUNDRED)));
- }
- return sortAndPresent(arr);
- }
-
- @Override
- public long getValue() {
- return (long) (rate.value().doubleValue() * ONE_HUNDRED);
- }
-
- };
- }
-
- @Override
- public long getAverageGetTimeNanos() {
- return cache.getStatistics().cacheGetOperation().latency().average().value().longValue();
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheHitSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheHitOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheHitInMemorySample() {
- return new SampledCounterProxy(cache.getStatistics().localHeapHitOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheHitOffHeapSample() {
- return new SampledCounterProxy(cache.getStatistics().localOffHeapHitOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheHitOnDiskSample() {
- return new SampledCounterProxy(cache.getStatistics().localDiskHitOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheMissOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissInMemorySample() {
- return new SampledCounterProxy(cache.getStatistics().localHeapMissOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissOffHeapSample() {
- return new SampledCounterProxy(cache.getStatistics().localOffHeapMissOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissOnDiskSample() {
- return new SampledCounterProxy(cache.getStatistics().localDiskMissOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissExpiredSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheMissExpiredOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheMissNotFoundSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheMissNotFoundOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheElementEvictedSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheEvictionOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheElementRemovedSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheRemoveOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheElementExpiredSample() {
- return new SampledCounterProxy(cache.getStatistics().cacheExpiredOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheElementPutSample() {
- return new SampledCounterProxy(cache.getStatistics().cachePutOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheElementUpdatedSample() {
- return new SampledCounterProxy(cache.getStatistics().cachePutReplacedOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledRateCounter getAverageGetTimeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().cacheGetOperation().latency().average());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledRateCounter getAverageSearchTimeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().cacheSearchOperation().latency().average());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getSearchesPerSecondSample() {
- return new SampledRateCounterProxy(cache.getStatistics().cacheSearchOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheXaCommitsSample() {
- return new SampledRateCounterProxy(cache.getStatistics().xaCommitSuccessOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getCacheXaRollbacksSample() {
- return new SampledRateCounterProxy(cache.getStatistics().xaRollbackOperation().rate());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getSizeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().size());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalHeapSizeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localHeapSize());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalHeapSizeInBytesSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localHeapSizeInBytes());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalOffHeapSizeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localOffHeapSize());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalOffHeapSizeInBytesSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localOffHeapSizeInBytes());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalDiskSizeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localDiskSize());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getLocalDiskSizeInBytesSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().localDiskSizeInBytes());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getRemoteSizeSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().remoteSize());
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public SampledCounter getWriterQueueLengthSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().writerQueueLength());
- }
-
- @Override
- public long getAverageSearchTimeNanos() {
- return getAverageSearchTime();
- }
-
- @Override
- public long getCacheClusterOfflineCount() {
- try {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.OFFLINE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getCacheClusterRejoinCount() {
- try {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.REJOINED).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getCacheClusterOnlineCount() {
- try {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.ONLINE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getCacheClusterOfflineMostRecentSample() {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.OFFLINE).rate().value().longValue();
- }
-
- @Override
- public long getCacheClusterRejoinMostRecentSample() {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.REJOINED).rate().value().longValue();
- }
-
- @Override
- public long getCacheClusterOnlineMostRecentSample() {
- return cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.ONLINE).rate().value().longValue();
- }
-
- @Override
- public SampledCounter getCacheClusterOfflineSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.OFFLINE).rate());
- }
-
- @Override
- public SampledCounter getCacheClusterOnlineSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.ONLINE).rate());
- }
-
- @Override
- public SampledCounter getCacheClusterRejoinSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().clusterEvent().component(ClusterEventOutcomes.REJOINED).rate());
- }
-
- @Override
- public long getMostRecentRejoinTimeStampMillis() {
- try {
- return cache.getStatistics().getExtended().mostRecentRejoinTimeStampMillis().value().longValue();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public SampledCounter getMostRecentRejoinTimestampMillisSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().mostRecentRejoinTimeStampMillis());
- }
-
- @Override
- public long getNonStopSuccessCount() {
- try {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.SUCCESS).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getNonStopFailureCount() {
- try {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.FAILURE).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getNonStopRejoinTimeoutCount() {
- try {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.REJOIN_TIMEOUT).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getNonStopTimeoutCount() {
- try {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.TIMEOUT).count().value();
- } catch (RuntimeException e) {
- throw Utils.newPlainException(e);
- }
- }
-
- @Override
- public long getNonStopSuccessMostRecentSample() {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.SUCCESS).rate().value().longValue();
- }
-
- @Override
- public long getNonStopFailureMostRecentSample() {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.FAILURE).rate().value().longValue();
- }
-
- @Override
- public long getNonStopRejoinTimeoutMostRecentSample() {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.REJOIN_TIMEOUT).rate().value().longValue();
- }
-
- @Override
- public long getNonStopTimeoutMostRecentSample() {
- return cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.TIMEOUT).rate().value().longValue();
- }
-
- @Override
- public SampledCounter getNonStopSuccessSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.SUCCESS).rate());
- }
-
- @Override
- public SampledCounter getNonStopFailureSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.FAILURE).rate());
- }
-
- @Override
- public SampledCounter getNonStopRejoinTimeoutSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.REJOIN_TIMEOUT).rate());
- }
-
- @Override
- public SampledCounter getNonStopTimeoutSample() {
- return new SampledRateCounterProxy(cache.getStatistics().getExtended().nonstop().component(NonStopOperationOutcomes.TIMEOUT).rate());
- }
-
- @Override
- public long getNonStopSuccessRate() {
- return getNonStopSuccessMostRecentSample();
- }
-
- @Override
- public long getNonStopFailureRate() {
- return getNonStopFailureMostRecentSample();
- }
-
- @Override
- public long getNonStopRejoinTimeoutRate() {
- return getNonStopRejoinTimeoutMostRecentSample();
- }
-
- @Override
- public long getNonStopTimeoutRate() {
- return getNonStopTimeoutMostRecentSample();
- }
-
- @Override
- public SampledCounter getReplaceOneArgSuccessSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().replaceOneArg().component(
- CacheOperationOutcomes.ReplaceOneArgOutcome.SUCCESS).rate());
- }
-
- @Override
- public SampledCounter getReplaceOneArgMissSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().replaceOneArg().component(
- CacheOperationOutcomes.ReplaceOneArgOutcome.FAILURE).rate());
- }
-
- @Override
- public SampledCounter getReplaceTwoArgSuccessSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().replaceTwoArg().component(
- CacheOperationOutcomes.ReplaceTwoArgOutcome.SUCCESS).rate());
- }
-
- @Override
- public SampledCounter getReplaceTwoArgMissSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().replaceTwoArg().component(
- CacheOperationOutcomes.ReplaceTwoArgOutcome.FAILURE).rate());
- }
-
- @Override
- public SampledCounter getPutIfAbsentSuccessSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().putIfAbsent().component(
- CacheOperationOutcomes.PutIfAbsentOutcome.SUCCESS).rate());
- }
-
- @Override
- public SampledCounter getPutIfAbsentMissSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().putIfAbsent().component(
- CacheOperationOutcomes.PutIfAbsentOutcome.FAILURE).rate());
- }
-
- @Override
- public SampledCounter getRemoveElementSuccessSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().removeElement().component(
- CacheOperationOutcomes.RemoveElementOutcome.SUCCESS).rate());
- }
-
- @Override
- public SampledCounter getRemoveElementMissSample() {
- return new SampledCounterProxy(cache.getStatistics().getExtended().removeElement().component(
- CacheOperationOutcomes.RemoveElementOutcome.FAILURE).rate());
- }
-
- @Override
- public int getNonstopTimeoutRatio() {
- return (int) (cache.getStatistics().getExtended().nonstopTimeoutRatio().value().doubleValue() * ONE_HUNDRED);
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/package.html
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/package.html (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/management/sampled/package.html (revision 0)
@@ -1,8 +0,0 @@
-
-
-
-
-This package contains classes related to MBeans with Sampled Statistics.
-
-
-
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/SearchAttribute.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/SearchAttribute.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/config/SearchAttribute.java (revision 0)
@@ -1,333 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.config;
-
-import java.util.Properties;
-import java.util.Set;
-
-import net.sf.ehcache.config.generator.model.NodeElement;
-import net.sf.ehcache.config.generator.model.SimpleNodeAttribute;
-import net.sf.ehcache.config.generator.model.SimpleNodeElement;
-import net.sf.ehcache.search.attribute.AttributeExtractor;
-import net.sf.ehcache.search.attribute.AttributeType;
-import net.sf.ehcache.search.attribute.JavaBeanAttributeExtractor;
-import net.sf.ehcache.search.attribute.ReflectionAttributeExtractor;
-import net.sf.ehcache.util.ClassLoaderUtil;
-import net.sf.ehcache.util.PropertyUtil;
-
-/**
- * A cache search attribute. Search attributes must have a name and optionally an expression or class set (if neither is set then this
- * implies java bean style)
- *
- * @author teck
- */
-public class SearchAttribute {
-
- private static final Class UNRESOLVED = UnresolvedType.class;
-
- private String name;
- private String className;
- private String expression;
- private String properties;
- private String propertySeparator;
- private String typeName;
- private Class type;
-
- /**
- * Set the attribute name
- *
- * @param name
- */
- public void setName(String name) {
- this.name = name;
- }
-
- /**
- * Set the extractor class for this attribute. This class must be available at runtime and must implement {@link AttributeExtractor}
- *
- * @param className
- */
- public void setClass(String className) {
- if (expression != null) {
- throw new InvalidConfigurationException("Cannot set both class and expression for a search attribute");
- }
- this.className = className;
- }
-
- /**
- * Set the attribute expression. See {@link ReflectionAttributeExtractor} for more information
- *
- * @param expression
- */
- public void setExpression(String expression) {
- if (className != null) {
- throw new InvalidConfigurationException("Cannot set both class and expression for a search attribute");
- }
- this.expression = expression;
- }
-
- /**
- * Set optional attribute type
- * @param type
- */
- public void setType(String type) {
- this.type = UNRESOLVED;
- this.typeName = type;
- }
-
- /**
- * Set optional attribute type
- * @param type
- */
- public void setType(Class type) {
- this.typeName = validateType(type);
- this.type = type;
- }
-
- /**
- * Get the extractor class name
- */
- public String getClassName() {
- return className;
- }
-
- /**
- * Get the attribute expression
- */
- public String getExpression() {
- return expression;
- }
-
- /**
- * Get the attribute name
- */
- public String getName() {
- return name;
- }
-
- /**
- * @return String representation of attribute type
- */
- public String getTypeName() {
- return typeName;
- }
-
-
- /**
- * Get actual attribute type
- * @return
- */
- Class getType(ClassLoader loader) {
- if (type == UNRESOLVED) {
- type = validateType(this.typeName, loader);
- }
-
-
- return type;
- }
-
- /**
- * Construct the extractor for this attribute configuration
- */
- public AttributeExtractor constructExtractor(ClassLoader loader) {
- if (name == null) {
- throw new InvalidConfigurationException("search attribute has no name");
- }
-
- if (expression != null) {
- return new ReflectionAttributeExtractor(expression);
- } else if (className != null) {
- if (properties != null) {
- return (AttributeExtractor) ClassLoaderUtil.createNewInstance(loader, className, new Class[] {Properties.class},
- new Object[] {PropertyUtil.parseProperties(properties, propertySeparator)});
- } else {
- return (AttributeExtractor) ClassLoaderUtil.createNewInstance(loader, className);
- }
- } else {
- return new JavaBeanAttributeExtractor(name);
- }
- }
-
- /**
- * Set the attribute name
- *
- * @param name
- * @return this
- */
- public SearchAttribute name(String name) {
- setName(name);
- return this;
- }
-
- /**
- * Set the attribute extractor class name
- *
- * @param className
- * attribute extractor class
- * @return this
- */
- public SearchAttribute className(String className) {
- setClass(className);
- return this;
- }
-
- /**
- * Set the attribute expression
- *
- * @param expression
- * attribute expression
- * @return this
- */
- public SearchAttribute expression(String expression) {
- setExpression(expression);
- return this;
- }
-
- /**
- * Set optional attribute type
- * @param type
- * @return this
- */
- public SearchAttribute type(String type) {
- setType(type);
- return this;
- }
-
- /**
- * Set optional attribute type
- * @param type
- * @return this
- */
- public SearchAttribute type(Class type) {
- setType(type);
- return this;
- }
-
- /**
- * Set the extractor properties
- *
- * @param props
- */
- public void setProperties(String props) {
- this.properties = props;
- }
-
- /**
- * Set the extractor properties separator
- *
- * @param sep
- */
- public void setPropertySeparator(String sep) {
- this.propertySeparator = sep;
- }
-
- /**
- * Set the extractor properties separator
- *
- * @param sep
- * @return this
- */
- public SearchAttribute propertySeparator(String sep) {
- setPropertySeparator(sep);
- return this;
- }
-
- /**
- * Set the extractor properties
- *
- * @param props
- * @return this
- */
- public SearchAttribute properties(String props) {
- setProperties(props);
- return this;
- }
-
- /**
- * Create a generated config element node for this search attribute definition
- *
- * @param parent the enclosing parent config element
- * @return generated config element for this search attribute
- */
- public NodeElement asConfigElement(NodeElement parent) {
- SimpleNodeElement rv = new SimpleNodeElement(parent, "searchAttribute");
-
- rv.addAttribute(new SimpleNodeAttribute("name", name));
-
- if (expression != null) {
- rv.addAttribute(new SimpleNodeAttribute("expression", expression));
- } else if (className != null) {
- rv.addAttribute(new SimpleNodeAttribute("class", className));
- if (properties != null) {
- rv.addAttribute(new SimpleNodeAttribute("properties", properties));
- }
- if (propertySeparator != null) {
- rv.addAttribute(new SimpleNodeAttribute("propertySeparator", propertySeparator));
- }
- }
- if (typeName != null) {
- rv.addAttribute(new SimpleNodeAttribute("type", typeName));
- }
-
- return rv;
- }
-
- private Class validateType(String attrType, ClassLoader loader) {
- Class realType = null;
- for (Class c : AttributeType.getSupportedJavaTypes()) {
- if (attrType.equals(c.getName())) {
- realType = c;
- break;
- }
- String[] groups = c.getName().split("\\.");
- if (attrType.equals(groups[groups.length - 1])) {
- if (realType != null) { throw new InvalidConfigurationException("Ambiguous attribute type " + attrType); }
- realType = c;
- }
- }
-
- if (realType == null) {
- // Attempt to load then validate that it's enum
- try {
- realType = loader.loadClass(attrType);
- } catch (ClassNotFoundException e) {
- throw new InvalidConfigurationException(String.format("Unable to load class specified as type of attribute %s: %s",
- name, e.getMessage()));
- }
- if (!realType.isEnum()) {
- throw new InvalidConfigurationException(String.format("Unsupported attribute type specified %s for search attribute %s",
- attrType, name));
- }
- }
-
- return realType;
- }
-
- private String validateType(Class attrType) {
- Set> knownTypes = AttributeType.getSupportedJavaTypes();
- String t = attrType.getName();
- if (!knownTypes.contains(attrType) && !attrType.isEnum()) {
- throw new InvalidConfigurationException(String.format("Unsupported attribute type specified %s for search attribute %s", t, name));
- }
- return t;
- }
-
- private static class UnresolvedType {
- //
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/search/QueryExamplesTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/search/QueryExamplesTest.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/java/net/sf/ehcache/search/QueryExamplesTest.java (revision 0)
@@ -1,268 +0,0 @@
-package net.sf.ehcache.search;
-
-import static net.sf.ehcache.search.Query.KEY;
-import static org.junit.Assert.assertEquals;
-
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.config.SearchAttribute;
-
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import bsh.EvalError;
-import bsh.Interpreter;
-
-/**
- * This class was used to develop the API and now that the code has been written it has been made an
- * executable test.
- *
- * @author teck
- * @author Greg Luck
- */
-public class QueryExamplesTest {
-
- private static final Logger LOG = LoggerFactory.getLogger(QueryExamplesTest.class);
-
- private CacheManager cacheManager;
- private Ehcache cache;
-
- @Before
- public void before() {
- cacheManager = new CacheManager(getClass().getResource("/ehcache-search.xml"));
- cache = cacheManager.getCache("cache1");
- SearchTestUtil.populateData(cache);
- }
-
- @After
- public void after() {
- cacheManager.shutdown();
- }
-
- @Test
- public void testExamples() {
- examples();
- }
-
- void examples() throws SearchException {
-
- Attribute age = cache.getSearchAttribute("age");
- Attribute gender = cache.getSearchAttribute("gender");
- Attribute name = cache.getSearchAttribute("name");
-
- Query query;
- Results results;
-
- // include all keys in the cache
- query = cache.createQuery().includeKeys().end();
- results = query.execute();
- for (Result result : results.all()) {
- LOG.info("" + result.getKey());
- }
- results.discard(); // not required but will speed resource freeing
-
- // access results in a "paged" manner
- query = cache.createQuery().includeKeys().end();
- results = query.execute();
-
- int pageSize = 100;
- int index = 0;
- List page;
- do {
- page = results.range(index, pageSize);
-
- for (Result result : page) {
- LOG.info("" + result.getKey());
- }
-
- index += page.size();
- } while (page.size() == pageSize);
-
- // select age from the cache
- query = cache.createQuery().includeAttribute(age).end();
- results = query.execute();
- for (Result result : results.all()) {
- LOG.info("" + result.getAttribute(age));
- }
-
- // select age, gender from the cache
- query = cache.createQuery().includeAttribute(age, gender).end();
- results = query.execute();
- for (Result result : results.all()) {
- LOG.info("" + result.getAttribute(age));
- // slf4j weirdness
- Object object = result.getAttribute(gender);
- LOG.info("" + object);
- }
-
- // select max(age) -- named indexed attribute "age"
- Query sumQuery = cache.createQuery().includeAggregator(age.sum()).end();
- results = sumQuery.execute();
- for (Result result : results.all()) {
- Long sumResult = (Long) result.getAggregatorResults().get(0);
- LOG.info("Sum is: " + sumResult);
- }
-
- // select keys with criteria age == 12 AND gender = "timmy"
- query = cache.createQuery().includeKeys().addCriteria(age.eq(12).and(gender.eq("timmy"))).end();
-
- // same as above (but without AND, uses two add() -- multiple
- // criteria implies AND)
- query = cache.createQuery().includeKeys().addCriteria(age.eq(12)).addCriteria(gender.eq("timmy")).end();
-
- // slightly more complicated expression and multiple ordering
- // age = 13 OR (age == 12 AND gender = "timmy") order by age asc, gender desc limit 10
- query = cache.createQuery().includeKeys().addCriteria(age.eq(13).or(age.eq(12).and(gender.eq("timmy"))))
- .addOrderBy(age, Direction.ASCENDING).addOrderBy(gender, Direction.DESCENDING).maxResults(10).end();
- }
-
- @Test
- public void testNoIncludeSpecified() {
- Attribute age = cache.getSearchAttribute("age");
- Query query = cache.createQuery().addCriteria(age.eq(35));
- try {
- query.execute();
- Assert.fail();
- } catch (SearchException e) {
- System.err.println("Expected " + e.toString());
- }
- }
-
- @Test
- public void testUseShorthandKeyAttribute() {
- Results results = cache.createQuery().addCriteria(KEY.eq(1)).includeKeys().execute();
- assertEquals(1, results.size());
- assertEquals(1, results.all().iterator().next().getKey());
- }
-
- @Test
- public void testUseShorthandValueAttribute() {
- Object tmpKey = new Object();
- Double value = Math.PI * System.nanoTime();
- cache.put(new Element(tmpKey, value));
-
- try {
- Results results = cache.createQuery().addCriteria(Query.VALUE.eq(value)).includeKeys().execute();
- assertEquals(1, results.size());
- assertEquals(tmpKey, results.all().iterator().next().getKey());
- } finally {
- cache.remove(tmpKey);
- }
- }
-
- @Test
- public void testIncludeKeysSpecified() {
- Attribute age = cache.getSearchAttribute("age");
- Results results = cache.createQuery().addCriteria(age.eq(35)).includeKeys().execute();
- assertEquals(2, results.size());
- for (Result result : results.all()) {
- LOG.info("" + cache.get(result.getKey()));
- }
- }
-
- @Test
- public void testSearchKeys() {
- Results results = cache.createQuery().addCriteria(Query.KEY.in(Arrays.asList(1, 3))).includeKeys().execute();
- assertEquals(2, results.size());
- for (Result result : results.all()) {
- LOG.info("" + cache.get(result.getKey()));
- }
- }
-
- /**
- * Show how to execute a query in beanshell
- */
- @Test
- public void testBasicBeanShellQuery() throws EvalError {
-
- Interpreter i = new Interpreter();
- Query query = cache.createQuery().includeKeys();
-
- Attribute age = cache.getSearchAttribute("age");
-
- i.set("query", query);
- Results results = null;
- i.set("results", results);
- i.set("age", age);
-
- i.eval("results = query.addCriteria(age.eq(35)).execute()");
- results = (Results) i.get("results");
- assertEquals(2, results.size());
- for (Result result : results.all()) {
- LOG.info("" + result.getKey());
- }
- }
-
- /**
- * Show how to execute a query in beanshell
- */
- @Test
- public void testInjectedStringBeanShellQuery() throws EvalError {
-
- Interpreter i = new Interpreter();
- Query query = cache.createQuery().includeKeys();
-
- Attribute age = cache.getSearchAttribute("age");
-
- i.set("query", query);
- Results results = null;
- i.set("results", results);
- i.set("age", age);
-
- String userDefinedQuery = "age.eq(35)";
- String fullQueryString = "results = query.addCriteria(" + userDefinedQuery + ").execute()";
-
- i.eval(fullQueryString);
- results = (Results) i.get("results");
- assertEquals(2, results.size());
- for (Result result : results.all()) {
- LOG.info("" + result.getKey());
- }
- }
-
- /**
- * Show how to execute a query in beanshell using autodiscovered attributes
- */
- @Test
- public void testAutoDiscoveredAttributesBeanShellQuery() throws EvalError {
-
- Interpreter i = new Interpreter();
-
- // Auto discover the search attributes and add them to the interpreter's context
- Map attributes = cache.getCacheConfiguration().getSearchAttributes();
- for (Map.Entry entry : attributes.entrySet()) {
- i.set(entry.getKey(), cache.getSearchAttribute(entry.getKey()));
- LOG.info("Setting attribute " + entry.getKey());
- }
-
- // Define the query and results. Add things which would be set in the GUI i.e. includeKeys and add to context
- Query query = cache.createQuery().includeKeys();
- Results results = null;
- i.set("query", query);
- i.set("results", results);
-
- // This comes from the freeform text field
- String userDefinedQuery = "age.eq(35)";
-
- // Add the stuff on that we need
- String fullQueryString = "results = query.addCriteria(" + userDefinedQuery + ").execute()";
-
- i.eval(fullQueryString);
- results = (Results) i.get("results");
- assertEquals(2, results.size());
- for (Result result : results.all()) {
- LOG.info("" + result.getKey());
- }
-
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/ehcache/tests/ClientArrayValues1.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/ehcache/tests/ClientArrayValues1.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/system-tests/src/test/java/org/terracotta/ehcache/tests/ClientArrayValues1.java (revision 0)
@@ -1,27 +0,0 @@
-package org.terracotta.ehcache.tests;
-
-import net.sf.ehcache.Cache;
-import net.sf.ehcache.Element;
-
-import org.terracotta.toolkit.Toolkit;
-
-public class ClientArrayValues1 extends ClientBase {
-
- public ClientArrayValues1(String[] args) {
- super("test", args);
- }
-
- public static void main(String[] args) {
- new ClientArrayValues1(args).run();
- }
-
- @Override
- protected void runTest(Cache cache, Toolkit toolkit) throws Throwable {
- cache.put(new Element("key", new String[] { "a", "b", "c" }));
-// } else {
-// Element elem = cache.get("key");
-// assertNotNull()
-// String[] value = elem.getValue();
-// }
- }
-}
Index: rctags/ehcache-2.10.9.1.15/system-tests/src/test/resources/net/sf/ehcache/osgi/ehcache-scheduled-refresh.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/system-tests/src/test/resources/net/sf/ehcache/osgi/ehcache-scheduled-refresh.xml (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/system-tests/src/test/resources/net/sf/ehcache/osgi/ehcache-scheduled-refresh.xml (revision 0)
@@ -1,20 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-no-update.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-no-update.xml (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/test/resources/ehcache-no-update.xml (revision 0)
@@ -1,13 +0,0 @@
-
-
-
-
-
-
-
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/nonstop/concurrency/LockOperationTimedOutNonstopException.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/nonstop/concurrency/LockOperationTimedOutNonstopException.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/constructs/nonstop/concurrency/LockOperationTimedOutNonstopException.java (revision 0)
@@ -1,38 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.constructs.nonstop.concurrency;
-
-import net.sf.ehcache.constructs.nonstop.NonStopCacheException;
-
-/**
- * Special class of {@link NonStopCacheException} which is thrown on timeout of lock operations
- *
- * @author Abhishek Sanoujam
- *
- */
-public class LockOperationTimedOutNonstopException extends NonStopCacheException {
-
- /**
- * public constructor
- *
- * @param message
- */
- public LockOperationTimedOutNonstopException(String message) {
- super(message);
- }
-
-}
Index: rctags/ehcache-2.10.9.1.15/management-ehcache-v2/src/main/java/net/sf/ehcache/management/resource/CacheStatisticSampleEntityV2.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/management-ehcache-v2/src/main/java/net/sf/ehcache/management/resource/CacheStatisticSampleEntityV2.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/management-ehcache-v2/src/main/java/net/sf/ehcache/management/resource/CacheStatisticSampleEntityV2.java (revision 0)
@@ -1,33 +0,0 @@
-/*
- * All content copyright (c) 2003-2012 Terracotta, Inc., except as may otherwise be noted in a separate copyright
- * notice. All rights reserved.
- */
-package net.sf.ehcache.management.resource;
-
-import java.util.Map;
-
-/**
- * @author brandony
- */
-public class CacheStatisticSampleEntityV2 extends AbstractCacheEntityV2{
-
- private String statName;
-
- private Map statValueByTimeMillis;
-
- public String getStatName() {
- return statName;
- }
-
- public void setStatName(String statName) {
- this.statName = statName;
- }
-
- public Map getStatValueByTimeMillis() {
- return statValueByTimeMillis;
- }
-
- public void setStatValueByTimeMillis(Map statValueByTimeMillis) {
- this.statValueByTimeMillis = statValueByTimeMillis;
- }
-}
Index: rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/LruMemoryStore.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/LruMemoryStore.java (revision 11494)
+++ rctags/ehcache-2.10.9.1.15/ehcache-core/src/main/java/net/sf/ehcache/store/LruMemoryStore.java (revision 0)
@@ -1,719 +0,0 @@
-/**
- * Copyright Terracotta, Inc.
- *
- * Licensed 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 net.sf.ehcache.store;
-
-import net.sf.ehcache.CacheEntry;
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.Ehcache;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.Status;
-import net.sf.ehcache.config.CacheConfiguration;
-import net.sf.ehcache.config.PinningConfiguration;
-import net.sf.ehcache.config.SizeOfPolicyConfiguration;
-import net.sf.ehcache.pool.Size;
-import net.sf.ehcache.pool.SizeOfEngine;
-import net.sf.ehcache.pool.SizeOfEngineLoader;
-import net.sf.ehcache.writer.CacheWriterManager;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import net.sf.ehcache.CacheOperationOutcomes.EvictionOutcome;
-import net.sf.ehcache.statistics.StatisticBuilder;
-import net.sf.ehcache.store.StoreOperationOutcomes.GetOutcome;
-import org.terracotta.statistics.Statistic;
-import org.terracotta.statistics.observer.OperationObserver;
-
-import net.sf.ehcache.store.StoreOperationOutcomes.PutOutcome;
-import net.sf.ehcache.store.StoreOperationOutcomes.RemoveOutcome;
-
-/**
- * An implementation of a LruMemoryStore.
- *
- * This uses {@link java.util.LinkedHashMap} as its backing map. It uses the {@link java.util.LinkedHashMap} LRU
- * feature. LRU for this implementation means least recently accessed.
- *
- * @author Greg Luck
- * @version $Id$
- */
-public class LruMemoryStore extends AbstractStore {
-
- private static final Logger LOG = LoggerFactory.getLogger(LruMemoryStore.class.getName());
-
- /**
- * The cache this store is associated with.
- */
- protected Ehcache cache;
-
- /**
- * Map where items are stored by key.
- */
- protected Map map;
-
- /**
- * The DiskStore associated with this MemoryStore.
- */
- protected final Store diskStore;
-
- /**
- * status.
- */
- protected Status status;
-
- /**
- * The maximum size of the store (0 == no limit)
- */
- protected long maximumSize;
-
- private final boolean cachePinned;
- private final boolean elementPinningEnabled;
-
- private final CopyStrategyHandler copyStrategyHandler;
-
-
- private final OperationObserver getObserver = StatisticBuilder.operation(GetOutcome.class).named("get").of(this)
- .tag("local-heap").build();
- private final OperationObserver