net.dontdrinkandroot.cache.impl.disk.indexed

Class BufferedSerializableIndexedDiskCache

java.lang.Object

net.dontdrinkandroot.cache.impl.AbstractCache<K,V>

net.dontdrinkandroot.cache.impl.AbstractMapBackedCache<K,V,M>

net.dontdrinkandroot.cache.impl.AbstractMapBackedCustomTtlCache<K,V,BlockMetaData>

net.dontdrinkandroot.cache.impl.disk.indexed.AbstractIndexedDiskCache<Serializable,Serializable>

net.dontdrinkandroot.cache.impl.disk.indexed.SerializableIndexedDiskCache

net.dontdrinkandroot.cache.impl.disk.indexed.BufferedSerializableIndexedDiskCache

All Implemented Interfaces:

BufferedRecyclingCache<Serializable,Serializable>, Cache<Serializable,Serializable>, CustomTtlCache<Serializable,Serializable>, RecyclingCache<Serializable,Serializable>

public class BufferedSerializableIndexedDiskCache
extends SerializableIndexedDiskCache
implements BufferedRecyclingCache<Serializable,Serializable>

A SerializableIndexedDiskCache that buffers entries in memory on successful disk put and get operations. The size and contents of the buffer are determined by a buffer ExpungeStrategy that works the same way as a normal ExpungeStrategy but only on the buffer entries.

Author:

Philip W. Sorst

Field Summary

Fields inherited from class net.dontdrinkandroot.cache.impl.disk.indexed.AbstractIndexedDiskCache

dataFile, dataFileLock, indexFile, indexFileLock, lockFile, queueSizeWarningLimit

Fields inherited from interface net.dontdrinkandroot.cache.Cache

UNLIMITED_IDLE_TIME

Constructor Summary

Constructors

Constructor and Description
BufferedSerializableIndexedDiskCache(String name, long defaultTimeToLive, int maxSize, int recycleSize, File baseDir, int bufferSize)
BufferedSerializableIndexedDiskCache(String name, long defaultTimeToLive, long defaultMaxIdleTime, int maxSize, int recycleSize, File baseDir, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected <T extends Serializable> T	copyData(T data) Creates a copy of the given data.
protected void	doDelete(Serializable key, BlockMetaData metaData) Performs deletion of the data belonging to the metadata.
protected <T extends Serializable> T	doGet(Serializable key, BlockMetaData metaData) Performs retrieval of the data belonging to the metadata.
protected <T extends Serializable> T	doPut(Serializable key, T data, long timeToLive, long maxIdleTime) Performs storage of the given data and adds new metadata to the map.
int	getBufferSize()
SimpleCacheStatistics	getBufferStatistics() Get the cache statistics of the buffer.
boolean	isCopyOnRead()
boolean	isCopyOnWrite()
void	setBufferSize(int bufferSize)
BufferedSerializableIndexedDiskCache	setCopyOnRead(boolean copyOnRead) Sets if a successful get should return a copy of the cache entry, so when manipulating the object no changes are persisted in the buffer.
BufferedSerializableIndexedDiskCache	setCopyOnWrite(boolean copyOnWrite) Sets if a successful put should return a copy of the cache entry, so when manipulating the object no changes are persisted in the buffer.

Methods inherited from class net.dontdrinkandroot.cache.impl.disk.indexed.SerializableIndexedDiskCache

dataFromBytes, dataToBytes, getDataFileNumAllocatedBlocks, getIndexFileNumAllocatedBlocks

Methods inherited from class net.dontdrinkandroot.cache.impl.disk.indexed.AbstractIndexedDiskCache

buildIndex, close, flush, getWriteQueueLength, isWriterThreadAlive, setQueueSizeWarningLimit

Methods inherited from class net.dontdrinkandroot.cache.impl.AbstractMapBackedCustomTtlCache

doPut, put, put, putWithErrors, putWithErrors

Methods inherited from class net.dontdrinkandroot.cache.impl.AbstractMapBackedCache

cleanUp, delete, delete, expunge, expunge, get, getCleanUpInterval, getComparator, getEntriesMetaData, getEntry, getMaxSize, getMetaData, getRecycleSize, getStatistics, getWithErrors, put, putEntry, putWithErrors, setCleanUpInterval, setMaxSize, setRecycleSize, triggerExpunge

Methods inherited from class net.dontdrinkandroot.cache.impl.AbstractCache

getCleanUpLogger, getDefaultMaxIdleTime, getDefaultTtl, getLogger, getName, setDefaultMaxIdleTime, setDefaultTtl

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.dontdrinkandroot.cache.RecyclingCache

getMaxSize, getRecycleSize, setMaxSize, setRecycleSize

Methods inherited from interface net.dontdrinkandroot.cache.Cache

cleanUp, delete, expunge, get, getDefaultMaxIdleTime, getDefaultTtl, getMetaData, getName, getStatistics, getWithErrors, put, putWithErrors, setDefaultTtl

Constructor Detail

BufferedSerializableIndexedDiskCache

public BufferedSerializableIndexedDiskCache(String name,
                                    long defaultTimeToLive,
                                    int maxSize,
                                    int recycleSize,
                                    File baseDir,
                                    int bufferSize)
                                     throws IOException

Throws:

IOException

BufferedSerializableIndexedDiskCache

public BufferedSerializableIndexedDiskCache(String name,
                                    long defaultTimeToLive,
                                    long defaultMaxIdleTime,
                                    int maxSize,
                                    int recycleSize,
                                    File baseDir,
                                    int bufferSize)
                                     throws IOException

Throws:

IOException

Method Detail

getBufferStatistics

public SimpleCacheStatistics getBufferStatistics()

Get the cache statistics of the buffer. The buffer statistics indicate the following: a cache hit means that the entry exists in the cache and was found in the buffer, a cache miss means that the entry exists in the cache and was not found in the buffer, the get and put count reflects gets and puts to the buffer, not the cache itself, the size is the current size of the buffer.

doGet

protected <T extends Serializable> T doGet(Serializable key,
                               BlockMetaData metaData)
                                throws CacheException

Description copied from class: AbstractMapBackedCache

Performs retrieval of the data belonging to the metadata.

Overrides:

doGet in class AbstractIndexedDiskCache<Serializable,Serializable>

Throws:

CacheException

doPut

protected <T extends Serializable> T doPut(Serializable key,
                               T data,
                               long timeToLive,
                               long maxIdleTime)
                                throws CacheException

Description copied from class: AbstractMapBackedCustomTtlCache

Performs storage of the given data and adds new metadata to the map.

Overrides:

doPut in class AbstractIndexedDiskCache<Serializable,Serializable>

Throws:

CacheException

doDelete

protected void doDelete(Serializable key,
            BlockMetaData metaData)
                 throws CacheException

Description copied from class: AbstractMapBackedCache

Performs deletion of the data belonging to the metadata. Removal from the map is done by the superclass.

Overrides:

doDelete in class AbstractIndexedDiskCache<Serializable,Serializable>

Throws:

CacheException

getBufferSize

public int getBufferSize()

Specified by:

getBufferSize in interface BufferedRecyclingCache<Serializable,Serializable>

setBufferSize

public void setBufferSize(int bufferSize)

Specified by:

setBufferSize in interface BufferedRecyclingCache<Serializable,Serializable>

copyData

protected <T extends Serializable> T copyData(T data)

Creates a copy of the given data.

isCopyOnRead

public boolean isCopyOnRead()

isCopyOnWrite

public boolean isCopyOnWrite()

setCopyOnRead

public BufferedSerializableIndexedDiskCache setCopyOnRead(boolean copyOnRead)

Sets if a successful get should return a copy of the cache entry, so when manipulating the object no changes are persisted in the buffer.

setCopyOnWrite

public BufferedSerializableIndexedDiskCache setCopyOnWrite(boolean copyOnWrite)

Sets if a successful put should return a copy of the cache entry, so when manipulating the object no changes are persisted in the buffer.