org.jgroups.protocols

Class FD_SOCK.BroadcastTask

java.lang.Object

org.jgroups.protocols.FD_SOCK.BroadcastTask

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

FD_SOCK

protected class FD_SOCK.BroadcastTask
extends java.lang.Object
implements java.lang.Runnable

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.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BroadcastTask()

Method Summary

Modifier and Type	Method and Description
protected void	addSuspectedMember(Address mbr) Adds a suspected member.
protected void	adjustSuspectedMembers(java.util.List<Address> new_mbrship) Removes all elements from suspected_mbrs that are not in the new membership
protected void	removeAll()
protected void	removeSuspectedMember(Address suspected_mbr)
void	run()
protected void	startTask()
protected void	stopTask()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastTask

protected BroadcastTask()

Method Detail

addSuspectedMember

protected void addSuspectedMember(Address mbr)

Adds a suspected member. Starts the task if not yet running

removeSuspectedMember

protected void removeSuspectedMember(Address suspected_mbr)

removeAll

protected void removeAll()

startTask

protected void startTask()

stopTask

protected void stopTask()

adjustSuspectedMembers

protected void adjustSuspectedMembers(java.util.List<Address> new_mbrship)

Removes all elements from suspected_mbrs that are not in the new membership

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object