Package org.jgroups.protocols.pbcast
Class ParticipantGmsImpl
- java.lang.Object
-
- org.jgroups.protocols.pbcast.GmsImpl
-
- org.jgroups.protocols.pbcast.ParticipantGmsImpl
-
public class ParticipantGmsImpl extends GmsImpl
- Version:
- $Id: ParticipantGmsImpl.java,v 1.29.4.1 2009/04/07 09:53:56 belaban Exp $
- Author:
- Bela Ban
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.jgroups.protocols.pbcast.GmsImpl
GmsImpl.Request
-
-
Constructor Summary
Constructors Constructor Description ParticipantGmsImpl(GMS g)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidhandleJoinResponse(JoinRsp join_rsp)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 oursvoidhandleLeaveResponse()voidhandleMembershipChange(java.util.Collection<GmsImpl.Request> requests)voidhandleMergeRequest(Address sender, ViewId merge_id)voidhandleViewChange(View new_view, Digest digest)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.voidinit()voidjoin(Address mbr)voidjoinWithStateTransfer(Address mbr)voidleave(Address mbr)Loop: determine coord.voidsuspect(Address mbr)voidunsuspect(Address mbr)Removes previously suspected member from list of currently suspected members-
Methods inherited from class org.jgroups.protocols.pbcast.GmsImpl
handleDigestResponse, handleExit, handleMergeCancelled, handleMergeResponse, handleMergeView, handleUpEvent, iWouldBeCoordinator, merge, sendMergeRejectedResponse, start, stop, wrongMethod
-
-
-
-
Constructor Detail
-
ParticipantGmsImpl
public ParticipantGmsImpl(GMS g)
-
-
Method Detail
-
init
public void init() throws java.lang.Exception
-
joinWithStateTransfer
public void joinWithStateTransfer(Address mbr)
- Specified by:
joinWithStateTransferin classGmsImpl
-
leave
public void leave(Address mbr)
Loop: determine coord. If coord is me --> handleLeave(). Else send handleLeave() to coord until success
-
handleJoinResponse
public void handleJoinResponse(JoinRsp join_rsp)
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- Specified by:
handleJoinResponsein classGmsImpl- Parameters:
join_rsp-
-
handleLeaveResponse
public void handleLeaveResponse()
- Specified by:
handleLeaveResponsein classGmsImpl
-
unsuspect
public void unsuspect(Address mbr)
Removes previously suspected member from list of currently suspected members
-
handleMembershipChange
public void handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
- Specified by:
handleMembershipChangein classGmsImpl
-
handleViewChange
public void handleViewChange(View new_view, Digest digest)
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.- Specified by:
handleViewChangein classGmsImpl- Parameters:
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 GMS
-
handleMergeRequest
public void handleMergeRequest(Address sender, ViewId merge_id)
- Overrides:
handleMergeRequestin classGmsImpl
-
-