com.fr.third.jgroups.protocols.pbcast

类 ParticipantGmsImpl

java.lang.Object

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

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

com.fr.third.jgroups.protocols.pbcast.ParticipantGmsImpl

public class ParticipantGmsImpl
extends ServerGmsImpl

作者:

Bela Ban

嵌套类概要

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

GmsImpl.Request

字段概要

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

gms, log, merger

构造器概要

构造器

构造器和说明
ParticipantGmsImpl(GMS g)

方法概要

方法

限定符和类型	方法和说明
void	handleJoinResponse(JoinRsp join_rsp) In case we get a different JOIN_RSP from a previous JOIN_REQ sent by us (as a client), we simply apply the new view if it is greater than ours
void	handleLeaveResponse()
void	handleMembershipChange(java.util.Collection<GmsImpl.Request> requests)
void	handleViewChange(View new_view, Digest digest) If we are leaving, we have to wait for the view change (last msg in the current view) that excludes us before we can leave.
void	init()
void	join(Address mbr, boolean useFlushIfPresent)
void	joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
void	leave(Address mbr) Loop: determine coord.
void	suspect(Address mbr)
void	unsuspect(Address mbr) Removes previously suspected member from list of currently suspected members

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

handleDigestResponse, handleMergeRequest, handleMergeView

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

handleMergeCancelled, handleMergeResponse, merge, sendMergeRejectedResponse, start, stop, wrongMethod

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

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

构造器详细资料

ParticipantGmsImpl

public ParticipantGmsImpl(GMS g)

方法详细资料

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)

Loop: determine coord. If coord is me --> handleLeave(). Else send handleLeave() to coord until success

指定者:

leave 在类中 GmsImpl

handleJoinResponse

public void handleJoinResponse(JoinRsp join_rsp)

In case we get a different JOIN_RSP from a previous JOIN_REQ sent by us (as a client), we simply apply the new view if it is greater than ours

覆盖:

handleJoinResponse 在类中 GmsImpl

参数:

join_rsp -

handleLeaveResponse

public void handleLeaveResponse()

覆盖:

handleLeaveResponse 在类中 GmsImpl

suspect

public void suspect(Address mbr)

覆盖:

suspect 在类中 GmsImpl

unsuspect

public void unsuspect(Address mbr)

Removes previously suspected member from list of currently suspected members

覆盖:

unsuspect 在类中 GmsImpl

handleMembershipChange

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

覆盖:

handleMembershipChange 在类中 GmsImpl

handleViewChange

public void handleViewChange(View new_view,
                    Digest digest)

If we are leaving, we have to wait for the view change (last msg in the current view) that excludes us before we can leave.

覆盖:

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