org.jgroups.protocols

Class FD.Broadcaster

java.lang.Object

org.jgroups.protocols.FD.Broadcaster

Enclosing class:

FD

protected final class FD.Broadcaster
extends 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 and Description
protected Future<?>	bcast_future
protected Lock	bcast_lock
protected List<Address>	suspected_mbrs
protected FD.BroadcastTask	task

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Broadcaster()

Method Summary

Modifier and Type	Method and Description
protected void	addSuspectedMember(Address mbr) Adds a suspected member.
protected 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 List<Address> suspected_mbrs

bcast_lock

protected final Lock bcast_lock

bcast_future

protected Future<?> bcast_future

task

protected FD.BroadcastTask task

Constructor Detail

Broadcaster

protected Broadcaster()

Method Detail

getSuspectedMembers

protected 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