com.fr.third.jgroups.protocols.pbcast

类 CoordGmsImpl

java.lang.Object

com.fr.third.jgroups.protocols.pbcast.GmsImpl

com.fr.third.jgroups.protocols.pbcast.ServerGmsImpl

com.fr.third.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.

作者:

Bela Ban

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.pbcast.GmsImpl

GmsImpl.Request

字段概要

字段

限定符和类型	字段和说明
protected static java.lang.Long	MAX_SUSPEND_TIMEOUT

从类继承的字段 com.fr.third.jgroups.protocols.pbcast.GmsImpl

gms, log, merger

构造器概要

构造器

构造器和说明
CoordGmsImpl(GMS g)

方法概要

方法

限定符和类型	方法和说明
MergeId	getMergeId()
void	handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void	handleMergeCancelled(MergeId merge_id)
void	handleMergeResponse(MergeData data, MergeId merge_id)
void	handleViewChange(View new_view, Digest digest) Called by the GMS when a VIEW is received.
void	init()
void	join(Address mbr, boolean useFlushIfPresent)
void	joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
void	leave(Address mbr) The coordinator itself wants to leave the group
void	merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	stop()
void	suspect(Address mbr)

从类继承的方法 com.fr.third.jgroups.protocols.pbcast.ServerGmsImpl

handleDigestResponse, handleMergeRequest, handleMergeView

从类继承的方法 com.fr.third.jgroups.protocols.pbcast.GmsImpl

handleJoinResponse, handleLeaveResponse, sendMergeRejectedResponse, start, unsuspect, wrongMethod

从类继承的方法 java.lang.Object

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

字段详细资料

MAX_SUSPEND_TIMEOUT

protected static final java.lang.Long MAX_SUSPEND_TIMEOUT

构造器详细资料

CoordGmsImpl

public CoordGmsImpl(GMS g)

方法详细资料

getMergeId

public MergeId getMergeId()

init

public void init()
          throws java.lang.Exception

覆盖:

init 在类中 GmsImpl

抛出:

java.lang.Exception

join

public void join(Address mbr,
        boolean useFlushIfPresent)

指定者:

join 在类中 GmsImpl

joinWithStateTransfer

public void joinWithStateTransfer(Address mbr,
                         boolean useFlushIfPresent)

指定者:

joinWithStateTransfer 在类中 GmsImpl

leave

public void leave(Address mbr)

The coordinator itself wants to leave the group

指定者:

leave 在类中 GmsImpl

suspect

public void suspect(Address mbr)

覆盖:

suspect 在类中 GmsImpl

merge

public void merge(java.util.Map<Address,View> views)

Invoked upon receiving a MERGE event from the MERGE layer. Starts the merge protocol. See description of protocol in DESIGN.

覆盖:

merge 在类中 GmsImpl

参数:

views - A List of different views detected by the merge protocol

handleMergeResponse

public void handleMergeResponse(MergeData data,
                       MergeId merge_id)

覆盖:

handleMergeResponse 在类中 GmsImpl

handleMergeCancelled

public void handleMergeCancelled(MergeId merge_id)

覆盖:

handleMergeCancelled 在类中 GmsImpl

handleMembershipChange

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

覆盖:

handleMembershipChange 在类中 GmsImpl

handleViewChange

public void handleViewChange(View new_view,
                    Digest digest)

Called by the GMS when a VIEW is received.

覆盖:

handleViewChange 在类中 GmsImpl

参数:

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

stop

public void stop()

覆盖:

stop 在类中 GmsImpl