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 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 oursvoid
handleLeaveResponse()
void
handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void
handleMergeRequest(Address sender, ViewId merge_id)
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.void
init()
void
join(Address mbr)
void
joinWithStateTransfer(Address mbr)
void
leave(Address mbr)
Loop: determine coord.void
suspect(Address mbr)
void
unsuspect(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:
joinWithStateTransfer
in 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:
handleJoinResponse
in classGmsImpl
- Parameters:
join_rsp
-
-
handleLeaveResponse
public void handleLeaveResponse()
- Specified by:
handleLeaveResponse
in 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:
handleMembershipChange
in 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:
handleViewChange
in 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:
handleMergeRequest
in classGmsImpl
-
-