com.hazelcast.quorum.impl

Class RecentlyActiveQuorumFunction

java.lang.Object

com.hazelcast.quorum.impl.AbstractPingAwareQuorumFunction

com.hazelcast.quorum.impl.RecentlyActiveQuorumFunction

All Implemented Interfaces:

HazelcastInstanceAware, MembershipListener, HeartbeatAware, PingAware, QuorumFunction, EventListener

public class RecentlyActiveQuorumFunction
extends AbstractPingAwareQuorumFunction
implements HeartbeatAware, QuorumFunction, MembershipListener

A quorum function that keeps track of the last heartbeat timestamp per member. For a member to be considered live (for the purpose of determining presence of quorum), a heartbeat must have been received at most heartbeatToleranceMillis milliseconds before current time.

Field Summary

Fields inherited from class com.hazelcast.quorum.impl.AbstractPingAwareQuorumFunction

cluster, pingFailureDetector, pingFDEnabled

Constructor Summary

Constructors

Constructor and Description
RecentlyActiveQuorumFunction(int quorumSize, int heartbeatToleranceMillis)

Method Summary

Modifier and Type	Method and Description
boolean	apply(Collection<Member> members) Determines if quorum is present based on the current list of members in the cluster.
boolean	equals(Object o)
int	getHeartbeatToleranceMillis()
int	hashCode()
void	memberAdded(MembershipEvent membershipEvent) Invoked when a new member is added to the cluster.
void	memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) Invoked when an attribute of a member was changed.
void	memberRemoved(MembershipEvent membershipEvent) Invoked when an existing member leaves the cluster.
void	onHeartbeat(Member member, long timestamp) Notifies of a received heartbeat.

Methods inherited from class com.hazelcast.quorum.impl.AbstractPingAwareQuorumFunction

isAlivePerIcmp, onPingLost, onPingRestored, setHazelcastInstance

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecentlyActiveQuorumFunction

public RecentlyActiveQuorumFunction(int quorumSize,
                                    int heartbeatToleranceMillis)

Method Detail

apply

public boolean apply(Collection<Member> members)

Description copied from interface: QuorumFunction

Determines if quorum is present based on the current list of members in the cluster.
This method should not block nor execute time-consuming operations, otherwise it may stall other quorum function invocations.

Specified by:

apply in interface QuorumFunction

Parameters:

members - snapshot of current member list

Returns:

boolean presence/absence of quorum

onHeartbeat

public void onHeartbeat(Member member,
                        long timestamp)

Description copied from interface: HeartbeatAware

Notifies of a received heartbeat. This method is always invoked before QuorumFunction.apply(Collection) so the QuorumFunction can update its internal state before deciding on quorum presence.

Specified by:

onHeartbeat in interface HeartbeatAware

Parameters:

member - member from which heartbeat was received

timestamp - timestmap on which heartbeat was received

memberAdded

public void memberAdded(MembershipEvent membershipEvent)

Description copied from interface: MembershipListener

Invoked when a new member is added to the cluster.

Specified by:

memberAdded in interface MembershipListener

Parameters:

membershipEvent - membership event

memberRemoved

public void memberRemoved(MembershipEvent membershipEvent)

Description copied from interface: MembershipListener

Invoked when an existing member leaves the cluster.

Specified by:

memberRemoved in interface MembershipListener

Parameters:

membershipEvent - membership event when an existing member leaves the cluster

memberAttributeChanged

public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent)

Description copied from interface: MembershipListener

Invoked when an attribute of a member was changed.

Specified by:

memberAttributeChanged in interface MembershipListener

Parameters:

memberAttributeEvent - member attribute event when an attribute of a member was changed

getHeartbeatToleranceMillis

public int getHeartbeatToleranceMillis()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object