com.hazelcast.splitbrainprotection.impl

Class RecentlyActiveSplitBrainProtectionFunction

java.lang.Object

com.hazelcast.splitbrainprotection.impl.AbstractPingAwareSplitBrainProtectionFunction

com.hazelcast.splitbrainprotection.impl.RecentlyActiveSplitBrainProtectionFunction

All Implemented Interfaces:

MembershipListener, HazelcastInstanceAware, HeartbeatAware, PingAware, SplitBrainProtectionFunction, EventListener

public class RecentlyActiveSplitBrainProtectionFunction
extends AbstractPingAwareSplitBrainProtectionFunction
implements HeartbeatAware, SplitBrainProtectionFunction, MembershipListener

A split brain protection function that keeps track of the last heartbeat timestamp per member. For a member to be considered live (for the purpose to conclude whether the minimum cluster size property is satisfied), a heartbeat must have been received at most heartbeatToleranceMillis milliseconds before current time.

Constructor Summary

Constructors

Constructor and Description
RecentlyActiveSplitBrainProtectionFunction(int minimumClusterSize, int heartbeatToleranceMillis)

Method Summary

Modifier and Type	Method and Description
boolean	apply(Collection<Member> members) Determines whether the minimum cluster size property is satisfied based on the current list of members in the cluster.
boolean	equals(Object o)
int	getHeartbeatToleranceMillis()
int	hashCode()
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.splitbrainprotection.impl.AbstractPingAwareSplitBrainProtectionFunction

isAlivePerIcmp, memberAdded, memberAttributeChanged, onPingLost, onPingRestored, setHazelcastInstance

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cluster.MembershipListener

memberAdded, memberAttributeChanged

Constructor Detail

RecentlyActiveSplitBrainProtectionFunction

public RecentlyActiveSplitBrainProtectionFunction(int minimumClusterSize,
                                                  int heartbeatToleranceMillis)

Method Detail

apply

public boolean apply(Collection<Member> members)

Description copied from interface: SplitBrainProtectionFunction

Determines whether the minimum cluster size property is satisfied based on the current list of members in the cluster. Lite members are excluded and only data members are provided to this method.
This method should not block nor execute time-consuming operations, otherwise it may stall other split brain protection function invocations.

Specified by:

apply in interface SplitBrainProtectionFunction

Parameters:

members - snapshot of current member list

Returns:

boolean whether the minimum cluster size property is satisfied

onHeartbeat

public void onHeartbeat(Member member,
                        long timestamp)

Description copied from interface: HeartbeatAware

Notifies of a received heartbeat. This method is always invoked before SplitBrainProtectionFunction.apply(Collection) so the SplitBrainProtectionFunction can update its internal state before deciding on whether the minimum cluster size property (for the purpose of split brain detection) is satisfied.

Specified by:

onHeartbeat in interface HeartbeatAware

Parameters:

member - member from which heartbeat was received

timestamp - timestmap on which heartbeat was received

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

Overrides:

memberRemoved in class AbstractPingAwareSplitBrainProtectionFunction

Parameters:

membershipEvent - membership event when an existing member leaves the cluster

getHeartbeatToleranceMillis

public int getHeartbeatToleranceMillis()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object