org.jgroups.protocols.pbcast

Class GmsImpl

Known Direct Subclasses:
ClientGmsImpl, CoordGmsImpl, ParticipantGmsImpl

public abstract class GmsImpl
extends java.lang.Object

Field Summary

protected GMS
gms
protected Log
log

Constructor Summary

GmsImpl()
GmsImpl(GMS gms)

Method Summary

boolean
handleDownEvent(Event evt)
void
handleExit()
abstract void
handleJoin(Address mbr)
abstract void
handleJoinResponse(JoinRsp join_rsp)
abstract void
handleLeave(Address mbr, boolean suspected)
abstract void
handleLeaveResponse()
void
handleMergeCancelled(ViewId merge_id)
void
handleMergeRequest(Address sender, ViewId merge_id)
void
handleMergeResponse(MergeData data, ViewId merge_id)
void
handleMergeView(MergeData data, ViewId merge_id)
abstract void
handleSuspect(Address mbr)
boolean
handleUpEvent(Event evt)
abstract void
handleViewChange(View new_view, Digest digest)
protected boolean
iWouldBeCoordinator(Vector new_mbrs)
Returns potential coordinator based on lexicographic ordering of member addresses.
void
init()
abstract void
join(Address mbr)
abstract void
leave(Address mbr)
void
merge(Vector other_coords)
protected void
sendMergeRejectedResponse(Address sender, ViewId merge_id)
void
start()
void
stop()
abstract void
suspect(Address mbr)
abstract void
unsuspect(Address mbr)
protected void
wrongMethod(String method_name)

Field Details

gms

protected GMS gms

log

protected final Log log

Constructor Details

GmsImpl

protected GmsImpl()

GmsImpl

protected GmsImpl(GMS gms)

Method Details

handleDownEvent

public boolean handleDownEvent(Event evt)

handleExit

public void handleExit()

handleJoin

public abstract void handleJoin(Address mbr)

handleJoinResponse

public abstract void handleJoinResponse(JoinRsp join_rsp)

handleLeave

public abstract void handleLeave(Address mbr,
                                 boolean suspected)

handleLeaveResponse

public abstract void handleLeaveResponse()

handleMergeCancelled

public void handleMergeCancelled(ViewId merge_id)

handleMergeRequest

public void handleMergeRequest(Address sender,
                               ViewId merge_id)

handleMergeResponse

public void handleMergeResponse(MergeData data,
                                ViewId merge_id)

handleMergeView

public void handleMergeView(MergeData data,
                            ViewId merge_id)

handleSuspect

public abstract void handleSuspect(Address mbr)

handleUpEvent

public boolean handleUpEvent(Event evt)

handleViewChange

public abstract void handleViewChange(View new_view,
                                      Digest digest)

iWouldBeCoordinator

protected boolean iWouldBeCoordinator(Vector new_mbrs)
Returns potential coordinator based on lexicographic ordering of member addresses. Another approach would be to keep track of the primary partition and return the first member if we are the primary partition.

init

public void init()
            throws Exception

join

public abstract void join(Address mbr)

leave

public abstract void leave(Address mbr)

merge

public void merge(Vector other_coords)

sendMergeRejectedResponse

protected void sendMergeRejectedResponse(Address sender,
                                         ViewId merge_id)

start

public void start()
            throws Exception

stop

public void stop()

suspect

public abstract void suspect(Address mbr)

unsuspect

public abstract void unsuspect(Address mbr)

wrongMethod

protected void wrongMethod(String method_name)

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