org.jgroups.protocols.pbcast

Class ParticipantGmsImpl


public class ParticipantGmsImpl
extends GmsImpl

Field Summary

Fields inherited from class org.jgroups.protocols.pbcast.GmsImpl

gms, log

Constructor Summary

ParticipantGmsImpl(GMS g)

Method Summary

void
handleJoin(Address mbr)
void
handleJoinResponse(JoinRsp join_rsp)
void
handleLeave(Address mbr, boolean suspected)
void
handleLeaveResponse()
void
handleMergeRequest(Address sender, ViewId merge_id)
void
handleSuspect(Address mbr)
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
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

handleDownEvent, handleExit, handleJoin, handleJoinResponse, handleLeave, handleLeaveResponse, handleMergeCancelled, handleMergeRequest, handleMergeResponse, handleMergeView, handleSuspect, handleUpEvent, handleViewChange, iWouldBeCoordinator, init, join, leave, merge, sendMergeRejectedResponse, start, stop, suspect, unsuspect, wrongMethod

Constructor Details

ParticipantGmsImpl

public ParticipantGmsImpl(GMS g)

Method Details

handleJoin

public void handleJoin(Address mbr)
Overrides:
handleJoin in interface GmsImpl

handleJoinResponse

public void handleJoinResponse(JoinRsp join_rsp)
Overrides:
handleJoinResponse in interface GmsImpl

handleLeave

public void handleLeave(Address mbr,
                        boolean suspected)
Overrides:
handleLeave in interface GmsImpl

handleLeaveResponse

public void handleLeaveResponse()
Overrides:
handleLeaveResponse in interface GmsImpl

handleMergeRequest

public void handleMergeRequest(Address sender,
                               ViewId merge_id)
Overrides:
handleMergeRequest in interface GmsImpl

handleSuspect

public void handleSuspect(Address mbr)
Overrides:
handleSuspect in interface GmsImpl

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.
Overrides:
handleViewChange in interface GmsImpl
Parameters:
new_view - The view to be installed
digest - If view is a MergeView, digest contains the seqno digest of all members and has to be set by GMS

init

public void init()
            throws Exception
Overrides:
init in interface GmsImpl

join

public void join(Address mbr)
Overrides:
join in interface GmsImpl

leave

public void leave(Address mbr)
Loop: determine coord. If coord is me --> handleLeave(). Else send handleLeave() to coord until success
Overrides:
leave in interface GmsImpl

suspect

public void suspect(Address mbr)
Overrides:
suspect in interface GmsImpl

unsuspect

public void unsuspect(Address mbr)
Removes previously suspected member from list of currently suspected members
Overrides:
unsuspect in interface GmsImpl

Copyright B) 1998-2005 Bela Ban. All Rights Reserved.