com.hazelcast.cluster

Class ClusterManager

java.lang.Object

com.hazelcast.impl.BaseManager

com.hazelcast.cluster.ClusterManager

All Implemented Interfaces:

ConnectionListener

public final class ClusterManager
extends BaseManager
implements ConnectionListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ClusterManager.AsyncRemotelyBooleanOp
static class	ClusterManager.AuthenticationFailureProcessable
static class	ClusterManager.MasterConfirmation
class	ClusterManager.NoneMemberAsyncRemotelyBooleanOp

Nested classes/interfaces inherited from class com.hazelcast.impl.BaseManager

BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp

Field Summary

Fields inherited from class com.hazelcast.impl.BaseManager

BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember

Constructor Summary

Constructors

Constructor and Description
ClusterManager(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
MemberImpl	addMember(Address address, NodeType nodeType, String nodeUuid)
Member	addMember(boolean checkServiceThread, MemberImpl member)
Member	addMember(MemberImpl member)
void	appendState(StringBuffer sbState)
boolean	checkAuthorization(String groupName, String groupPassword, Address target)
JoinInfo	checkJoin(Connection conn)
void	checkScheduledActions()
void	connectionAdded(Connection connection)
void	connectionRemoved(Connection connection)
protected MemberImpl	createMember(Address address, NodeType nodeType, String nodeUuid, String ipV6ScopeId)
void	deregisterScheduledAction(ScheduledAction scheduledAction)
void	disconnectExistingCalls(Address deadAddress)
void	finalizeJoin()
MemberImpl	getMember(Address address)
void	handleAddRemoveConnection(AddOrRemoveConnection connection)
void	handleMaster(Master master)
void	heartBeater()
void	invalidateScheduledActionsFor(Address endpoint, Set<Integer> threadIds)
void	logAtMaster(Level level, String msg)
void	onRestart()
void	registerScheduledAction(ScheduledAction scheduledAction)
void	removeMember(MemberImpl member)
void	sendClusterMergeToOthers(Address newTargetAddress)
boolean	sendJoinRequest(Address toAddress, boolean withCredentials)
boolean	shouldTryMerge()
void	stop()
String	toString()

Methods inherited from class com.hazelcast.impl.BaseManager

addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, isMigrating, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterManager

public ClusterManager(Node node)

Method Detail

shouldTryMerge

public boolean shouldTryMerge()

checkJoin

public JoinInfo checkJoin(Connection conn)

appendState

public void appendState(StringBuffer sbState)

logAtMaster

public void logAtMaster(Level level,
               String msg)

heartBeater

public final void heartBeater()

sendClusterMergeToOthers

public void sendClusterMergeToOthers(Address newTargetAddress)

handleMaster

public void handleMaster(Master master)

handleAddRemoveConnection

public void handleAddRemoveConnection(AddOrRemoveConnection connection)

disconnectExistingCalls

public void disconnectExistingCalls(Address deadAddress)

toString

public String toString()

Overrides:

toString in class Object

onRestart

public void onRestart()

checkAuthorization

public boolean checkAuthorization(String groupName,
                         String groupPassword,
                         Address target)

finalizeJoin

public void finalizeJoin()

sendJoinRequest

public boolean sendJoinRequest(Address toAddress,
                      boolean withCredentials)

registerScheduledAction

public void registerScheduledAction(ScheduledAction scheduledAction)

deregisterScheduledAction

public void deregisterScheduledAction(ScheduledAction scheduledAction)

checkScheduledActions

public void checkScheduledActions()

invalidateScheduledActionsFor

public void invalidateScheduledActionsFor(Address endpoint,
                                 Set<Integer> threadIds)

connectionAdded

public void connectionAdded(Connection connection)

Specified by:

connectionAdded in interface ConnectionListener

connectionRemoved

public void connectionRemoved(Connection connection)

Specified by:

connectionRemoved in interface ConnectionListener

addMember

public Member addMember(MemberImpl member)

addMember

public Member addMember(boolean checkServiceThread,
               MemberImpl member)

removeMember

public void removeMember(MemberImpl member)

createMember

protected MemberImpl createMember(Address address,
                      NodeType nodeType,
                      String nodeUuid,
                      String ipV6ScopeId)

getMember

public MemberImpl getMember(Address address)

addMember

public final MemberImpl addMember(Address address,
                   NodeType nodeType,
                   String nodeUuid)

stop

public void stop()