Package org.jgroups.protocols.pbcast

Class ParticipantGmsImpl

java.lang.Object
org.jgroups.protocols.pbcast.GmsImpl
org.jgroups.protocols.pbcast.ServerGmsImpl
org.jgroups.protocols.pbcast.ParticipantGmsImpl
public class ParticipantGmsImpl extends ServerGmsImpl
Author:
Bela Ban

  • Constructor Details

    • ParticipantGmsImpl

      public ParticipantGmsImpl(GMS g)

  • Method Details

    • init

      public void init() throws Exception
      Overrides:
      init in class GmsImpl
      Throws:
      Exception

    • join

      public void join(Address mbr, boolean useFlushIfPresent)
      Specified by:
      join in class GmsImpl

    • joinWithStateTransfer

      public void joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
      Specified by:
      joinWithStateTransfer in class GmsImpl

    • leave

      public void leave(Address mbr)
      Loop: determine coord. If coord is me --> handleLeave(). Else send handleLeave() to coord until success
      Specified by:
      leave in class GmsImpl

    • handleJoinResponse

      public void handleJoinResponse(JoinRsp join_rsp)
      In case we get a different JOIN_RSP from a previous JOIN_REQ sent by us (as a client), we simply apply the new view if it is greater than ours
      Overrides:
      handleJoinResponse in class GmsImpl
      Parameters:
      join_rsp -

    • handleLeaveResponse

      public void handleLeaveResponse()
      Overrides:
      handleLeaveResponse in class GmsImpl

    • suspect

      public void suspect(Address mbr)
      Overrides:
      suspect in class GmsImpl

    • unsuspect

      public void unsuspect(Address mbr)
      Removes previously suspected member from list of currently suspected members
      Overrides:
      unsuspect in class GmsImpl

    • handleMembershipChange

      public void handleMembershipChange(Collection<GmsImpl.Request> requests)
      Overrides:
      handleMembershipChange in class GmsImpl

    • handleViewChange

      public void handleViewChange(View new_view, Digest digest)
      If we are leaving, we have to wait for the view change (last msg in the current view) that excludes us before we can leave.
      Overrides:
      handleViewChange in class GmsImpl
      Parameters:
      new_view - The view to be installed
      digest - If view is a MergeView, digest contains the seqno digest of all members and has to be set by GMS