Package org.jgroups.protocols
Class FailureDetection
- java.lang.Object
-
- org.jgroups.stack.Protocol
-
- org.jgroups.protocols.FailureDetection
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FailureDetection.HeartbeatHeader
-
Field Summary
Fields Modifier and Type Field Description protected java.util.function.Predicate<Message>
HAS_HEADER
protected boolean
has_suspected_mbrs
protected java.util.concurrent.Future<?>
heartbeat_sender
protected long
interval
protected Address
local_addr
protected java.util.concurrent.locks.Lock
lock
protected java.util.concurrent.atomic.AtomicBoolean
mcast_sent
protected java.util.List<Address>
members
protected int
num_heartbeats_received
protected int
num_heartbeats_sent
protected int
num_suspect_events
protected BoundedList<Tuple<Address,java.lang.Long>>
suspect_history
protected java.util.Set<Address>
suspected_mbrs
protected long
timeout
protected java.util.concurrent.Future<?>
timeout_checker
protected TimeScheduler
timer
-
Fields inherited from class org.jgroups.stack.Protocol
after_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot
-
-
Constructor Summary
Constructors Constructor Description FailureDetection()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected java.lang.Runnable
createTimeoutChecker()
java.lang.Object
down(Event evt)
An event is to be sent down the stack.java.lang.Object
down(Message msg)
A message is sent down the stack.int
getHeartbeatsReceived()
int
getHeartbeatsSent()
long
getInterval()
java.lang.String
getLocalAddress()
java.lang.String
getMembers()
java.lang.String
getSuspectedMembers()
int
getSuspectEventsSent()
long
getTimeout()
protected abstract java.lang.String
getTimeoutCheckerInfo()
protected abstract long
getTimeoutCheckInterval()
protected abstract java.util.Map<Address,?>
getTimestamps()
protected void
handleViewChange(View v)
void
init()
Called after instance has been created (null constructor) and before protocol is started.boolean
isHeartbeatSenderRunning()
boolean
isRunning()
boolean
isTimeoutCheckerRunning()
protected abstract <T> boolean
needsToBeSuspected(Address mbr, T value)
java.lang.String
printSuspectHistory()
void
resetStats()
protected void
retainKeys(java.util.List<Address> mbrs)
<T extends FailureDetection>
TsetInterval(long i)
<T extends FailureDetection>
TsetTimeout(long t)
void
startFailureDetection()
protected void
startHeartbeatSender()
protected void
startTimeoutChecker()
void
stop()
This method is called on aJChannel.disconnect()
.void
stopFailureDetection()
protected void
stopHeartbeatSender()
protected void
stopTimeoutChecker()
protected void
suspect(java.util.List<Address> suspects)
protected boolean
unsuspect(Address mbr)
Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stackjava.lang.Object
up(Message msg)
A single message was received.void
up(MessageBatch batch)
Sends up a multiple messages in aMessageBatch
.protected abstract void
update(Address sender, boolean log_msg, boolean skip_if_exists)
-
Methods inherited from class org.jgroups.stack.Protocol
accept, afterCreationHook, destroy, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, start, statsEnabled, up
-
-
-
-
Field Detail
-
timeout
protected long timeout
-
interval
protected long interval
-
num_heartbeats_sent
protected int num_heartbeats_sent
-
num_heartbeats_received
protected int num_heartbeats_received
-
num_suspect_events
protected int num_suspect_events
-
has_suspected_mbrs
protected volatile boolean has_suspected_mbrs
-
local_addr
protected Address local_addr
-
members
protected final java.util.List<Address> members
-
suspected_mbrs
protected final java.util.Set<Address> suspected_mbrs
-
suspect_history
protected final BoundedList<Tuple<Address,java.lang.Long>> suspect_history
-
lock
protected final java.util.concurrent.locks.Lock lock
-
timer
protected TimeScheduler timer
-
HAS_HEADER
protected final java.util.function.Predicate<Message> HAS_HEADER
-
heartbeat_sender
protected java.util.concurrent.Future<?> heartbeat_sender
-
timeout_checker
protected java.util.concurrent.Future<?> timeout_checker
-
mcast_sent
protected final java.util.concurrent.atomic.AtomicBoolean mcast_sent
-
-
Method Detail
-
getTimestamps
protected abstract java.util.Map<Address,?> getTimestamps()
-
getTimeoutCheckInterval
protected abstract long getTimeoutCheckInterval()
-
getTimeoutCheckerInfo
protected abstract java.lang.String getTimeoutCheckerInfo()
-
update
protected abstract void update(Address sender, boolean log_msg, boolean skip_if_exists)
-
needsToBeSuspected
protected abstract <T> boolean needsToBeSuspected(Address mbr, T value)
-
getTimeout
public long getTimeout()
-
setTimeout
public <T extends FailureDetection> T setTimeout(long t)
-
getInterval
public long getInterval()
-
setInterval
public <T extends FailureDetection> T setInterval(long i)
-
getHeartbeatsSent
public int getHeartbeatsSent()
-
getHeartbeatsReceived
public int getHeartbeatsReceived()
-
getSuspectEventsSent
public int getSuspectEventsSent()
-
retainKeys
protected void retainKeys(java.util.List<Address> mbrs)
-
createTimeoutChecker
protected java.lang.Runnable createTimeoutChecker()
-
getLocalAddress
public java.lang.String getLocalAddress()
-
getMembers
public java.lang.String getMembers()
-
getSuspectedMembers
public java.lang.String getSuspectedMembers()
-
isRunning
public boolean isRunning()
-
isTimeoutCheckerRunning
public boolean isTimeoutCheckerRunning()
-
isHeartbeatSenderRunning
public boolean isHeartbeatSenderRunning()
-
startFailureDetection
public void startFailureDetection()
-
stopFailureDetection
public void stopFailureDetection()
-
printSuspectHistory
public java.lang.String printSuspectHistory()
-
resetStats
public void resetStats()
- Overrides:
resetStats
in classProtocol
-
init
public void init() throws java.lang.Exception
Description copied from class:Protocol
Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.
-
stop
public void stop()
Description copied from class:Protocol
This method is called on aJChannel.disconnect()
. Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed
-
down
public java.lang.Object down(Event evt)
Description copied from class:Protocol
An event is to be sent down the stack. A protocol may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the protocol may need to add a header to it (or do nothing at all) before sending it down the stack usingdown_prot.down()
.
-
down
public java.lang.Object down(Message msg)
Description copied from class:Protocol
A message is sent down the stack. Protocols may examine the message and do something (e.g. add a header) with it before passing it down.
-
up
public java.lang.Object up(Message msg)
Description copied from class:Protocol
A single message was received. Protocols may examine the message and do something (e.g. add a header) with it before passing it up.
-
up
public void up(MessageBatch batch)
Description copied from class:Protocol
Sends up a multiple messages in aMessageBatch
. The sender of the batch is always the same, and so is the destination (null == multicast messages). Messages in a batch can be OOB messages, regular messages, or mixed messages, although the transport itself will create initial MessageBatches that contain only either OOB or regular messages. The default processing below sends messages up the stack individually, based on a matching criteria (callingProtocol.accept(org.jgroups.Message)
), and - if true - callsProtocol.up(org.jgroups.Event)
for that message and removes the message. If the batch is not empty, it is passed up, or else it is dropped. Subclasses should check if there are any messages destined for them (e.g. usingMessageBatch.getMatchingMessages(short,boolean)
), then possibly remove and process them and finally pass the batch up to the next protocol. Protocols can also modify messages in place, e.g. ENCRYPT could decrypt all encrypted messages in the batch, not remove them, and pass the batch up when done.
-
handleViewChange
protected void handleViewChange(View v)
-
suspect
protected void suspect(java.util.List<Address> suspects)
-
unsuspect
protected boolean unsuspect(Address mbr)
Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack- Parameters:
mbr
- The member to be unsuspected- Returns:
- True if the member was removed from suspected_mbrs, otherwise false
-
startHeartbeatSender
protected void startHeartbeatSender()
-
stopHeartbeatSender
protected void stopHeartbeatSender()
-
startTimeoutChecker
protected void startTimeoutChecker()
-
stopTimeoutChecker
protected void stopTimeoutChecker()
-
-