Package org.apache.cassandra.gms

Class FailureDetector

java.lang.Object

org.apache.cassandra.gms.FailureDetector

All Implemented Interfaces:

FailureDetectorMBean, IFailureDetector

public class FailureDetector
extends Object
implements IFailureDetector, FailureDetectorMBean

This FailureDetector is an implementation of the paper titled "The Phi Accrual Failure Detector" by Hayashibara. Check the paper and the IFailureDetector interface for details.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final long	INITIAL_VALUE_NANOS
static final IFailureDetector	instance
static final Predicate<InetAddressAndPort>	isEndpointAlive
static final Predicate<Replica>	isReplicaAlive
static final String	MBEAN_NAME

Constructor Summary

Constructors

Constructor	Description
FailureDetector()

Method Summary

Modifier and Type	Method	Description
void	dumpInterArrivalTimes()	Dump the inter arrival times for examination if necessary.
void	forceConviction(InetAddressAndPort ep)	force conviction of endpoint in the failure detector
String	getAllEndpointStates()
String	getAllEndpointStates(boolean withPort)
String	getAllEndpointStates(boolean withPort, boolean resolveIp)
String	getAllEndpointStatesWithPort()
String	getAllEndpointStatesWithPortAndResolveIp()
String	getAllEndpointStatesWithResolveIp()
int	getDownEndpointCount()
String	getEndpointState(String address)
double	getPhiConvictThreshold()
TabularData	getPhiValues()
TabularData	getPhiValuesWithPort()
Map<String,String>	getSimpleStates()
Map<String,String>	getSimpleStatesWithPort()
int	getUpEndpointCount()
void	interpret(InetAddressAndPort ep)	This method is invoked by any entity wanting to interrogate the status of an endpoint.
boolean	isAlive(InetAddressAndPort ep)	Failure Detector's knowledge of whether a node is up or down.
void	registerFailureDetectionEventListener(IFailureDetectionEventListener listener)	Register interest for Failure Detector events.
void	remove(InetAddressAndPort ep)	remove endpoint from failure detector
void	report(InetAddressAndPort ep)	This method is invoked by the receiver of the heartbeat.
void	setPhiConvictThreshold(double phi)
String	toString()
void	unregisterFailureDetectionEventListener(IFailureDetectionEventListener listener)	Un-register interest for Failure Detector events.

Methods inherited from class java.lang.Object

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

Field Details

MBEAN_NAME

public static final String MBEAN_NAME

See Also:

• Constant Field Values

INITIAL_VALUE_NANOS

protected static final long INITIAL_VALUE_NANOS

instance

public static final IFailureDetector instance

isEndpointAlive

public static final Predicate<InetAddressAndPort> isEndpointAlive

isReplicaAlive

public static final Predicate<Replica> isReplicaAlive

Constructor Details

FailureDetector

public FailureDetector()

Method Details

getAllEndpointStates

public String getAllEndpointStates()

Specified by:

getAllEndpointStates in interface FailureDetectorMBean

getAllEndpointStatesWithResolveIp

public String getAllEndpointStatesWithResolveIp()

Specified by:

getAllEndpointStatesWithResolveIp in interface FailureDetectorMBean

getAllEndpointStatesWithPort

public String getAllEndpointStatesWithPort()

Specified by:

getAllEndpointStatesWithPort in interface FailureDetectorMBean

getAllEndpointStatesWithPortAndResolveIp

public String getAllEndpointStatesWithPortAndResolveIp()

Specified by:

getAllEndpointStatesWithPortAndResolveIp in interface FailureDetectorMBean

getAllEndpointStates

public String getAllEndpointStates(boolean withPort)

getAllEndpointStates

public String getAllEndpointStates(boolean withPort,
 boolean resolveIp)

getSimpleStates

public Map<String,String> getSimpleStates()

Specified by:

getSimpleStates in interface FailureDetectorMBean

getSimpleStatesWithPort

public Map<String,String> getSimpleStatesWithPort()

Specified by:

getSimpleStatesWithPort in interface FailureDetectorMBean

getDownEndpointCount

public int getDownEndpointCount()

Specified by:

getDownEndpointCount in interface FailureDetectorMBean

getUpEndpointCount

public int getUpEndpointCount()

Specified by:

getUpEndpointCount in interface FailureDetectorMBean

getPhiValues

public TabularData getPhiValues()
                         throws OpenDataException

Specified by:

getPhiValues in interface FailureDetectorMBean

Throws:

OpenDataException

getPhiValuesWithPort

public TabularData getPhiValuesWithPort()
                                 throws OpenDataException

Specified by:

getPhiValuesWithPort in interface FailureDetectorMBean

Throws:

OpenDataException

getEndpointState

public String getEndpointState(String address)
                        throws UnknownHostException

Specified by:

getEndpointState in interface FailureDetectorMBean

Throws:

UnknownHostException

dumpInterArrivalTimes

public void dumpInterArrivalTimes()

Dump the inter arrival times for examination if necessary.

Specified by:

dumpInterArrivalTimes in interface FailureDetectorMBean

setPhiConvictThreshold

public void setPhiConvictThreshold(double phi)

Specified by:

setPhiConvictThreshold in interface FailureDetectorMBean

getPhiConvictThreshold

public double getPhiConvictThreshold()

Specified by:

getPhiConvictThreshold in interface FailureDetectorMBean

isAlive

public boolean isAlive(InetAddressAndPort ep)

Description copied from interface: IFailureDetector

Failure Detector's knowledge of whether a node is up or down.

Specified by:

isAlive in interface IFailureDetector

Parameters:

ep - endpoint in question.

Returns:

true if UP and false if DOWN.

report

public void report(InetAddressAndPort ep)

Description copied from interface: IFailureDetector

This method is invoked by the receiver of the heartbeat. In our case it would be the Gossiper. Gossiper inform the Failure Detector on receipt of a heartbeat. The FailureDetector will then sample the arrival time as explained in the paper. param ep endpoint being reported.

Specified by:

report in interface IFailureDetector

interpret

public void interpret(InetAddressAndPort ep)

Description copied from interface: IFailureDetector

This method is invoked by any entity wanting to interrogate the status of an endpoint. In our case it would be the Gossiper. The Failure Detector will then calculate Phi and deem an endpoint as suspicious or alive as explained in the Hayashibara paper. param ep endpoint for which we interpret the inter arrival times.

Specified by:

interpret in interface IFailureDetector

forceConviction

public void forceConviction(InetAddressAndPort ep)

Description copied from interface: IFailureDetector

force conviction of endpoint in the failure detector

Specified by:

forceConviction in interface IFailureDetector

remove

public void remove(InetAddressAndPort ep)

Description copied from interface: IFailureDetector

remove endpoint from failure detector

Specified by:

remove in interface IFailureDetector

registerFailureDetectionEventListener

public void registerFailureDetectionEventListener(IFailureDetectionEventListener listener)

Description copied from interface: IFailureDetector

Register interest for Failure Detector events.

Specified by:

registerFailureDetectionEventListener in interface IFailureDetector

Parameters:

listener - implementation of an application provided IFailureDetectionEventListener

unregisterFailureDetectionEventListener

public void unregisterFailureDetectionEventListener(IFailureDetectionEventListener listener)

Description copied from interface: IFailureDetector

Un-register interest for Failure Detector events.

Specified by:

unregisterFailureDetectionEventListener in interface IFailureDetector

Parameters:

listener - implementation of an application provided IFailureDetectionEventListener

toString

public String toString()

Overrides:

toString in class Object