com.bigdata.ha.msg

Class HANotifyReleaseTimeRequest

java.lang.Object

com.bigdata.ha.msg.HANotifyReleaseTimeRequest

All Implemented Interfaces:

IHAMessage, IHANotifyReleaseTimeRequest, Serializable

public class HANotifyReleaseTimeRequest
extends Object
implements IHANotifyReleaseTimeRequest

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HANotifyReleaseTimeRequest(UUID serviceUUID, long pinnedCommitTime, long pinnedCommitCounter, long timestamp, boolean isMock, long newCommitCounter, long newCommitTime)

Method Summary

Methods

Modifier and Type	Method and Description
long	getNewCommitCounter() The commit counter that will be assigned to the new commit point (as specified by the leader).
long	getNewCommitTime() The commit time that will be assigned to the new commit point (as specified by the leader).
long	getPinnedCommitCounter() The earliest pinned commit counter on the follower.
long	getPinnedCommitTime() The earliest pinned commit time on the follower.
UUID	getServiceUUID() The service that provided this information.
long	getTimestamp() A timestamp taken during the protocol used to agree on the new release time.
boolean	isMock() Mock responses are used when a follow is unable to provide a correct response (typically because the follower is not yet HAReady and hence is not able to participate in the gather).
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

HANotifyReleaseTimeRequest

public HANotifyReleaseTimeRequest(UUID serviceUUID,
                          long pinnedCommitTime,
                          long pinnedCommitCounter,
                          long timestamp,
                          boolean isMock,
                          long newCommitCounter,
                          long newCommitTime)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getServiceUUID

public UUID getServiceUUID()

Description copied from interface: IHANotifyReleaseTimeRequest

The service that provided this information.

Specified by:

getServiceUUID in interface IHANotifyReleaseTimeRequest

getPinnedCommitTime

public long getPinnedCommitTime()

Description copied from interface: IHANotifyReleaseTimeRequest

The earliest pinned commit time on the follower.

Specified by:

getPinnedCommitTime in interface IHANotifyReleaseTimeRequest

getPinnedCommitCounter

public long getPinnedCommitCounter()

Description copied from interface: IHANotifyReleaseTimeRequest

The earliest pinned commit counter on the follower.

Specified by:

getPinnedCommitCounter in interface IHANotifyReleaseTimeRequest

getTimestamp

public long getTimestamp()

Description copied from interface: IHANotifyReleaseTimeRequest

A timestamp taken during the protocol used to agree on the new release time. This is used to detect problems where the clocks are not synchronized on the services.

Specified by:

getTimestamp in interface IHANotifyReleaseTimeRequest

isMock

public boolean isMock()

Description copied from interface: IHANotifyReleaseTimeRequest

Mock responses are used when a follow is unable to provide a correct response (typically because the follower is not yet HAReady and hence is not able to participate in the gather). The mock responses preserves liveness since the GATHER protocol will terminate quickly. By marking the response as a mock object, the leader can differentiate mock responses from valid responses and discard the mock responeses. If the GATHER task on the follower sends a mock response to the leader, then it will also have thrown an exception out of its GatherTask which will prevent the follower from voting YES on the PREPARE message for that 2-phase commit.

Specified by:

isMock in interface IHANotifyReleaseTimeRequest

See Also:

HA3 simultaneous service start failure

getNewCommitCounter

public long getNewCommitCounter()

Description copied from interface: IHANotifyReleaseTimeRequest

The commit counter that will be assigned to the new commit point (as specified by the leader).

Specified by:

getNewCommitCounter in interface IHANotifyReleaseTimeRequest

getNewCommitTime

public long getNewCommitTime()

Description copied from interface: IHANotifyReleaseTimeRequest

The commit time that will be assigned to the new commit point (as specified by the leader).

Specified by:

getNewCommitTime in interface IHANotifyReleaseTimeRequest