Package org.jgroups.protocols.pbcast

Class ClientGmsImpl

java.lang.Object

org.jgroups.protocols.pbcast.GmsImpl

org.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.

Version:

$Revision: 1.78 $

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.protocols.pbcast.GmsImpl

GmsImpl.Request

Field Summary

Fields

Modifier and Type	Field	Description
protected Promise<JoinRsp>	join_promise

Fields inherited from class org.jgroups.protocols.pbcast.GmsImpl

gms, leaver, log, merger

Constructor Summary

Constructors

Constructor	Description
ClientGmsImpl(GMS g)

Method Summary

Modifier and Type	Method	Description
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)	Makes this process join a group.
void	joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	leave()

Methods inherited from class org.jgroups.protocols.pbcast.GmsImpl

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

Methods inherited from class java.lang.Object

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

Field Detail

join_promise

protected final Promise<JoinRsp> join_promise

Constructor Detail

ClientGmsImpl

public ClientGmsImpl(GMS g)

Method Detail

init

public void init()
          throws java.lang.Exception

Overrides:

init in class GmsImpl

Throws:

java.lang.Exception

join

public void join(Address address,
                 boolean useFlushIfPresent)

Specified by:

join in class GmsImpl

joinWithStateTransfer

public void joinWithStateTransfer(Address local_addr,
                                  boolean useFlushIfPresent)

Specified by:

joinWithStateTransfer in class GmsImpl

joinInternal

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

Makes this process join a group. Determines the coordinator and sends a JOIN request to it. The coordinator returns a JOIN response, then broadcasts the new view, which contains a message digest and the current membership (including the joiner). The joiner then installs the new view and the digest and starts accepting messages.
If successful, impl is changed to an instance of ParticipantGmsImpl. Otherwise, we continue trying to send JOIN requests to the coordinator, until we succeed (or there is no member in the group. In this case, we create our own singleton group).

Parameters:

mbr - Our own address

leave

public void leave()

Specified by:

leave in class GmsImpl

handleJoinResponse

public void handleJoinResponse(JoinRsp join_rsp)

Overrides:

handleJoinResponse in class 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)