Package com.tangosol.net.cache

Class ReadWriteBackingMap.CacheStoreWrapper

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

com.tangosol.net.cache.ReadWriteBackingMap.CacheStoreWrapper

Direct Known Subclasses:

VersionedBackingMap.CacheStoreWrapper

Enclosing class:

ReadWriteBackingMap

public class ReadWriteBackingMap.CacheStoreWrapper
extends ReadWriteBackingMap.StoreWrapper

A wrapper around the original CacheStore to allow operations to be overridden and extended.

Author:

cp 2002.06.04

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

f_cLoadFailures, f_cLoadMillis, f_cLoadOps, f_cPendingAsyncStoreOps, f_cStoreEntries, f_cStoreFailures, f_cStoreMillis, f_cStoreOps, m_cEraseFailures, m_cEraseMillis, m_cEraseOps, m_eraseBundler, m_fEraseAllSupported, m_fEraseSupported, m_fStoreAllSupported, m_fStoreSupported, m_loadBundler, m_storeBundler

Fields inherited from class com.tangosol.util.Base

LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Constructor	Description
CacheStoreWrapper(CacheStore store)	Construct a CacheStoreWrapper.

Method Summary

Modifier and Type	Method	Description
protected void	eraseAllInternal(Set setBinEntries)	Remove the specified entries from the underlying store.
protected void	eraseInternal(ReadWriteBackingMap.Entry binEntry)	Remove the specified entry from the underlying store.
CacheStore	getCacheStore()	The wrapped CacheStore.
Object	getStore()	Return the cache store object to which this wrapper delegates.
AbstractBundler	instantiateEraseBundler()	Create the bundler for the erase operations.
AbstractBundler	instantiateLoadBundler()	Create the bundler for the load operations.
AbstractBundler	instantiateStoreBundler()	Create the bundler for the store operations.
protected Set	loadAllInternal(Set setBinKey)	Load the entries associated with each of the specified binary keys from the underlying store.
protected ReadWriteBackingMap.Entry	loadInternal(Object binKey)	Load the entry associated with the specified key from the underlying store.
protected com.tangosol.internal.tracing.Span.Builder	newSpan(String sOperation)	Return a Span.Builder for the specified operation.
protected com.tangosol.internal.tracing.Span.Builder	newSpan(String sOperation, ReadWriteBackingMap.Entry entry)	Return a Span.Builder for a given operation on an entry.
protected com.tangosol.internal.tracing.Span.Builder	newSpan(String sOperation, Set<ReadWriteBackingMap.Entry> setEntries)	Return a Span.Builder for a given operation on a set of entries.
protected void	storeAllInternal(Set setBinEntries)	Store the entries in the specified set in the underlying store.
protected void	storeInternal(ReadWriteBackingMap.Entry binEntry)	Store the specified entry in the underlying store.
String	toString()	Return a String representation of the CacheStoreWrapper object that will be used as a part of the write-behind thread name.

Methods inherited from class com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

calculateRequeueDelay, ensureEraseBundler, ensureLoadBundler, ensureStoreBundler, erase, eraseAll, formatKeys, getAverageBatchSize, getAverageEraseMillis, getAverageLoadMillis, getAverageStoreMillis, getEraseBundler, getEraseFailures, getEraseMillis, getEraseOps, getLoadBundler, getLoadFailures, getLoadMillis, getLoadOps, getPendingAsyncStoreOps, getStoreBundler, getStoreFailures, getStoreMillis, getStoreOps, isBlocking, isEraseAllSupported, isEraseSupported, isStoreAllSupported, isStoreSupported, load, loadAll, onEraseAllFailure, onEraseFailure, onLoadAllFailure, onLoadAllFailure, onLoadFailure, onLoadFailure, onStoreAllFailure, onStoreAllFailure, onStoreFailure, onStoreFailure, replace, reportUnsupported, requeue, resetStatistics, setEraseAllSupported, setEraseSupported, setStoreAllSupported, setStoreSupported, store, storeAll

Methods inherited from class com.tangosol.util.Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class java.lang.Object

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

Constructor Details

CacheStoreWrapper

public CacheStoreWrapper(CacheStore store)

Construct a CacheStoreWrapper.

Parameters:

store - the CacheStore to wrap

Method Details

instantiateLoadBundler

public AbstractBundler instantiateLoadBundler()

Create the bundler for the load operations.

Specified by:

instantiateLoadBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "load" bundler

instantiateStoreBundler

public AbstractBundler instantiateStoreBundler()

Create the bundler for the store operations.

Specified by:

instantiateStoreBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "store" bundler

instantiateEraseBundler

public AbstractBundler instantiateEraseBundler()

Create the bundler for the erase operations.

Specified by:

instantiateEraseBundler in class ReadWriteBackingMap.StoreWrapper

Returns:

the "erase" bundler

loadInternal

protected ReadWriteBackingMap.Entry loadInternal(Object binKey)

Load the entry associated with the specified key from the underlying store.

Specified by:

loadInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binKey - binary key whose associated value is to be loaded

Returns:

the entry associated with the specified key, or null if no value is available for that key

loadAllInternal

protected Set loadAllInternal(Set setBinKey)

Load the entries associated with each of the specified binary keys from the underlying store.

Specified by:

loadAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinKey - a set of binary keys to load

Returns:

a Set of entries for the specified keys

storeInternal

protected void storeInternal(ReadWriteBackingMap.Entry binEntry)

Store the specified entry in the underlying store.

Specified by:

storeInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binEntry - the entry to be stored

storeAllInternal

protected void storeAllInternal(Set setBinEntries)

Store the entries in the specified set in the underlying store.

Specified by:

storeAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinEntries - the set of entries to be stored

eraseInternal

protected void eraseInternal(ReadWriteBackingMap.Entry binEntry)

Remove the specified entry from the underlying store.

Specified by:

eraseInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

binEntry - the entry to be removed from the store

eraseAllInternal

protected void eraseAllInternal(Set setBinEntries)

Remove the specified entries from the underlying store.

Specified by:

eraseAllInternal in class ReadWriteBackingMap.StoreWrapper

Parameters:

setBinEntries - the set entries to be removed from the store

getStore

public Object getStore()

Return the cache store object to which this wrapper delegates.

Specified by:

getStore in class ReadWriteBackingMap.StoreWrapper

Returns:

the cache store object to which this wrapper delegates

getCacheStore

public CacheStore getCacheStore()

The wrapped CacheStore.

Returns:

the underlying CacheStore this CacheStoreWrapper wraps

newSpan

protected com.tangosol.internal.tracing.Span.Builder newSpan(String sOperation)

Return a Span.Builder for the specified operation.

Parameters:

sOperation - the operation name

Returns:

the Span.Builder

newSpan

protected com.tangosol.internal.tracing.Span.Builder newSpan(String sOperation,
 ReadWriteBackingMap.Entry entry)

Return a Span.Builder for a given operation on an entry.

Parameters:

sOperation - the operation name

entry - the entry

Returns:

the Span.Builder

newSpan

protected com.tangosol.internal.tracing.Span.Builder newSpan(String sOperation,
 Set<ReadWriteBackingMap.Entry> setEntries)

Return a Span.Builder for a given operation on a set of entries.

Parameters:

sOperation - the operation name

setEntries - the set of entries

Returns:

the Span.Builder

toString

public String toString()

Return a String representation of the CacheStoreWrapper object that will be used as a part of the write-behind thread name.

Overrides:

toString in class Object

Returns:

a String representation of the CacheStoreWrapper object