com.hazelcast.quorum.impl

Class AbstractPingAwareQuorumFunction

java.lang.Object

com.hazelcast.quorum.impl.AbstractPingAwareQuorumFunction

All Implemented Interfaces:

HazelcastInstanceAware, PingAware

Direct Known Subclasses:

ProbabilisticQuorumFunction, RecentlyActiveQuorumFunction

public class AbstractPingAwareQuorumFunction
extends Object
implements PingAware, HazelcastInstanceAware

Base class for quorum functions which may use ICMP failure detector information to determine presence of quorum.

Field Summary

Fields

Modifier and Type	Field and Description
protected Cluster	cluster
protected PingFailureDetector<Member>	pingFailureDetector
protected boolean	pingFDEnabled

Constructor Summary

Constructors

Constructor and Description
AbstractPingAwareQuorumFunction()

Method Summary

Modifier and Type	Method and Description
protected boolean	isAlivePerIcmp(Member member)
void	onPingLost(Member member) Notifies the QuorumFunction of ping loss.
void	onPingRestored(Member member) Notifies the QuorumFunction 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

Field Detail

pingFDEnabled

protected boolean pingFDEnabled

pingFailureDetector

protected PingFailureDetector<Member> pingFailureDetector

cluster

protected Cluster cluster

Constructor Detail

AbstractPingAwareQuorumFunction

public AbstractPingAwareQuorumFunction()

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 QuorumFunction 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 QuorumFunction 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

isAlivePerIcmp

protected boolean isAlivePerIcmp(Member member)