| java.lang.Object
 org.jgroups.protocols.pbcast.GmsImpl
org.jgroups.protocols.pbcast.CoordGmsImpl
| CoordGmsImpl | | public class CoordGmsImpl extends GmsImpl (Code) | | Coordinator role of the Group MemberShip (GMS) protocol. Accepts JOIN and LEAVE requests and emits view changes
accordingly.
author:
Bela Ban |
| handleExit | | public void handleExit()(Code) | | |
| handleJoinResponse | | public void handleJoinResponse(JoinRsp join_rsp)(Code) | | |
| handleLeaveResponse | | public void handleLeaveResponse()(Code) | | |
| handleMembershipChange | | public void handleMembershipChange(Collection new_mbrs, Collection leaving_mbrs, Collection suspected_mbrs)(Code) | | Exclude mbr from the membership. If suspected is true, then
this member crashed and therefore is forced to leave, otherwise it is leaving voluntarily.
|
| handleMergeCancelled | | public void handleMergeCancelled(ViewId merge_id)(Code) | | |
| handleMergeRequest | | public void handleMergeRequest(Address sender, ViewId merge_id)(Code) | | Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
If a merge is already in progress, send back a MergeData with the merge_rejected field set to true.
|
| handleMergeView | | public void handleMergeView(MergeData data, ViewId merge_id)(Code) | | If merge_id is not equal to this.merge_id then discard.
Else cast the view/digest to all members of this group.
|
| handleViewChange | | public void handleViewChange(View new_view, Digest digest)(Code) | | Called by the GMS when a VIEW is received.
Parameters:
new_view - The view to be installed
Parameters:
digest - If view is a MergeView, digest contains the seqno digest of all members and has tobe set by GMS |
| leave | | public void leave(Address mbr)(Code) | | The coordinator itself wants to leave the group
|
| merge | | public void merge(Vector other_coords)(Code) | | Invoked upon receiving a MERGE event from the MERGE layer. Starts the merge protocol.
See description of protocol in DESIGN.
Parameters:
other_coords - A list of coordinators (including myself) found by MERGE protocol |
| stopMergeTask | | void stopMergeTask()(Code) | | |
|
|