Class GmsImpl

    • Field Detail

      • gms

        protected GMS gms
      • log

        protected final org.apache.commons.logging.Log log
    • Constructor Detail

      • GmsImpl

        protected GmsImpl()
      • GmsImpl

        protected GmsImpl​(GMS gms)
    • Method Detail

      • 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​(java.util.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​(java.util.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 java.lang.Exception
        Throws:
        java.lang.Exception
      • start

        public void start()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • stop

        public void stop()
      • sendMergeRejectedResponse

        protected void sendMergeRejectedResponse​(Address sender,
                                                 ViewId merge_id)
      • wrongMethod

        protected void wrongMethod​(java.lang.String method_name)
      • iWouldBeCoordinator

        protected boolean iWouldBeCoordinator​(java.util.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.