|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.javagroups.protocols.pbcast.GmsImpl
org.javagroups.protocols.pbcast.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.javagroups.protocols.pbcast.GmsImpl |
gms |
Constructor Summary | |
CoordGmsImpl(GMS g)
|
Method Summary | |
JoinRsp |
handleJoin(Address mbr)
Computes the new view (including the newly joined member) and get the digest from PBCAST. |
void |
handleJoinResponse(JoinRsp join_rsp)
|
void |
handleLeave(Address mbr,
boolean suspected)
Exclude mbr from the membership. |
void |
handleLeaveResponse()
|
void |
handleMergeCancelled(java.lang.Object merge_id)
|
void |
handleMergeRequest(Address sender,
java.lang.Object 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,
java.lang.Object merge_id)
|
void |
handleMergeView(MergeData data,
java.lang.Object merge_id)
If merge_id != this.merge_id --> discard Else cast the view/digest to all members of this group. |
void |
handleSuspect(Address mbr)
|
void |
handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received. |
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.javagroups.protocols.pbcast.GmsImpl |
handleDownEvent, handleUpEvent, init, iWouldBeCoordinator, 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 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, java.lang.Object merge_id)
handleMergeRequest
in class GmsImpl
public void handleMergeResponse(MergeData data, java.lang.Object merge_id)
handleMergeResponse
in class GmsImpl
public void handleMergeView(MergeData data, java.lang.Object merge_id)
handleMergeView
in class GmsImpl
public void handleMergeCancelled(java.lang.Object merge_id)
handleMergeCancelled
in class GmsImpl
public JoinRsp handleJoin(Address mbr)
handleJoin
in class GmsImpl
public void handleLeave(Address mbr, boolean suspected)
mbr
from the membership. If suspected
is true, then
this member crashed and therefore is forced to leave, otherwise it is leaving voluntarily.
handleLeave
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 handleSuspect(Address mbr)
handleSuspect
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 |