Package org.jgroups.protocols

Class FD_SOCK.BroadcastTask

java.lang.Object
org.jgroups.protocols.FD_SOCK.BroadcastTask
All Implemented Interfaces:
Runnable
Enclosing class:
FD_SOCK
protected class FD_SOCK.BroadcastTask extends Object implements 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.

  • Field Details

    • suspects

      protected final Set<Address> suspects

    • future

      protected Future<?> future

  • Constructor Details

    • BroadcastTask

      protected BroadcastTask()

  • Method Details

    • 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(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 Runnable

    • toString

      public String toString()
      Overrides:
      toString in class Object