Package com.tangosol.persistence

Class AbstractPersistenceManager.AbstractPersistentStore.OpenTask

java.lang.Object

com.tangosol.util.Base

AbstractPersistenceManager<PS>.com.tangosol.persistence.AbstractPersistenceManager.Task

com.tangosol.persistence.AbstractPersistenceManager.AbstractPersistentStore.OpenTask

All Implemented Interfaces:

Associated, KeyAssociation, Runnable

Enclosing class:

AbstractPersistenceManager.AbstractPersistentStore

protected class AbstractPersistenceManager.AbstractPersistentStore.OpenTask
extends AbstractPersistenceManager<PS>.Task
implements KeyAssociation

An OpenTask opens the store (parent of this inner class) with the provided store and notifies the Collector when complete.

Nested Class Summary

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

Base.LoggingWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected final Collector<Object>	f_collector	The Collector to notify upon completion of opening the store.
protected final com.oracle.coherence.persistence.PersistentStore<ReadBuffer>	f_storeFrom	The PersistentStore to open with.

Fields inherited from class com.tangosol.persistence.AbstractPersistenceManager.Task

f_canceled

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
OpenTask(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom, Collector<Object> collector)	Construct an OpenTask.

Method Summary

Modifier and Type	Method	Description
void	execute()	Execute the task.
Object	getAssociatedKey()	Determine the host key (or base) object to which this object is associated.

Methods inherited from class com.tangosol.persistence.AbstractPersistenceManager.Task

cancel, notifyCanceled, register, run

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, toString, wait, wait, wait

Field Details

f_storeFrom

protected final com.oracle.coherence.persistence.PersistentStore<ReadBuffer> f_storeFrom

The PersistentStore to open with. The contents of this store are copied to the store being opened.

f_collector

protected final Collector<Object> f_collector

The Collector to notify upon completion of opening the store.

Constructor Details

OpenTask

public OpenTask(com.oracle.coherence.persistence.PersistentStore<ReadBuffer> storeFrom,
 Collector<Object> collector)

Construct an OpenTask.

Parameters:

storeFrom - store to open from

collector - collector to notify when the open completes

Method Details

getAssociatedKey

public Object getAssociatedKey()

Description copied from interface: Associated

Determine the host key (or base) object to which this object is associated.

Note: It's expected that the returned object is suitable to be used as an immutable identity (e.g. a key in a Map).
Note 2: Circular associations are not permitted.

Specified by:

getAssociatedKey in interface Associated

Returns:

the host key that for this object, or null if this object has no association

execute

public void execute()

Description copied from class: AbstractPersistenceManager.Task

Execute the task.

Specified by:

execute in class AbstractPersistenceManager<PS extends AbstractPersistenceManager.AbstractPersistentStore>.Task