Package org.jgroups.protocols

Class FD_ALL2

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.FailureDetection

org.jgroups.protocols.FD_ALL2

All Implemented Interfaces:

Lifecycle

public class FD_ALL2
extends FailureDetection

Failure detection based on simple heartbeat protocol. Every member periodically (interval ms) multicasts a heartbeat. Every member also maintains a table of all members (minus itself). When data or a heartbeat from P is received, we set the flag associated with P to true. Periodically, we check for expired members, and suspect those whose flag is false (no heartbeat or message received within timeout ms).

Version:

3.5

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.protocols.FailureDetection

FailureDetection.HeartbeatHeader, FailureDetection.HeartbeatSender, FailureDetection.TimeoutChecker

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Address,AtomicBoolean>	timestamps

Fields inherited from class org.jgroups.protocols.FailureDetection

HAS_HEADER, has_suspected_mbrs, heartbeat_sender, interval, lock, mcast_sent, members, num_heartbeats_received, num_heartbeats_sent, num_suspect_events, suspect_history, suspected_mbrs, timeout, timeout_checker, timer

Fields inherited from class org.jgroups.stack.Protocol

after_creation_hook, down_prot, ergonomics, id, local_addr, log, policies, stack, stats, up_prot

Constructor Summary

Constructors

Constructor	Description
FD_ALL2()

Method Summary

Modifier and Type	Method	Description
protected String	_printTimestamps()
protected String	getTimeoutCheckerInfo()
protected long	getTimeoutCheckInterval()
protected Map<Address,?>	getTimestamps()
protected <T> boolean	needsToBeSuspected(Address mbr, T value)
String	printTimestamps()
protected void	update(Address sender, boolean log_msg, boolean skip_if_exists)

Methods inherited from class org.jgroups.protocols.FailureDetection

createTimeoutChecker, down, down, getHeartbeatsReceived, getHeartbeatsSent, getInterval, getMembers, getSuspectedMembers, getSuspectEventsSent, getTimeout, handleViewChange, init, isHeartbeatSenderRunning, isRunning, isTimeoutCheckerRunning, printSuspectHistory, resetStats, retainKeys, setInterval, setTimeout, startFailureDetection, startHeartbeatSender, startTimeoutChecker, stop, stopFailureDetection, stopHeartbeatSender, stopTimeoutChecker, suspect, unsuspect, up, up

Methods inherited from class org.jgroups.stack.Protocol

accept, addPolicy, addr, addr, afterCreationHook, destroy, down, enableStats, getAddress, getComponents, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getPolicies, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, policies, providedDownServices, providedUpServices, removePolicy, requiredDownServices, requiredUpServices, resetStatistics, setAddress, setDownProtocol, setErgonomics, setId, setLevel, setPolicies, setProtocolStack, setSocketFactory, setUpProtocol, setValue, start, statsEnabled, toString, up

Methods inherited from class java.lang.Object

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

Field Details

timestamps

protected final Map<Address,AtomicBoolean> timestamps

Constructor Details

FD_ALL2

public FD_ALL2()

Method Details

getTimestamps

protected Map<Address,?> getTimestamps()

Specified by:

getTimestamps in class FailureDetection

getTimeoutCheckInterval

protected long getTimeoutCheckInterval()

Specified by:

getTimeoutCheckInterval in class FailureDetection

printTimestamps

public String printTimestamps()

update

protected void update(Address sender,
 boolean log_msg,
 boolean skip_if_exists)

Specified by:

update in class FailureDetection

needsToBeSuspected

protected <T> boolean needsToBeSuspected(Address mbr,
 T value)

Specified by:

needsToBeSuspected in class FailureDetection

getTimeoutCheckerInfo

protected String getTimeoutCheckerInfo()

Specified by:

getTimeoutCheckerInfo in class FailureDetection

_printTimestamps

protected String _printTimestamps()