com.tangosol.net

Class ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.ConfigurableQuorumPolicy

com.tangosol.net.ConfigurableQuorumPolicy.MembershipQuorumPolicy

com.tangosol.net.ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy

All Implemented Interfaces:

ActionPolicy

Enclosing class:

ConfigurableQuorumPolicy

public static class ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy
extends ConfigurableQuorumPolicy.MembershipQuorumPolicy

PartitionedCacheQuorumPolicy defines a configurable quorum policy that is applicable to a DistributedCacheService.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy.ActionRule Action Rules for ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy

Nested classes/interfaces inherited from class com.tangosol.net.ConfigurableQuorumPolicy.MembershipQuorumPolicy

ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumListener, ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule

Nested classes/interfaces inherited from class com.tangosol.net.ConfigurableQuorumPolicy

ConfigurableQuorumPolicy.ClusterQuorumPolicy, ConfigurableQuorumPolicy.MembershipQuorumPolicy, ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy, ConfigurableQuorumPolicy.ProxyQuorumPolicy, ConfigurableQuorumPolicy.WrapperQuorumPolicy

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

Base.LoggingWriter, Base.StackFrame

Field Summary

Fields

Modifier and Type	Field and Description
protected AddressProvider	m_apRecovery The recovery address-provider.
protected boolean	m_fReportRuleChange Whether the quorum rule has changed and disallowed actions should be reported.
static int	MASK_DISTRIBUTION Bitmask used to encode a distribution action.
static int	MASK_READ Bitmask used to encode a read action.
static int	MASK_RECOVER Bitmask used to encode a recover action.
static int	MASK_RESTORE Bitmask used to encode a partition restore action.
static int	MASK_WRITE Bitmask used to encode a write action.

Fields inherited from class com.tangosol.net.ConfigurableQuorumPolicy.MembershipQuorumPolicy

m_aRules, m_ruleCurrent, m_service, m_setLeaving

Fields inherited from class com.tangosol.util.Base

LOG_ALWAYS, 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 and Description
PartitionedCacheQuorumPolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule, AddressProvider provider) Construct a PartitionedCacheQuorumPolicy with the specified rule.

Method Summary

Modifier and Type	Method and Description
protected boolean	checkRecoveryAddresses() Check that all of the recovery addresses are represented by the ownership-enabled members.
protected String	getActionName(int nMask) Return the string description of the given mask (rule).
protected Set	getOwnershipMemberSet() Return the set of ownership-enabled members in the associated PartitionedService.
int	getPolicyPopulation() Calculate and return the current size of the member set that contributes to the quorum for this policy domain.
String	getStatusDescription() Return a String that describes the current Quorum state.
boolean	isAllowed(Service service, Action action) Evaluate if the specified action is currently allowed by this policy.
protected void	reportDisallowedAction(int nMaskDisallowed) Report all disallowed actions if the quorum rule has changed.
protected void	setCurrentRule(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule ruleCurrent) Set the current quorum rule used by the policy.

Methods inherited from class com.tangosol.net.ConfigurableQuorumPolicy.MembershipQuorumPolicy

configure, getCurrentRule, getLeavingMembers, getQuorumRules, getService, init, instantiateMemberListener, setQuorumRules, setService, sortByThreshold, toString, updateCurrentRule

Methods inherited from class com.tangosol.net.ConfigurableQuorumPolicy

instantiateClusterPolicy, instantiatePartitionedCachePolicy, instantiateProxyPolicy

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, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, 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

Field Detail

MASK_DISTRIBUTION

public static final int MASK_DISTRIBUTION

Bitmask used to encode a distribution action.

See Also:

Constant Field Values

MASK_RESTORE

public static final int MASK_RESTORE

Bitmask used to encode a partition restore action.

See Also:

Constant Field Values

MASK_READ

public static final int MASK_READ

Bitmask used to encode a read action.

See Also:

Constant Field Values

MASK_WRITE

public static final int MASK_WRITE

Bitmask used to encode a write action.

See Also:

Constant Field Values

MASK_RECOVER

public static final int MASK_RECOVER

Bitmask used to encode a recover action.

See Also:

Constant Field Values

m_apRecovery

protected AddressProvider m_apRecovery

The recovery address-provider.

m_fReportRuleChange

protected boolean m_fReportRuleChange

Whether the quorum rule has changed and disallowed actions should be reported.

Constructor Detail

PartitionedCacheQuorumPolicy

public PartitionedCacheQuorumPolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule,
                                    AddressProvider provider)

Construct a PartitionedCacheQuorumPolicy with the specified rule.

Parameters:

aRule - the quorum rule.

provider - the recovery address-provider

Method Detail

getOwnershipMemberSet

protected Set getOwnershipMemberSet()

Return the set of ownership-enabled members in the associated PartitionedService.

Returns:

the set of ownership-enabled members

checkRecoveryAddresses

protected boolean checkRecoveryAddresses()

Check that all of the recovery addresses are represented by the ownership-enabled members.

Returns:

true iff all of the recovery addresses are represented

getStatusDescription

public String getStatusDescription()

Return a String that describes the current Quorum state.

Specified by:

getStatusDescription in class ConfigurableQuorumPolicy

Returns:

a String describing the allowed actions in the current state

getPolicyPopulation

public int getPolicyPopulation()

Calculate and return the current size of the member set that contributes to the quorum for this policy domain.

Note: The quorum for PartitionedService is determined by the ownership-enabled members only.

Overrides:

getPolicyPopulation in class ConfigurableQuorumPolicy.MembershipQuorumPolicy

Returns:

the current size

isAllowed

public boolean isAllowed(Service service,
                         Action action)

Evaluate if the specified action is currently allowed by this policy.

Note: for forward compatibility, implementations should generally return true for actions that are not recognized.

Parameters:

service - the service that is performing the action

action - the action that is being performed

Returns:

true iff the specified action is currently allowed by this policy

setCurrentRule

protected void setCurrentRule(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule ruleCurrent)

Description copied from class: ConfigurableQuorumPolicy.MembershipQuorumPolicy

Set the current quorum rule used by the policy.

Overrides:

setCurrentRule in class ConfigurableQuorumPolicy.MembershipQuorumPolicy

Parameters:

ruleCurrent - the current quorum rule used by the policy

reportDisallowedAction

protected void reportDisallowedAction(int nMaskDisallowed)

Report all disallowed actions if the quorum rule has changed.

Parameters:

nMaskDisallowed - a mask of the disallowed action

getActionName

protected String getActionName(int nMask)

Return the string description of the given mask (rule).

Parameters:

nMask - the bitmask

Returns:

the string description of the given mask (rule)