| java.lang.Object
 org.jgroups.protocols.pbcast.GmsImpl
org.jgroups.protocols.pbcast.ParticipantGmsImpl
| ParticipantGmsImpl | | public class ParticipantGmsImpl extends GmsImpl (Code) | | |
| ParticipantGmsImpl | | public ParticipantGmsImpl(GMS g)(Code) | | |
| handleJoinResponse | | public void handleJoinResponse(JoinRsp join_rsp)(Code) | | In case we get a different JOIN_RSP from a previous JOIN_REQ sent by us (as a client), we simply apply the
new view if it is greater than ours
Parameters:
join_rsp - |
| handleLeaveResponse | | public void handleLeaveResponse()(Code) | | |
| handleViewChange | | public void handleViewChange(View new_view, Digest digest)(Code) | | If we are leaving, we have to wait for the view change (last msg in the current view) that
excludes us before we can leave.
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) | | Loop: determine coord. If coord is me --> handleLeave().
Else send handleLeave() to coord until success
|
| unsuspect | | public void unsuspect(Address mbr)(Code) | | Removes previously suspected member from list of currently suspected members
|
| wouldIBeCoordinator | | boolean wouldIBeCoordinator()(Code) | | Determines whether this member is the new coordinator given a list of suspected members. This is
computed as follows: the list of currently suspected members (suspected_mbrs) is removed from the current
membership. If the first member of the resulting list is equals to the local_addr, then it is true,
otherwise false. Example: own address is B, current membership is {A, B, C, D}, suspected members are {A,
D}. The resulting list is {B, C}. The first member of {B, C} is B, which is equal to the
local_addr. Therefore, true is returned.
|
|
|