Class CoordGmsImpl

java.lang.Object

org.jgroups.protocols.pbcast.GmsImpl

org.jgroups.protocols.pbcast.ServerGmsImpl

org.jgroups.protocols.pbcast.CoordGmsImpl

public class CoordGmsImpl
extends ServerGmsImpl

Coordinator role of the Group MemberShip (GMS) protocol. Accepts JOIN and LEAVE requests and emits view changes accordingly.

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class GmsImpl

GmsImpl.Request

Field Summary

Fields

Modifier and Type	Field	Description
protected static final Long	MAX_SUSPEND_TIMEOUT

Fields inherited from class GmsImpl

gms, leaver, log, merger

Constructor Summary

Constructors

Constructor	Description
CoordGmsImpl(GMS g)

Method Summary

Modifier and Type	Method	Description
MergeId	getMergeId()
void	handleCoordLeave()
void	handleMembershipChange(Collection<GmsImpl.Request> requests)
void	init()
void	join(Address ignored)
void	joinWithStateTransfer(Address ignored)
void	leave()	The coordinator itself wants to leave the group
void	stop()
void	suspect(Address mbr)

Methods inherited from class ServerGmsImpl

coordChanged, handleDigestResponse, handleMergeCancelled, handleMergeRequest, handleMergeResponse, handleMergeView, handleViewChange, merge

Methods inherited from class GmsImpl

handleJoinResponse, handleLeaveResponse, sendMergeRejectedResponse, start, unsuspect, wrongMethod

Methods inherited from class Object

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

Field Details

MAX_SUSPEND_TIMEOUT

protected static final Long MAX_SUSPEND_TIMEOUT

Constructor Details

CoordGmsImpl

public CoordGmsImpl(GMS g)

Method Details

getMergeId

public MergeId getMergeId()

init

public void init()
          throws Exception

Overrides:

init in class ServerGmsImpl

Throws:

Exception

join

public void join(Address ignored)

Specified by:

join in class GmsImpl

joinWithStateTransfer

public void joinWithStateTransfer(Address ignored)

Specified by:

joinWithStateTransfer in class GmsImpl

leave

public void leave()

The coordinator itself wants to leave the group

Specified by:

leave in class GmsImpl

handleCoordLeave

public void handleCoordLeave()

Overrides:

handleCoordLeave in class GmsImpl

suspect

public void suspect(Address mbr)

Overrides:

suspect in class GmsImpl

handleMembershipChange

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

Overrides:

handleMembershipChange in class GmsImpl

stop

public void stop()

Overrides:

stop in class GmsImpl