Package org.jgroups.protocols.pbcast
Class GmsImpl
- java.lang.Object
-
- org.jgroups.protocols.pbcast.GmsImpl
-
- Direct Known Subclasses:
ClientGmsImpl
,ServerGmsImpl
public abstract class GmsImpl extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
GmsImpl.Request
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
handleCoordLeave()
void
handleDigestResponse(Address sender, Digest digest)
void
handleJoinResponse(JoinRsp join_rsp)
void
handleLeaveResponse(Address sender)
void
handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void
handleMergeCancelled(MergeId merge_id)
void
handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
void
handleMergeResponse(MergeData data, MergeId merge_id)
void
handleMergeView(MergeData data, MergeId merge_id)
void
handleViewChange(View new_view, Digest digest)
void
init()
abstract void
join(Address mbr, boolean useFlushIfPresent)
abstract void
joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
abstract void
leave()
void
merge(java.util.Map<Address,View> views)
protected void
sendMergeRejectedResponse(Address sender, MergeId merge_id)
void
start()
void
stop()
void
suspect(Address mbr)
void
unsuspect(Address mbr)
protected void
wrongMethod(java.lang.String method_name)
-
-
-
Constructor Detail
-
GmsImpl
protected GmsImpl(GMS gms)
-
-
Method Detail
-
join
public abstract void join(Address mbr, boolean useFlushIfPresent)
-
joinWithStateTransfer
public abstract void joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
-
leave
public abstract void leave()
-
handleCoordLeave
public void handleCoordLeave()
-
handleJoinResponse
public void handleJoinResponse(JoinRsp join_rsp)
-
handleLeaveResponse
public void handleLeaveResponse(Address sender)
-
suspect
public void suspect(Address mbr)
-
unsuspect
public void unsuspect(Address mbr)
-
handleMergeRequest
public void handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
-
handleMergeCancelled
public void handleMergeCancelled(MergeId merge_id)
-
handleMembershipChange
public void handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
-
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, MergeId merge_id)
-
wrongMethod
protected void wrongMethod(java.lang.String method_name)
-
-