|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jgroups.protocols.pbcast.GmsImpl
org.jgroups.protocols.pbcast.CoordGmsImpl
public class CoordGmsImpl
Coordinator role of the Group MemberShip (GMS) protocol. Accepts JOIN and LEAVE requests and emits view changes accordingly.
Field Summary |
---|
Fields inherited from class org.jgroups.protocols.pbcast.GmsImpl |
---|
gms, log |
Constructor Summary | |
---|---|
CoordGmsImpl(GMS g)
|
Method Summary | |
---|---|
void |
handleExit()
|
void |
handleJoinResponse(JoinRsp join_rsp)
|
void |
handleLeaveResponse()
|
void |
handleMembershipChange(java.util.Collection new_mbrs,
java.util.Collection leaving_mbrs,
java.util.Collection suspected_mbrs)
Exclude mbr from the membership. |
void |
handleMergeCancelled(ViewId merge_id)
|
void |
handleMergeRequest(Address sender,
ViewId merge_id)
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. |
void |
handleMergeResponse(MergeData data,
ViewId merge_id)
|
void |
handleMergeView(MergeData data,
ViewId merge_id)
If merge_id is not equal to this.merge_id then discard. |
void |
handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received. |
void |
init()
|
void |
join(Address mbr)
|
void |
leave(Address mbr)
The coordinator itself wants to leave the group |
void |
merge(java.util.Vector other_coords)
Invoked upon receiving a MERGE event from the MERGE layer. |
void |
stop()
|
void |
suspect(Address mbr)
|
void |
unsuspect(Address mbr)
|
Methods inherited from class org.jgroups.protocols.pbcast.GmsImpl |
---|
handleUpEvent, iWouldBeCoordinator, sendMergeRejectedResponse, start, wrongMethod |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CoordGmsImpl(GMS g)
Method Detail |
---|
public void init() throws java.lang.Exception
init
in class GmsImpl
java.lang.Exception
public void join(Address mbr)
join
in class GmsImpl
public void leave(Address mbr)
leave
in class GmsImpl
public void handleJoinResponse(JoinRsp join_rsp)
handleJoinResponse
in class GmsImpl
public void handleLeaveResponse()
handleLeaveResponse
in class GmsImpl
public void suspect(Address mbr)
suspect
in class GmsImpl
public void unsuspect(Address mbr)
unsuspect
in class GmsImpl
public void merge(java.util.Vector other_coords)
merge
in class GmsImpl
other_coords
- A list of coordinators (including myself) found by MERGE protocolpublic void handleMergeRequest(Address sender, ViewId merge_id)
handleMergeRequest
in class GmsImpl
public void handleMergeResponse(MergeData data, ViewId merge_id)
handleMergeResponse
in class GmsImpl
public void handleMergeView(MergeData data, ViewId merge_id)
handleMergeView
in class GmsImpl
public void handleMergeCancelled(ViewId merge_id)
handleMergeCancelled
in class GmsImpl
public void handleMembershipChange(java.util.Collection new_mbrs, java.util.Collection leaving_mbrs, java.util.Collection suspected_mbrs)
mbr
from the membership. If suspected
is true, then
this member crashed and therefore is forced to leave, otherwise it is leaving voluntarily.
handleMembershipChange
in class GmsImpl
public void handleViewChange(View new_view, Digest digest)
handleViewChange
in class GmsImpl
new_view
- The view to be installeddigest
- If view is a MergeView, digest contains the seqno digest of all members and has to
be set by GMSpublic void handleExit()
handleExit
in class GmsImpl
public void stop()
stop
in class GmsImpl
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |