Package org.jgroups.protocols.pbcast

Class GmsImpl

java.lang.Object

org.jgroups.protocols.pbcast.GmsImpl

Direct Known Subclasses:

ClientGmsImpl, CoordGmsImpl, ParticipantGmsImpl

public abstract class GmsImpl
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GmsImpl.Request

Field Summary

Fields

Modifier and Type	Field	Description
protected GMS	gms
protected org.apache.commons.logging.Log	log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GmsImpl()
protected	GmsImpl(GMS gms)

Method Summary

Modifier and Type	Method	Description
void	handleDigestResponse(Address sender, Digest digest)
void	handleExit()
abstract void	handleJoinResponse(JoinRsp join_rsp)
abstract void	handleLeaveResponse()
abstract void	handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
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)
boolean	handleUpEvent(Event evt)
abstract void	handleViewChange(View new_view, Digest digest)
void	init()
protected boolean	iWouldBeCoordinator(java.util.Vector new_mbrs)	Returns potential coordinator based on lexicographic ordering of member addresses.
abstract void	join(Address mbr)
abstract void	joinWithStateTransfer(Address local_addr)
abstract void	leave(Address mbr)
void	merge(java.util.Vector<Address> 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(java.lang.String method_name)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

gms

protected GMS gms

log

protected final org.apache.commons.logging.Log log

Constructor Detail

GmsImpl

protected GmsImpl()

GmsImpl

protected GmsImpl(GMS gms)

Method Detail

join

public abstract void join(Address mbr)

joinWithStateTransfer

public abstract void joinWithStateTransfer(Address local_addr)

leave

public abstract void leave(Address mbr)

handleJoinResponse

public abstract void handleJoinResponse(JoinRsp join_rsp)

handleLeaveResponse

public abstract void handleLeaveResponse()

suspect

public abstract void suspect(Address mbr)

unsuspect

public abstract void unsuspect(Address mbr)

merge

public void merge(java.util.Vector<Address> other_coords)

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)

handleMergeCancelled

public void handleMergeCancelled(ViewId merge_id)

handleDigestResponse

public void handleDigestResponse(Address sender,
                                 Digest digest)

handleMembershipChange

public abstract void handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)

handleViewChange

public abstract void handleViewChange(View new_view,
                                      Digest digest)

handleExit

public void handleExit()

handleUpEvent

public boolean handleUpEvent(Event evt)

init

public void init()
          throws java.lang.Exception

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()

sendMergeRejectedResponse

protected void sendMergeRejectedResponse(Address sender,
                                         ViewId merge_id)

wrongMethod

protected void wrongMethod(java.lang.String method_name)

iWouldBeCoordinator

protected boolean iWouldBeCoordinator(java.util.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.