com.fr.third.jgroups.protocols

类 FD.Broadcaster

java.lang.Object

com.fr.third.jgroups.protocols.FD.Broadcaster

封闭类:

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.

字段概要

字段

限定符和类型	字段和说明
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

构造器概要

构造器

限定符	构造器和说明
protected	FD.Broadcaster()

方法概要

方法

限定符和类型	方法和说明
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()

从类继承的方法 java.lang.Object

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

字段详细资料

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

构造器详细资料

FD.Broadcaster

protected FD.Broadcaster()

方法详细资料

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.

参数:

suspect -

stopBroadcastTask

protected void stopBroadcastTask()

addSuspectedMember

protected void addSuspectedMember(Address mbr)

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