- * 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.
- * 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
- * An entity representing a cache resource from the management API.
- *
- * Note that Ehcache API also allows the CacheLoader to be set programmatically.
- * @author Greg Luck
- * @version $Id: CacheLoaderFactory.java 10789 2018-04-26 02:08:13Z adahanne $
- */
-public abstract class CacheLoaderFactory {
-
- /**
- * Creates a CacheLoader using the Ehcache configuration mechanism at the time the associated cache
- * is created.
- * @param cache a reference to the owning cache, this cache isn't yet initialized nor wired to a particular CacheManager
- * @param properties implementation specific properties configured as delimiter
- * separated name value pairs in ehcache.xml
- * @return a constructed CacheLoader
- */
- public abstract CacheLoader createCacheLoader(Ehcache cache, Properties properties);
-
-}
Index: rctags/ehcache-2.10.9.1.33/distribution/colorcache/src/main/webapp/WEB-INF/web.xml
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/distribution/colorcache/src/main/webapp/WEB-INF/web.xml (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/distribution/colorcache/src/main/webapp/WEB-INF/web.xml (revision 0)
@@ -1,16 +0,0 @@
-
-
-
-
- * The {@link net.sf.ehcache.config.ConfigurationFactory} and clients can create these.
- *
- * A client can specify their own settings here and pass the {@link Ehcache} object
- * into {@link net.sf.ehcache.CacheManager#addCache} to specify parameters other than the defaults.
- *
- * Only the CacheManager can initialise them.
- *
- * @param cache An ehcache
- * @throws net.sf.ehcache.CacheException
- */
- public Cache(Ehcache cache) throws CacheException {
- this.cache = cache;
- objectName = createObjectName(cache.getCacheManager().toString(), cache.getName());
- }
-
- /**
- * Creates an object name using the scheme "net.sf.ehcache:type=Cache,CacheManager=
- * 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
- * The last access time in {@link net.sf.ehcache.Element} is updated.
- *
- * @param key the cache key
- * @return the element, or null if there was no match for the key
- */
- public final synchronized Element get(Object key) {
- getObserver.begin();
- Element e = (Element) map.get(key);
- if (e == null) {
- getObserver.end(GetOutcome.MISS);
- return null;
- } else {
- getObserver.end(GetOutcome.HIT);
- return e;
- }
- }
-
- /**
- * Gets an item from the cache, without updating statistics.
- *
- * @param key the cache key
- * @return the element, or null if there was no match for the key
- */
- public final synchronized Element getQuiet(Object key) {
- return (Element) map.get(key);
- }
-
- /**
- * Removes an Element from the store.
- *
- * @param key the key of the Element, usually a String
- * @return the Element if one was found, else null
- */
- public final Element remove(Object key) {
- return removeInternal(key, null);
- }
-
- /**
- * {@inheritDoc}
- */
- public final Element removeWithWriter(Object key, CacheWriterManager writerManager) throws CacheException {
- return removeInternal(key, writerManager);
- }
-
- private synchronized Element removeInternal(Object key, CacheWriterManager writerManager) throws CacheException {
- // remove single item.
- removeObserver.begin();
- Element element = (Element) map.remove(key);
- if (writerManager != null) {
- writerManager.remove(new CacheEntry(key, element));
- }
- removeObserver.end(RemoveOutcome.SUCCESS);
- if (element != null) {
- return element;
- } else {
- return null;
- }
- }
-
- /**
- * Remove all of the elements from the store.
- */
- public final synchronized void removeAll() throws CacheException {
- clear();
- }
-
- /**
- * Clears any data structures and places it back to its state when it was first created.
- */
- protected final void clear() {
- map.clear();
- }
-
- /**
- * Prepares for shutdown.
- */
- public final synchronized void dispose() {
- if (status.equals(Status.STATUS_SHUTDOWN)) {
- return;
- }
- status = Status.STATUS_SHUTDOWN;
- flush();
-
- //release reference to cache
- cache = null;
- }
-
-
- /**
- * Flush to disk only if the cache is diskPersistent.
- */
- public final void flush() {
- if (cache.getCacheConfiguration().isDiskPersistent()) {
- if (LOG.isDebugEnabled()) {
- LOG.debug(cache.getName() + " is persistent. Spooling " + map.size() + " elements to the disk store.");
- }
- spoolAllToDisk();
- }
-
- //should be emptied if clearOnFlush is true
- if (cache.getCacheConfiguration().isClearOnFlush()) {
- clear();
- }
- }
-
-
- /**
- * Spools all elements to disk, in preparation for shutdown.
- *
- * This revised implementation is a little slower but avoids using increased memory during the method.
- */
- protected final void spoolAllToDisk() {
- boolean clearOnFlush = cache.getCacheConfiguration().isClearOnFlush();
- for (Object key : getKeys()) {
- Element element = (Element) map.get(key);
- if (element != null) {
- if (!element.isSerializable()) {
- if (LOG.isWarnEnabled()) {
- LOG.warn("Object with key " + element.getObjectKey()
- + " is not Serializable and is not being overflowed to disk.");
- }
- } else {
- spoolToDisk(element);
- //Don't notify listeners. They are not being removed from the cache, only a store
- //Leave it in the memory store for performance if do not want to clear on flush
- if (clearOnFlush) {
- remove(key);
- }
- }
- }
- }
- }
-
- /**
- * Puts the element in the DiskStore.
- * Should only be called if isOverflowToDisk is true
- *
- * Relies on being called from a synchronized method
- *
- * @param element The Element
- */
- protected void spoolToDisk(Element element) {
- diskStore.put(element);
- if (LOG.isDebugEnabled()) {
- LOG.debug(cache.getName() + "Cache: spool to disk done for: " + element.getObjectKey());
- }
- }
-
- /**
- * Gets the status of the MemoryStore.
- */
- public final Status getStatus() {
- return status;
- }
-
- /**
- * Gets an Array of the keys for all elements in the memory cache.
- *
- * Does not check for expired entries
- *
- * @return An Object[]
- */
- public final synchronized List getKeys() {
- return new ArrayList(map.keySet());
- }
-
- /**
- * Returns the current cache size.
- *
- * @return The size value
- */
- public final int getSize() {
- return map.size();
- }
-
- /**
- * Returns nothing since a disk store isn't clustered
- *
- * @return returns 0
- */
- public final int getTerracottaClusteredSize() {
- return 0;
- }
-
-
- /**
- * An unsynchronized check to see if a key is in the Store. No check is made to see if the Element is expired.
- *
- * @param key The Element key
- * @return true if found. If this method return false, it means that an Element with the given key is definitely not in the MemoryStore.
- * If it returns true, there is an Element there. An attempt to get it may return null if the Element has expired.
- */
- public final boolean containsKey(Object key) {
- return map.containsKey(key);
- }
-
-
- /**
- * Measures the size of the memory store by using the sizeof engine.
- *
- * Warning: This method can be very expensive to run. Allow approximately 1 second
- * per 1MB of entries. Running this method could create liveness problems
- * because the object lock is held for a long period
- *
- * @return the size, in bytes
- */
- public final synchronized long getSizeInBytes() throws CacheException {
- SizeOfEngine defaultSizeOfEngine = SizeOfEngineLoader.newSizeOfEngine(
- SizeOfPolicyConfiguration.resolveMaxDepth(cache),
- SizeOfPolicyConfiguration.resolveBehavior(cache)
- .equals(SizeOfPolicyConfiguration.MaxDepthExceededBehavior.ABORT),
- true
- );
- long sizeInBytes = 0;
- for (Object o : map.entrySet()) {
- Map.Entry entry = (Map.Entry)o;
- Element element = (Element) entry.getValue();
- if (element != null) {
- Size size = defaultSizeOfEngine.sizeOf(entry.getKey(), element, null);
- sizeInBytes += size.getCalculated();
- }
- }
- return sizeInBytes;
- }
-
-
- /**
- * Evict the
- * Evict means that the
- * This is a default implementation which does nothing. Expiry on demand is only
- * implemented for disk stores.
- */
- public void expireElements() {
- //empty implementation
- }
-
- /**
- * Memory stores are never backed up and always return false
- */
- public boolean bufferFull() {
- return false;
- }
-
-
- /**
- * Package local access to the map for testing
- */
- Map getBackingMap() {
- return map;
- }
-
- /**
- * {@inheritDoc}
- */
- public Object getMBean() {
- return null;
- }
-
- /**
- * An extension of LinkedHashMap which overrides {@link #removeEldestEntry}
- * to persist cache entries to the auxiliary cache before they are removed.
- *
- * This implementation also provides LRU by access order.
- */
- public final class SpoolingLinkedHashMap extends java.util.LinkedHashMap {
- private static final int INITIAL_CAPACITY = 100;
- private static final float GROWTH_FACTOR = .75F;
-
- /**
- * Default constructor.
- * Will create an initial capacity of 100, a loading of .75 and
- * LRU by access order.
- */
- public SpoolingLinkedHashMap() {
- super(INITIAL_CAPACITY, GROWTH_FACTOR, true);
- }
-
- /**
- * Returns true if this map should remove its eldest entry.
- * This method is invoked by put and putAll after
- * inserting a new entry into the map. It provides the implementer
- * with the opportunity to remove the eldest entry each time a new one
- * is added. This is useful if the map represents a cache: it allows
- * the map to reduce memory consumption by deleting stale entries.
- *
- * Will return true if:
- *
- * 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
- * Throws {@link RejoinCacheException}
- */
- @Override
- public Map
- * 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
- * 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
- * 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
- * Throws {@link RejoinCacheException}
- */
- @Override
- public
- *
- *
- * @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(CallableError occurs.
- *
- * @param ehcache the cache in which the Exception occurred
- * @param key the key used in the operation, or null if the operation does not use a key
- * @param exception the exception caught
- */
- public void onException(Ehcache ehcache, Object key, Exception exception) {
-
- HandledException handledException = new HandledException(ehcache, key, exception);
- HANDLED_EXCEPTIONS.add(handledException);
- }
-
- /**
- * Clear counter
- */
- public static void resetCounters() {
- HANDLED_EXCEPTIONS.clear();
- }
-
- /**
- * A value object for each exception handled
- */
- public static class HandledException {
- private final Ehcache ehcache;
- private final Object key;
- private final Exception exception;
-
- /**
- * Constructor
- *
- * @param ehcache
- * @param key
- * @param exception
- */
- public HandledException(Ehcache ehcache, Object key, Exception exception) {
- this.ehcache = ehcache;
- this.key = key;
- this.exception = exception;
- }
-
- /**
- * @return
- */
- public Object getKey() {
- return key;
- }
-
- /**
- * @return underlying exception
- */
- public Exception getException() {
- return exception;
- }
- }
-
-
-}
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/event/CacheEventListenerFactory.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/event/CacheEventListenerFactory.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/event/CacheEventListenerFactory.java (revision 0)
@@ -1,39 +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;
-
-/**
- * An abstract factory for creating listeners. Implementers should provide their own
- * concrete factory extending this factory. It can then be configured in ehcache.xml.
- *
- * @author Greg Luck
- * @version $Id: CacheEventListenerFactory.java 5594 2012-05-07 16:04:31Z cdennis $
- */
-public abstract class 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 abstract CacheEventListener createCacheEventListener(Properties properties);
-
-}
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/util/ClassLoaderUtil.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/util/ClassLoaderUtil.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/util/ClassLoaderUtil.java (revision 0)
@@ -1,98 +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;
-
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-
-import net.sf.ehcache.CacheException;
-
-/**
- * Keeps all classloading in ehcache consistent.
- *
- * @author Greg Luck
- * @version $Id: ClassLoaderUtil.java 8764 2014-02-18 23:08:43Z teck $
- */
-public final class ClassLoaderUtil {
-
- /**
- * Utility class.
- */
- private ClassLoaderUtil() {
- //noop
- }
-
- /**
- * Creates a new class instance with the given loader. Logs errors along the way.
- *
- * @param loader the classloader to load the class
- * @param className a fully qualified class name
- * @return the newly created instance
- * @throws CacheException if instance cannot be created due to a missing class or exception
- */
- public static Object createNewInstance(ClassLoader loader, String className) throws CacheException {
- return createNewInstance(loader, className, new Class[0], new Object[0]);
- }
-
- /**
- * Creates a new class instance and passes args to the constructor call. Logs errors along the way.
- *
- * @param loader the classloader to load the class
- * @param className a fully qualified class name
- * @param argTypes Types for constructor argument parameters
- * @param args Values for constructor argument parameters
- * @return the newly created instance
- * @throws CacheException if instance cannot be created due to a missing class or exception
- */
- public static Object createNewInstance(ClassLoader loader, String className, Class[] argTypes, Object[] args) throws CacheException {
- Class clazz;
- Object newInstance;
- try {
- clazz = loader.loadClass(className);
- } catch (ClassNotFoundException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- }
-
- try {
- Constructor constructor = clazz.getConstructor(argTypes);
- newInstance = constructor.newInstance(args);
- } catch (IllegalAccessException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- } catch (InstantiationException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- } catch (NoSuchMethodException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- } catch (SecurityException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- } catch (IllegalArgumentException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getMessage(), e);
- } catch (InvocationTargetException e) {
- throw new CacheException("Unable to load class " + className +
- ". Initial cause was " + e.getCause().getMessage(), e.getCause());
- }
- return newInstance;
- }
-
-
-
-}
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/constructs/CacheDecoratorFactoryTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/constructs/CacheDecoratorFactoryTest.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/constructs/CacheDecoratorFactoryTest.java (revision 0)
@@ -1,99 +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;
-
-import java.util.Arrays;
-import java.util.List;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
-import junit.framework.TestCase;
-import net.sf.ehcache.CacheManager;
-import net.sf.ehcache.constructs.MockDecoratorFactory.MockDecoratorFactoryCache;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.terracotta.test.categories.CheckShorts;
-
-/**
- * @author Abhishek Sanoujam
- */
-@Category(CheckShorts.class)
-public class CacheDecoratorFactoryTest extends TestCase {
-
- private static final Logger LOG = LoggerFactory.getLogger(CacheDecoratorFactoryTest.class);
-
- @Test
- public void testCacheDecoratorFactory() {
- CacheManager cacheManager = new CacheManager(getClass().getResourceAsStream("/ehcache-decorator-test.xml"));
- ListCacheEventListener
- *
- * @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.33/ehcache-core/src/main/java/net/sf/ehcache/config/package.html
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/config/package.html (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/config/package.html (revision 0)
@@ -1,7 +0,0 @@
-
-
-
-
- This package contains the cache configuration code.
-
-
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/util/counter/CounterImpl.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/main/java/net/sf/ehcache/util/counter/CounterImpl.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/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.33/ehcache-search-parser/src/test/resources/unparseable.txt
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-search-parser/src/test/resources/unparseable.txt (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-search-parser/src/test/resources/unparseable.txt (revision 0)
@@ -1,58 +0,0 @@
-// things which should not be parsed.
-
-// simplest
-slect * from foo
-
-// really simple from foo where clause
-select foo from foo where name = foo
-select * from foo where name' != foo
-select * from foo where (name < foo
-select key from foo where name & foo
-
-// add some aggregators to the target list
-select key,summer(foo) from foo
-
-// ok, some casting. note that no parsing is done in quoted string which is being cast.
-select * from foo where age = bool 'true'
-select * from foo where age = (string)10
-select * from foo where age = (long)'11'
-
-// some ands
-select key,value from foo where (age > 100 and zip=20144
-select key,value from foo where (age > 100 and zip=20144 and time)
-select key,value from foo where ((age > 100 and zip=20144 and time > 10 and fun>100)
-
-// some ors
-select key,value from foo where (age > 100 or zip=20144
-select key,value from foo where (age > 100 or zip=20144 or > 10)
-select key,value from foo where (age > 100 or zip=20144) or time > 10 or fun>100)
-
-// ors and ands, partying together
-select key,value from foo where (age > 100 and zip=20144) or time > 10)
-select key,value from foo where ((age > 100 or zip=20144 and (time > 10 or fun>100))
-select key,value from foo where ((age > 100 or zip=20144) time > 10)
-select key,value from foo where ((age > 100 and zip'=20144) or (time > 10 and fun>100))
-
-// group by?
-select * from foo where ((age > 100 and zip=20144) or time > 10) groupby age
-select * from foo where ((age > 100 and zip=20144) or time > 10) group by
-
-// order by?
-select * from foo where ((age > 100 and zip=20144) or time > 10) orderby age
-select * from foo where ((age > 100 and zip=20144) or time > 10) order by age order by
-
-// order and group by, mixing order
-select * from foo where ((age > 100 and zip=20144) or time > 10) group age order age
-
-// limit must go on the end!
-select * from foo where ((age > 100 and zip=20144) or time > 10) order by age group by age order by zip limit 10 group by zip
-
-// some quoting chicanery
-select * from foo where foo='tom\'
-select * from foo where foo=\'tom\foo
-select * from foo where foo='tom\u04'
-
-select * from foo where name = (date)'abcde'
-select * from foo where name = (date)'12-20'
-
-select a, b from foo where bar is not not null
\ No newline at end of file
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/RecalculateSizeTest.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/RecalculateSizeTest.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/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 AtomicReferenceElement.
- * Element is:
- *
- *
- *
- * @param element the Element is spooled to the DiskStore
- * Element is removed.
- * Element to be evicted.
- */
- protected final void evict(Element element) throws CacheException {
- if (cache.getCacheConfiguration().isOverflowToDisk()) {
- if (!element.isSerializable()) {
- if (LOG.isWarnEnabled()) {
- LOG.warn(new StringBuilder("Object with key ").append(element.getObjectKey())
- .append(" is not Serializable and cannot be overflowed to disk").toString());
- }
- cache.getCacheEventNotificationService().notifyElementEvicted(copyStrategyHandler.copyElementForReadIfNeeded(element), false);
- } else {
- spoolToDisk(element);
- }
- } else {
- evictionObserver.begin();
- evictionObserver.end(EvictionOutcome.SUCCESS);
- cache.getCacheEventNotificationService().notifyElementEvicted(copyStrategyHandler.copyElementForReadIfNeeded(element), false);
- }
- }
-
- /**
- * Before eviction elements are checked.
- *
- * @param element
- */
- protected final void notifyExpiry(Element element) {
- cache.getCacheEventNotificationService().notifyElementExpiry(copyStrategyHandler.copyElementForReadIfNeeded(element), false);
- }
-
-
- /**
- * An algorithm to tell if the MemoryStore is at or beyond its carrying capacity.
- */
- protected final boolean isFull() {
- return maximumSize > 0 && map.size() > maximumSize;
- }
-
- /**
- * Expire all elsments.
- *
- *
- *
- * @param eldest The least recently inserted entry in the map, or if
- * this is an access-ordered map, the least recently accessed
- * entry. This is the entry that will be removed it this
- * method returns true. If the map was empty prior
- * to the put or putAll invocation resulting
- * in this invocation, this will be the entry that was just
- * inserted; in other words, if the map contains a single
- * entry, the eldest entry is also the newest.
- * @return true if the eldest entry should be removed
- * from the map; false if it should be retained.
- */
- @Override
- protected final boolean removeEldestEntry(Map.Entry eldest) {
- Element element = (Element) eldest.getValue();
- return element != null && removeLeastRecentlyUsedElement(element);
- }
-
- /**
- * {@inheritDoc}
- */
- @Override
- public Object put(Object key, Object value) {
- Object put = super.put(key, value);
-
- Iterator it = entrySet().iterator();
- while (isFull() && it.hasNext()) {
- Map.Entry entry = (Map.Entry) it.next();
- if (removeEldestEntry(entry)) {
- it.remove();
- }
- }
-
- return put;
- }
-
- /**
- * Relies on being called from a synchronized method
- *
- * @param element
- * @return true if the LRU element should be removed
- */
- private boolean removeLeastRecentlyUsedElement(Element element) throws CacheException {
- //check for expiry and remove before going to the trouble of spooling it
- if (element.isExpired()) {
- notifyExpiry(element);
- return true;
- }
-
- if (isFull() && !cachePinned) {
- evict(element);
- return true;
- } else {
- return false;
- }
-
- }
- }
-
-
- /**
- * @return the current eviction policy. This may not be the configured policy, if it has been
- * dynamically set.
- * @see #setEvictionPolicy(Policy)
- */
- public Policy getEvictionPolicy() {
- return new LruPolicy();
- }
-
- /**
- * Sets the eviction policy strategy. The Store will use a policy at startup. The store may allow changing
- * the eviction policy strategy dynamically. Otherwise implementations will throw an exception if this method
- * is called.
- *
- * @param policy the new policy
- */
- public void setEvictionPolicy(Policy policy) {
- throw new UnsupportedOperationException("This store is LRU only. It does not support changing the eviction" +
- " strategy.");
- }
-
- /**
- * {@inheritDoc}
- */
- public Object getInternalContext() {
- return null;
- }
-
- /**
- * {@inheritDoc}
- */
- public boolean containsKeyInMemory(Object key) {
- return containsKey(key);
- }
-
- /**
- * {@inheritDoc}
- */
- public boolean containsKeyOffHeap(Object key) {
- return false;
- }
-
- /**
- * {@inheritDoc}
- */
- public boolean containsKeyOnDisk(Object key) {
- return false;
- }
-
- /**
- * {@inheritDoc}
- */
- public Policy getInMemoryEvictionPolicy() {
- return getEvictionPolicy();
- }
-
- /**
- * {@inheritDoc}
- */
- @Statistic(name = "size", tags = "local-heap")
- public int getInMemorySize() {
- return getSize();
- }
-
- /**
- * {@inheritDoc}
- */
- @Statistic(name = "size-in-bytes", tags = "local-heap")
- public long getInMemorySizeInBytes() {
- return getSizeInBytes();
- }
-
- /**
- * {@inheritDoc}
- */
- public int getOffHeapSize() {
- return 0;
- }
-
- /**
- * {@inheritDoc}
- */
- public long getOffHeapSizeInBytes() {
- return 0;
- }
-
- /**
- * {@inheritDoc}
- */
- public int getOnDiskSize() {
- return 0;
- }
-
- /**
- * {@inheritDoc}
- */
- public long getOnDiskSizeInBytes() {
- return 0;
- }
-
- /**
- * {@inheritDoc}
- */
- public void setInMemoryEvictionPolicy(Policy policy) {
- setEvictionPolicy(policy);
- }
-
- /**
- * Unsupported in LruMemoryStore
- */
- public Element putIfAbsent(Element element) throws NullPointerException {
- throw new UnsupportedOperationException();
- }
-
- /**
- * Unsupported in LruMemoryStore
- */
- public Element removeElement(Element element, ElementValueComparator comparator) throws NullPointerException {
- throw new UnsupportedOperationException();
- }
-
- /**
- * Unsupported in LruMemoryStore
- */
- public boolean replace(Element old, Element element, ElementValueComparator comparator)
- throws NullPointerException, IllegalArgumentException {
- throw new UnsupportedOperationException();
- }
-
- /**
- * Unsupported in LruMemoryStore
- */
- public Element replace(Element element) throws NullPointerException {
- throw new UnsupportedOperationException();
- }
-}
-
Index: rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/writer/TestCacheWriterRetries.java
===================================================================
diff -u -N
--- rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/writer/TestCacheWriterRetries.java (revision 11516)
+++ rctags/ehcache-2.10.9.1.33/ehcache-core/src/test/java/net/sf/ehcache/writer/TestCacheWriterRetries.java (revision 0)
@@ -1,237 +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;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-
-import net.sf.ehcache.CacheEntry;
-import net.sf.ehcache.CacheException;
-import net.sf.ehcache.Element;
-import net.sf.ehcache.writer.writebehind.operations.SingleOperationType;
-
-public class TestCacheWriterRetries extends AbstractTestCacheWriter {
- private final int retries;
- private final List