Package com.tangosol.persistence

Class GUIDHelper.GUIDResolver

java.lang.Object

com.tangosol.util.Base

com.tangosol.persistence.GUIDHelper.GUIDResolver

Enclosing class:

GUIDHelper

public static class GUIDHelper.GUIDResolver
extends Base

Resolver used during a recovery to discover the newest available GUID for a given partition.

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 Map<Member,com.oracle.coherence.persistence.PersistentStoreInfo[]>	f_mapStoreInfo	The Map of registered PersistentStoreInfos, keyed by member.
protected com.oracle.coherence.persistence.PersistentStoreInfo[]	m_aStoreNewest	The resolved list of the newest stores, indexed by partition-id.
protected int	m_cPartitions	The partition-count.
protected boolean	m_fSharedStorage	Specifies whether or not the storage is shared.
protected Map<Member,List<String>>	m_mapCleanup	The map of member to a list of GUIDs to be deleted.
protected Map<Member,PartitionSet>	m_mapResolved	The resolved map of members to the associated set of partitions.
protected PartitionSet	m_partsUnresolved	The PartitionSet containing partitions that don't have corresponding GUIDs.

Fields inherited from class com.tangosol.util.Base

DEFAULT_LOAD_FACTOR, 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
GUIDResolver(int cPartitions)	Construct a GUIDResolver for the specified partition-count.

Method Summary

Modifier and Type	Method	Description
Map<Member,List<String>>	getInvalidGUIDs()	Retrieve a map of member to a list of GUIDs to be deleted.
Map<Integer,com.oracle.coherence.persistence.PersistentStoreInfo[]>	getMemberStoreInfo()	Return a Map of member id to an array of PersistentStoreInfo.
String	getNewestGUID(int nPartition)	Return the newest GUID for the specified partition.
String[]	getNewestGUIDs(PartitionSet parts)	Return the list of the newest GUIDs for the specified set of partitions.
com.oracle.coherence.persistence.PersistentStoreInfo[]	getNewestStoreInfos(PartitionSet parts)	Return the list of the PersistentStoreInfo with newest GUIDs for the specified set of partitions.
PartitionSet	getUnresolvedPartitions()	Retrieve a PartitionSet containing all partitions that don't have any corresponding GUIDs.
boolean	isSharedStorage()	Check whether ior not all the partition stores visible by every member.
void	registerStoreInfo(Member member, com.oracle.coherence.persistence.PersistentStoreInfo[] aInfo)	Register the specified list of GUIDs from the specified member.
Map<Member,PartitionSet>	resolve()	Resolve the registered PersistentStoreInfos and return a map associating each member to the set of partitions that it had registered as having the newest GUID for, except when the newest store is empty while the older version is not.

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, newHashMap, newHashMap, newHashSet, newHashSet, 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_mapStoreInfo

protected final Map<Member,com.oracle.coherence.persistence.PersistentStoreInfo[]> f_mapStoreInfo

The Map of registered PersistentStoreInfos, keyed by member.

m_cPartitions

protected int m_cPartitions

The partition-count.

m_aStoreNewest

protected com.oracle.coherence.persistence.PersistentStoreInfo[] m_aStoreNewest

The resolved list of the newest stores, indexed by partition-id.

m_mapCleanup

protected Map<Member,List<String>> m_mapCleanup

The map of member to a list of GUIDs to be deleted.

m_mapResolved

protected Map<Member,PartitionSet> m_mapResolved

The resolved map of members to the associated set of partitions.

m_partsUnresolved

protected PartitionSet m_partsUnresolved

The PartitionSet containing partitions that don't have corresponding GUIDs.

m_fSharedStorage

protected boolean m_fSharedStorage

Specifies whether or not the storage is shared. If true, every member can see all the newest partition stores.

Constructor Details

GUIDResolver

public GUIDResolver(int cPartitions)

Construct a GUIDResolver for the specified partition-count.

Parameters:

cPartitions - the partition-count

Method Details

registerStoreInfo

public void registerStoreInfo(Member member,
 com.oracle.coherence.persistence.PersistentStoreInfo[] aInfo)

Register the specified list of GUIDs from the specified member.

Parameters:

member - the member

aInfo - the list of PersistentStoreInfo

getNewestGUID

public String getNewestGUID(int nPartition)

Return the newest GUID for the specified partition.

Parameters:

nPartition - the partition to return a GUID for

Returns:

the newest GUIDs

getNewestGUIDs

public String[] getNewestGUIDs(PartitionSet parts)

Return the list of the newest GUIDs for the specified set of partitions.

Parameters:

parts - the set of partitions to return GUIDs for

Returns:

the list of newest GUIDs

getNewestStoreInfos

public com.oracle.coherence.persistence.PersistentStoreInfo[] getNewestStoreInfos(PartitionSet parts)

Return the list of the PersistentStoreInfo with newest GUIDs for the specified set of partitions.

Parameters:

parts - the set of partitions to return PersistentStoreInfo for

Returns:

the list of the PersistentStoreInfo with newest GUIDs

Since:

24.09

getUnresolvedPartitions

public PartitionSet getUnresolvedPartitions()

Retrieve a PartitionSet containing all partitions that don't have any corresponding GUIDs.

Returns:

a PartitionSet of all unresolved partitions

getInvalidGUIDs

public Map<Member,List<String>> getInvalidGUIDs()

Retrieve a map of member to a list of GUIDs to be deleted.

Returns:

a map of member to a list of GUIDs to be deleted

getMemberStoreInfo

public Map<Integer,com.oracle.coherence.persistence.PersistentStoreInfo[]> getMemberStoreInfo()

Return a Map of member id to an array of PersistentStoreInfo.

Returns:

a Map of member id to an array of PersistentStoreInfo

isSharedStorage

public boolean isSharedStorage()

Check whether ior not all the partition stores visible by every member.

Returns:

true iff all the partition stores visible by every member

resolve

public Map<Member,PartitionSet> resolve()

Resolve the registered PersistentStoreInfos and return a map associating each member to the set of partitions that it had registered as having the newest GUID for, except when the newest store is empty while the older version is not.

Returns:

a map associating each member to the set of partitions it has the latest GUID for