Package org.jgroups.protocols.pbcast

Class GmsImpl

java.lang.Object
org.jgroups.protocols.pbcast.GmsImpl
Direct Known Subclasses:
ClientGmsImpl, CoordGmsImpl, ParticipantGmsImpl
public abstract class GmsImpl extends Object

  • Field Details

    • gms

      protected GMS gms

    • log

      protected final org.apache.commons.logging.Log log

  • Constructor Details

    • GmsImpl

      protected GmsImpl()

    • GmsImpl

      protected GmsImpl(GMS gms)

  • Method Details

    • join

      public abstract void join(Address mbr)

    • joinWithStateTransfer

      public abstract void joinWithStateTransfer(Address local_addr)

    • leave

      public abstract void leave(Address mbr)

    • handleJoinResponse

      public abstract void handleJoinResponse(JoinRsp join_rsp)

    • handleLeaveResponse

      public abstract void handleLeaveResponse()

    • suspect

      public abstract void suspect(Address mbr)

    • unsuspect

      public abstract void unsuspect(Address mbr)

    • merge

      public void merge(Vector<Address> other_coords)

    • handleMergeRequest

      public void handleMergeRequest(Address sender, ViewId merge_id)

    • handleMergeResponse

      public void handleMergeResponse(MergeData data, ViewId merge_id)

    • handleMergeView

      public void handleMergeView(MergeData data, ViewId merge_id)

    • handleMergeCancelled

      public void handleMergeCancelled(ViewId merge_id)

    • handleDigestResponse

      public void handleDigestResponse(Address sender, Digest digest)

    • handleMembershipChange

      public abstract void handleMembershipChange(Collection<GmsImpl.Request> requests)

    • handleViewChange

      public abstract void handleViewChange(View new_view, Digest digest)

    • handleExit

      public void handleExit()

    • handleUpEvent

      public boolean handleUpEvent(Event evt)

    • init

      public void init() throws Exception
      Throws:
      Exception

    • start

      public void start() throws Exception
      Throws:
      Exception

    • stop

      public void stop()

    • sendMergeRejectedResponse

      protected void sendMergeRejectedResponse(Address sender, ViewId merge_id)

    • wrongMethod

      protected void wrongMethod(String method_name)

    • iWouldBeCoordinator

      protected boolean iWouldBeCoordinator(Vector new_mbrs)
      Returns potential coordinator based on lexicographic ordering of member addresses. Another approach would be to keep track of the primary partition and return the first member if we are the primary partition.