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

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

protected

FD.Broadcaster()

Method Summary

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()

Methods inherited from class java.lang.Object

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

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

Constructor Detail

FD.Broadcaster

protected FD.Broadcaster()

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