com.hazelcast.splitbrainprotection.impl

Class AbstractPingAwareSplitBrainProtectionFunction

java.lang.Object

com.hazelcast.splitbrainprotection.impl.AbstractPingAwareSplitBrainProtectionFunction

All Implemented Interfaces:

MembershipListener, HazelcastInstanceAware, PingAware, EventListener

Direct Known Subclasses:

ProbabilisticSplitBrainProtectionFunction, RecentlyActiveSplitBrainProtectionFunction

public abstract class AbstractPingAwareSplitBrainProtectionFunction
extends Object
implements PingAware, HazelcastInstanceAware, MembershipListener

Base class for split brain protection functions which may use ICMP failure detector information to conclude whether the minimum cluster size property is satisfied.

Constructor Summary

Constructors

Constructor and Description
AbstractPingAwareSplitBrainProtectionFunction()

Method Summary

Modifier and Type	Method and Description
protected boolean	isAlivePerIcmp(Member member)
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	onPingLost(Member member) Notifies the SplitBrainProtectionFunction of ping loss.
void	onPingRestored(Member member) Notifies the SplitBrainProtectionFunction of a successful ping after one or more pings to that member were lost.
void	setHazelcastInstance(HazelcastInstance hazelcastInstance) Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPingAwareSplitBrainProtectionFunction

public AbstractPingAwareSplitBrainProtectionFunction()

Method Detail

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Description copied from interface: HazelcastInstanceAware

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

Parameters:

hazelcastInstance - the HazelcastInstance reference

onPingLost

public void onPingLost(Member member)

Description copied from interface: PingAware

Notifies the SplitBrainProtectionFunction of ping loss.

Specified by:

onPingLost in interface PingAware

Parameters:

member - member which was not pinged successfully

onPingRestored

public void onPingRestored(Member member)

Description copied from interface: PingAware

Notifies the SplitBrainProtectionFunction of a successful ping after one or more pings to that member were lost.

Specified by:

onPingRestored in interface PingAware

Parameters:

member - member which was pinged successfully

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

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

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

isAlivePerIcmp

protected boolean isAlivePerIcmp(Member member)