Package com.tangosol.net.cache

Class ReadWriteBackingMap.NonBlockingEntryStoreWrapper

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.ReadWriteBackingMap.StoreWrapper

com.tangosol.net.cache.ReadWriteBackingMap.NonBlockingEntryStoreWrapper

Enclosing class:

ReadWriteBackingMap

public class ReadWriteBackingMap.NonBlockingEntryStoreWrapper
extends ReadWriteBackingMap.StoreWrapper

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ReadWriteBackingMap.NonBlockingEntryStoreWrapper.LoadOperationObserver	Callbacks invoked by NonBlockingEntryStore implementation to handle the result of load operations.
class	ReadWriteBackingMap.NonBlockingEntryStoreWrapper.StoreOperationObserver	Callbacks invoked by NonBlockingEntryStore implementer to handle the result of store operations.

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
NonBlockingEntryStoreWrapper(NonBlockingEntryStore store)	Construct a NonBlockingEntryStoreWrapper.

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.
NonBlockingEntryStore	getNonBlockingEntryStore()	The wrapped NonBlockingEntryStore.
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.
boolean	isBlocking()	Determine if the wrapped store implements blocking 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 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 NonBlockingEntryStoreWrapper 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, 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

NonBlockingEntryStoreWrapper

public NonBlockingEntryStoreWrapper(NonBlockingEntryStore store)

Construct a NonBlockingEntryStoreWrapper.

Parameters:

store - the NonBlockingEntryStore 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

getNonBlockingEntryStore

public NonBlockingEntryStore getNonBlockingEntryStore()

The wrapped NonBlockingEntryStore.

Returns:

the underlying NonBlockingEntryStore this CacheStoreWrapper wraps

toString

public String toString()

Return a String representation of the NonBlockingEntryStoreWrapper 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

isBlocking

public boolean isBlocking()

Determine if the wrapped store implements blocking operations.

Overrides:

isBlocking in class ReadWriteBackingMap.StoreWrapper

Returns:

true if the operations are blocking