com.fr.third.jgroups.protocols.pbcast

类 ClientGmsImpl

java.lang.Object

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

com.fr.third.jgroups.protocols.pbcast.ClientGmsImpl

public class ClientGmsImpl
extends GmsImpl

Client part of GMS. Whenever a new member wants to join a group, it starts in the CLIENT role. No multicasts to the group will be received and processed until the member has been joined and turned into a SERVER (either coordinator or participant, mostly just participant). This class only implements Join (called by clients who want to join a certain group, and ViewChange which is called by the coordinator that was contacted by this client, to tell the client what its initial membership is.

版本:

$Revision: 1.78 $

作者:

Bela Ban

嵌套类概要

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

GmsImpl.Request

字段概要

字段

限定符和类型	字段和说明
protected Promise<JoinRsp>	join_promise

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

gms, log, merger

构造器概要

构造器

构造器和说明
ClientGmsImpl(GMS g)

方法概要

方法

限定符和类型	方法和说明
protected boolean	firstOfAllClients(Address joiner, Responses rsps) Handles the case where no coord responses were received.
void	handleJoinResponse(JoinRsp join_rsp)
void	init()
protected boolean	installViewIfValidJoinRsp(Promise<JoinRsp> join_promise, boolean block_for_rsp)
protected boolean	isJoinResponseValid(JoinRsp rsp)
void	join(Address address, boolean useFlushIfPresent)
protected void	joinInternal(Address mbr, boolean joinWithStateTransfer, boolean useFlushIfPresent) Joins this process to a group.
void	joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	leave(Address mbr)
protected static java.lang.String	print(java.util.List<PingData> rsps)
protected static java.lang.String	print(Responses rsps)

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

handleDigestResponse, handleLeaveResponse, handleMembershipChange, handleMergeCancelled, handleMergeRequest, handleMergeResponse, handleMergeView, handleViewChange, merge, sendMergeRejectedResponse, start, stop, suspect, unsuspect, wrongMethod

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

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

字段详细资料

join_promise

protected final Promise<JoinRsp> join_promise

构造器详细资料

ClientGmsImpl

public ClientGmsImpl(GMS g)

方法详细资料

init

public void init()
          throws java.lang.Exception

覆盖:

init 在类中 GmsImpl

抛出:

java.lang.Exception

join

public void join(Address address,
        boolean useFlushIfPresent)

指定者:

join 在类中 GmsImpl

joinWithStateTransfer

public void joinWithStateTransfer(Address local_addr,
                         boolean useFlushIfPresent)

指定者:

joinWithStateTransfer 在类中 GmsImpl

joinInternal

protected void joinInternal(Address mbr,
                boolean joinWithStateTransfer,
                boolean useFlushIfPresent)

Joins this process to a group. Determines the coordinator and sends a unicast handleJoin() message to it. The coordinator returns a JoinRsp and then broadcasts the new view, which contains a message digest and the current membership (including the joiner). The joiner is then supposed to install the new view and the digest and starts accepting mcast messages. Previous mcast messages were discarded (this is done in PBCAST).

If successful, impl is changed to an instance of ParticipantGmsImpl. Otherwise, we continue trying to send join() messages to the coordinator, until we succeed (or there is no member in the group. In this case, we create our own singleton group).

When GMS.disable_initial_coord is set to true, then we won't become coordinator on receiving an initial membership of 0, but instead will retry (forever) until we get an initial membership of > 0.

参数:

mbr - Our own address (assigned through SET_LOCAL_ADDRESS)

leave

public void leave(Address mbr)

指定者:

leave 在类中 GmsImpl

handleJoinResponse

public void handleJoinResponse(JoinRsp join_rsp)

覆盖:

handleJoinResponse 在类中 GmsImpl

installViewIfValidJoinRsp

protected boolean installViewIfValidJoinRsp(Promise<JoinRsp> join_promise,
                                boolean block_for_rsp)

firstOfAllClients

protected boolean firstOfAllClients(Address joiner,
                        Responses rsps)

Handles the case where no coord responses were received. Returns true if we became the coord (caller needs to terminate the join() call), or false when the caller needs to continue

isJoinResponseValid

protected boolean isJoinResponseValid(JoinRsp rsp)

print

protected static java.lang.String print(java.util.List<PingData> rsps)

print

protected static java.lang.String print(Responses rsps)