com.hazelcast.internal.cluster.impl

Class AbstractJoiner

java.lang.Object

com.hazelcast.internal.cluster.impl.AbstractJoiner

All Implemented Interfaces:

Joiner

Direct Known Subclasses:

MulticastJoiner, TcpIpJoiner

public abstract class AbstractJoiner
extends Object
implements Joiner

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<Address,Boolean>	blacklistedAddresses
protected ClusterJoinManager	clusterJoinManager
protected ClusterServiceImpl	clusterService
protected Config	config
protected ILogger	logger
protected Node	node

Constructor Summary

Constructors

Constructor and Description
AbstractJoiner(Node node)

Method Summary

Modifier and Type	Method and Description
void	blacklist(Address address, boolean permanent) Adds an address to the blacklist.
abstract void	doJoin()
protected long	getMaxJoinMillis()
protected long	getMaxJoinTimeToMasterNode()
long	getStartTime()
protected Address	getTargetAddress()
boolean	isBlacklisted(Address address) Checks if an address is blacklisted.
void	join()
void	reset()
protected SplitBrainJoinMessage.SplitBrainMergeCheckResult	sendSplitBrainJoinMessageAndCheckResponse(Address target, SplitBrainJoinMessage request) Sends a split brain join request to the target address and checks the response to see if this node should merge to the target address.
void	setTargetAddress(Address targetAddress)
protected boolean	shouldRetry()
protected void	startClusterMerge(Address targetAddress, int expectedMemberListVersion)
boolean	unblacklist(Address address) Removes an address from the blacklist if it is temporarily blacklisted.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cluster.Joiner

getType, searchForOtherClusters

Field Detail

config

protected final Config config

node

protected final Node node

clusterService

protected final ClusterServiceImpl clusterService

logger

protected final ILogger logger

blacklistedAddresses

protected final ConcurrentMap<Address,Boolean> blacklistedAddresses

clusterJoinManager

protected final ClusterJoinManager clusterJoinManager

Constructor Detail

AbstractJoiner

public AbstractJoiner(Node node)

Method Detail

getStartTime

public final long getStartTime()

Specified by:

getStartTime in interface Joiner

setTargetAddress

public void setTargetAddress(Address targetAddress)

Specified by:

setTargetAddress in interface Joiner

blacklist

public void blacklist(Address address,
                      boolean permanent)

Description copied from interface: Joiner

Adds an address to the blacklist. Blacklist is useful if a node should ignore another node, e.g. when the groupname of 2 machines is not the same and they should form different clusters.

If blacklist is permanent, then this operation is write-once. It cannot be unblacklisted again. If blacklist is temporary, blacklist can be removed via Joiner.unblacklist(com.hazelcast.nio.Address).

Method is thread-safe.

If the address already is blacklisted, the call is ignored

Specified by:

blacklist in interface Joiner

Parameters:

address - the address to blacklist.

permanent - true if blacklist is permanent, false if not.

See Also:

Joiner.isBlacklisted(com.hazelcast.nio.Address)

unblacklist

public boolean unblacklist(Address address)

Description copied from interface: Joiner

Removes an address from the blacklist if it is temporarily blacklisted. This method has no effect if given address is not blacklisted. Permanent blacklists cannot be undone.

Method is thread-safe.

If the address is not blacklisted, the call is ignored.

Specified by:

unblacklist in interface Joiner

Parameters:

address - the address to unblacklist.

Returns:

true if address is unblacklisted, false otherwise.

isBlacklisted

public boolean isBlacklisted(Address address)

Description copied from interface: Joiner

Checks if an address is blacklisted. Method is thread-safe.

Specified by:

isBlacklisted in interface Joiner

Parameters:

address - the address to check.

Returns:

true if blacklisted, false otherwise.

See Also:

Joiner.blacklist(com.hazelcast.nio.Address, boolean)

doJoin

public abstract void doJoin()

join

public final void join()

Specified by:

join in interface Joiner

shouldRetry

protected final boolean shouldRetry()

getMaxJoinMillis

protected final long getMaxJoinMillis()

getMaxJoinTimeToMasterNode

protected final long getMaxJoinTimeToMasterNode()

sendSplitBrainJoinMessageAndCheckResponse

protected final SplitBrainJoinMessage.SplitBrainMergeCheckResult sendSplitBrainJoinMessageAndCheckResponse(Address target,
                                                                                                           SplitBrainJoinMessage request)

Sends a split brain join request to the target address and checks the response to see if this node should merge to the target address.

reset

public void reset()

Specified by:

reset in interface Joiner

startClusterMerge

protected void startClusterMerge(Address targetAddress,
                                 int expectedMemberListVersion)

getTargetAddress

protected Address getTargetAddress()