Package org.jgroups.protocols
Class FD.Broadcaster
- java.lang.Object
-
- org.jgroups.protocols.FD.Broadcaster
-
- Enclosing class:
- FD
protected final class FD.Broadcaster extends java.lang.Object
Task that periodically broadcasts a list of suspected members to the group. Goal is not to lose a SUSPECT message: since these are bcast unreliably, they might get dropped. The BroadcastTask makes sure they are retransmitted until a view has been received which doesn't contain the suspected members any longer. Then the task terminates.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.concurrent.Future<?>
bcast_future
protected java.util.concurrent.locks.Lock
bcast_lock
protected java.util.List<Address>
suspected_mbrs
protected FD.BroadcastTask
task
-
Constructor Summary
Constructors Modifier Constructor Description protected
Broadcaster()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addSuspectedMember(Address mbr)
Adds a suspected member.protected java.util.List<Address>
getSuspectedMembers()
protected void
startBroadcastTask(Address suspect)
Starts a new task, or - if already running - adds the argument to the running task.protected void
stopBroadcastTask()
-
-
-
Field Detail
-
suspected_mbrs
protected final java.util.List<Address> suspected_mbrs
-
bcast_lock
protected final java.util.concurrent.locks.Lock bcast_lock
-
bcast_future
protected java.util.concurrent.Future<?> bcast_future
-
task
protected FD.BroadcastTask task
-
-
Method Detail
-
getSuspectedMembers
protected java.util.List<Address> getSuspectedMembers()
-
startBroadcastTask
protected void startBroadcastTask(Address suspect)
Starts a new task, or - if already running - adds the argument to the running task.- Parameters:
suspect
-
-
stopBroadcastTask
protected void stopBroadcastTask()
-
addSuspectedMember
protected void addSuspectedMember(Address mbr)
Adds a suspected member. Starts the task if not yet running
-
-