Package org.jgroups.protocols.pbcast
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 org.jgroups.protocols.pbcast.GmsImpl
GmsImpl.Request
-
-
Constructor Summary
Constructors Constructor Description CoordGmsImpl(GMS g)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MergeId
getMergeId()
void
handleCoordLeave()
void
handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void
init()
void
join(Address ignored)
void
joinWithStateTransfer(Address ignored)
void
leave()
The coordinator itself wants to leave the groupvoid
stop()
void
suspect(Address mbr)
-
Methods inherited from class org.jgroups.protocols.pbcast.ServerGmsImpl
coordChanged, handleDigestResponse, handleMergeCancelled, handleMergeRequest, handleMergeResponse, handleMergeView, handleViewChange, merge
-
Methods inherited from class org.jgroups.protocols.pbcast.GmsImpl
handleJoinResponse, handleLeaveResponse, sendMergeRejectedResponse, start, unsuspect, wrongMethod
-
-
-
-
Constructor Detail
-
CoordGmsImpl
public CoordGmsImpl(GMS g)
-
-
Method Detail
-
getMergeId
public MergeId getMergeId()
-
init
public void init() throws java.lang.Exception
- Overrides:
init
in classServerGmsImpl
- Throws:
java.lang.Exception
-
joinWithStateTransfer
public void joinWithStateTransfer(Address ignored)
- Specified by:
joinWithStateTransfer
in classGmsImpl
-
leave
public void leave()
The coordinator itself wants to leave the group
-
handleCoordLeave
public void handleCoordLeave()
- Overrides:
handleCoordLeave
in classGmsImpl
-
handleMembershipChange
public void handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
- Overrides:
handleMembershipChange
in classGmsImpl
-
-