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.

Method Summary

Modifier and Type	Method and Description
void	answerWhoisMasterQuestion(JoinMessage joinMessage, Connection connection) Respond to a WhoisMasterOp.
void	handleJoinRequest(JoinRequest joinRequest, Connection connection) Handle a JoinRequestOp.
void	handleMasterResponse(Address masterAddress, Address callerAddress) Set master address, if required.
boolean	sendJoinRequest(Address toAddress, boolean withCredentials) Send join request to toAddress.
boolean	sendMasterQuestion(Address toAddress) Send a WhoisMasterOp to designated address.
boolean	setThisMemberAsMaster()
SplitBrainJoinMessage.SplitBrainMergeCheckResult	shouldMerge(SplitBrainJoinMessage joinMessage)
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

Method Detail

handleJoinRequest

public void handleJoinRequest(JoinRequest joinRequest,
                              Connection connection)

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

Parameters:

joinRequest - the join request

connection - the connection to the joining node

See Also:

JoinRequestOp

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 - in case any exception occurred while checking compatibilty

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.

setThisMemberAsMaster

public boolean setThisMemberAsMaster()

handleMasterResponse

public void handleMasterResponse(Address masterAddress,
                                 Address callerAddress)

Set master address, if required.

Parameters:

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

callerAddress - address of node that sent the MasterResponseOp

See Also:

MasterResponseOp

sendMasterQuestion

public boolean sendMasterQuestion(Address toAddress)

Send a WhoisMasterOp to designated address.

Parameters:

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

Returns:

true if the operation was sent, otherwise false.

answerWhoisMasterQuestion

public void answerWhoisMasterQuestion(JoinMessage joinMessage,
                                      Connection connection)

Respond to a WhoisMasterOp.

Parameters:

joinMessage - the JoinMessage from the request.

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

See Also:

WhoisMasterOp

shouldMerge

public SplitBrainJoinMessage.SplitBrainMergeCheckResult shouldMerge(SplitBrainJoinMessage joinMessage)