com.hazelcast.internal.cluster.impl

Class ClusterJoinManager

java.lang.Object

com.hazelcast.internal.cluster.impl.ClusterJoinManager

public class ClusterJoinManager
extends Object

ClusterJoinManager manages member join process.

If this node is not master, then it will answer with sending master node's address to a join request.

If this is master node, it will handle join request and notify all other members about newly joined member.

Constructor Summary

Constructors

Constructor and Description
ClusterJoinManager(Node node, ClusterServiceImpl clusterService, Lock clusterServiceLock)

Method Summary

Modifier and Type	Method and Description
void	answerMasterQuestion(JoinMessage joinMessage, Connection connection) Respond to a MasterDiscoveryOperation.
void	handleJoinRequest(JoinRequest joinRequest, Connection connection) Handle a JoinRequestOperation: If this node is not master, reply with a SetMasterOperation to let the joining node know the current master Otherwise, if no other join is in progress, execute the JoinRequest
boolean	isJoinInProgress()
boolean	sendJoinRequest(Address toAddress, boolean withCredentials) Send join request to toAddress.
boolean	sendMasterQuestion(Address toAddress) Send a MasterDiscoveryOperation to designated address.
void	setMaster(Address masterAddress, Address callerAddress) Set master address, if required.
boolean	validateJoinMessage(JoinMessage joinMessage) Validate that the configuration received from the remote node in joinMessage is compatible with the configuration of this node.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterJoinManager

public ClusterJoinManager(Node node,
                          ClusterServiceImpl clusterService,
                          Lock clusterServiceLock)

Method Detail

isJoinInProgress

public boolean isJoinInProgress()

handleJoinRequest

public void handleJoinRequest(JoinRequest joinRequest,
                              Connection connection)

Handle a JoinRequestOperation:

• If this node is not master, reply with a SetMasterOperation to let the joining node know the current master
• Otherwise, if no other join is in progress, execute the JoinRequest

Parameters:

joinRequest -

connection -

See Also:

JoinRequestOperation

validateJoinMessage

public boolean validateJoinMessage(JoinMessage joinMessage)
                            throws Exception

Validate that the configuration received from the remote node in joinMessage is compatible with the configuration of this node.

Parameters:

joinMessage - the JoinMessage received from another node.

Returns:

true if packet version of join message matches this node's packet version and configurations are found to be compatible, otherwise false.

Throws:

Exception

See Also:

ConfigCheck

sendJoinRequest

public boolean sendJoinRequest(Address toAddress,
                               boolean withCredentials)

Send join request to toAddress.

Parameters:

toAddress - the currently known master address.

withCredentials - use cluster credentials

Returns:

true if join request was sent successfully, otherwise false.

setMaster

public void setMaster(Address masterAddress,
                      Address callerAddress)

Set master address, if required.

Parameters:

masterAddress - address of cluster's master, as provided in SetMasterOperation

callerAddress - address of node that sent the SetMasterOperation

See Also:

SetMasterOperation

sendMasterQuestion

public boolean sendMasterQuestion(Address toAddress)

Send a MasterDiscoveryOperation to designated address.

Parameters:

toAddress - the address to which the operation will be sent.

Returns:

true if the operation was sent, otherwise false.

answerMasterQuestion

public void answerMasterQuestion(JoinMessage joinMessage,
                                 Connection connection)

Respond to a MasterDiscoveryOperation.

Parameters:

joinMessage - the JoinMessage from the request.

connection - the connection to operation caller, to which response will be sent.

See Also:

MasterDiscoveryOperation