com.hazelcast.cluster.impl
public abstract class AbstractJoiner extends Object implements Joiner
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Address,Boolean> |
blacklistedAddresses |
protected Config |
config |
protected ILogger |
logger |
protected Node |
node |
Constructor and Description |
---|
AbstractJoiner(Node node) |
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() |
Address |
getTargetAddress() |
boolean |
isBlacklisted(Address address)
Checks if an address is blacklisted.
|
void |
join() |
void |
reset() |
void |
setTargetAddress(Address targetAddress) |
protected void |
startClusterMerge(Address targetAddress) |
boolean |
unblacklist(Address address)
Removes an address from the blacklist if it's temporarily blacklisted.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getType, searchForOtherClusters
protected final ConcurrentMap<Address,Boolean> blacklistedAddresses
protected final Config config
protected final Node node
protected final ILogger logger
public AbstractJoiner(Node node)
public void blacklist(Address address, boolean permanent)
Joiner
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
blacklist
in interface Joiner
address
- the address to blacklist.permanent
- if blacklist is permanent or notJoiner.isBlacklisted(com.hazelcast.nio.Address)
public boolean unblacklist(Address address)
Joiner
Method is thread-safe.
If the address is not blacklisted, the call is ignored.
unblacklist
in interface Joiner
address
- the address to unblacklist.public boolean isBlacklisted(Address address)
Joiner
isBlacklisted
in interface Joiner
address
- the address to check.Joiner.blacklist(com.hazelcast.nio.Address, boolean)
public abstract void doJoin()
protected final long getMaxJoinMillis()
protected final long getMaxJoinTimeToMasterNode()
protected void startClusterMerge(Address targetAddress)
public final long getStartTime()
getStartTime
in interface Joiner
public void setTargetAddress(Address targetAddress)
setTargetAddress
in interface Joiner
public Address getTargetAddress()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.