com.bigdata.ha.msg

Class HA2PhasePrepareMessage

java.lang.Object

com.bigdata.ha.msg.HA2PhasePrepareMessage

All Implemented Interfaces:

IHA2PhaseCommitProtocolMessage, IHA2PhasePrepareMessage, IHAMessage, Serializable

public class HA2PhasePrepareMessage
extends Object
implements IHA2PhasePrepareMessage, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HA2PhasePrepareMessage(IHANotifyReleaseTimeResponse consensusReleaseTime, boolean isGatherService, boolean isJoinedService, IRootBlockView rootBlock, long timeout, TimeUnit unit)

Method Summary

Methods

Modifier and Type	Method and Description
IHANotifyReleaseTimeResponse	getConsensusReleaseTime() The consensus release time from the GATHER.
IRootBlockView	getRootBlock() The new root block.
long	getTimeout() How long to wait for the other services to prepare.
TimeUnit	getUnit() The unit for the timeout.
boolean	isGatherService() true iff the service was recognized as being joined with the met quorum at the time that the GATHER message was prepared.
boolean	isJoinedService() true iff the service was recognized as being joined with the met quorum at the time that the PREPARE message was prepared.
boolean	isRootBlock0() true if this is rootBlock0 for the leader.
String	toString()
boolean	voteNo() When true, always vote note.

Methods inherited from class java.lang.Object

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

Constructor Detail

HA2PhasePrepareMessage

public HA2PhasePrepareMessage(IHANotifyReleaseTimeResponse consensusReleaseTime,
                      boolean isGatherService,
                      boolean isJoinedService,
                      IRootBlockView rootBlock,
                      long timeout,
                      TimeUnit unit)

Method Detail

getConsensusReleaseTime

public IHANotifyReleaseTimeResponse getConsensusReleaseTime()

Description copied from interface: IHA2PhasePrepareMessage

The consensus release time from the GATHER.

Specified by:

getConsensusReleaseTime in interface IHA2PhasePrepareMessage

isGatherService

public boolean isGatherService()

Description copied from interface: IHA2PhasePrepareMessage

true iff the service was recognized as being joined with the met quorum at the time that the GATHER message was prepared.

Note: This is used to support atomic decisions about whether or not a service was joined with the met quorum at the time that the leader decided to update the consensus release time. Services that are in the pipeline and resynchronizing were either joined or not for the purposes of a given 2-phase GATHER operation based on this flag.

Specified by:

isGatherService in interface IHA2PhasePrepareMessage

isJoinedService

public boolean isJoinedService()

Description copied from interface: IHA2PhasePrepareMessage

true iff the service was recognized as being joined with the met quorum at the time that the PREPARE message was prepared.

Note: This is used to support atomic decisions about whether or not a service was joined with the met quorum at the time that the leader decided to commit. Services that are in the pipeline and resynchronizing will either be joined or not for the purposes of a given 2-phase commit based on this flag.

Note: A better name for this flag would be isPrepareService().

Specified by:

isJoinedService in interface IHA2PhasePrepareMessage

isRootBlock0

public boolean isRootBlock0()

Description copied from interface: IHA2PhasePrepareMessage

true if this is rootBlock0 for the leader.

Specified by:

isRootBlock0 in interface IHA2PhasePrepareMessage

getRootBlock

public IRootBlockView getRootBlock()

Description copied from interface: IHA2PhasePrepareMessage

The new root block.

Specified by:

getRootBlock in interface IHA2PhasePrepareMessage

getTimeout

public long getTimeout()

Description copied from interface: IHA2PhasePrepareMessage

How long to wait for the other services to prepare.

Specified by:

getTimeout in interface IHA2PhasePrepareMessage

getUnit

public TimeUnit getUnit()

Description copied from interface: IHA2PhasePrepareMessage

The unit for the timeout.

Specified by:

getUnit in interface IHA2PhasePrepareMessage

voteNo

public boolean voteNo()

When true, always vote note.

Note: This is for unit tests only.

Returns false by default

Specified by:

voteNo in interface IHA2PhasePrepareMessage

toString

public String toString()

Overrides:

toString in class Object