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 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
handleDigestResponse(Address sender, Digest digest)
void
handleExit()
abstract void
handleJoinResponse(JoinRsp join_rsp)
abstract void
handleLeaveResponse()
abstract void
handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void
handleMergeCancelled(ViewId merge_id)
void
handleMergeRequest(Address sender, ViewId merge_id)
void
handleMergeResponse(MergeData data, ViewId merge_id)
void
handleMergeView(MergeData data, ViewId merge_id)
boolean
handleUpEvent(Event evt)
abstract void
handleViewChange(View new_view, Digest digest)
void
init()
protected boolean
iWouldBeCoordinator(java.util.Vector new_mbrs)
Returns potential coordinator based on lexicographic ordering of member addresses.abstract void
join(Address mbr)
abstract void
joinWithStateTransfer(Address local_addr)
abstract void
leave(Address mbr)
void
merge(java.util.Vector<Address> other_coords)
protected void
sendMergeRejectedResponse(Address sender, ViewId merge_id)
void
start()
void
stop()
abstract void
suspect(Address mbr)
abstract void
unsuspect(Address mbr)
protected void
wrongMethod(java.lang.String method_name)
-
-
-
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)
-
handleMergeCancelled
public void handleMergeCancelled(ViewId merge_id)
-
handleMembershipChange
public abstract void handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
-
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.
-
-