Package com.orientechnologies.orient.server.distributed.impl

Class ODistributedPlugin

java.lang.Object

com.orientechnologies.orient.server.plugin.OServerPluginAbstract

com.orientechnologies.orient.server.distributed.impl.ODistributedPlugin

All Implemented Interfaces:

OService, ODistributedServerManager, OServerPlugin

Direct Known Subclasses:

OHazelcastPlugin

public class ODistributedPlugin
extends OServerPluginAbstract
implements ODistributedServerManager

Plugin to manage the distributed environment.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

ODistributedServerManager.DB_STATUS

Field Summary

Fields

Modifier and Type	Field	Description
protected File	defaultDatabaseConfigFile
protected static final int	DEPLOY_DB_MAX_RETRIES
protected Set<String>	installingDatabases
protected List<ODistributedLifecycleListener>	listeners
protected AtomicLong	localMessageIdCounter
protected ODistributedMessageServiceImpl	messageService
protected static final String	NODE_NAME_ENV
protected static final String	PAR_DEF_DISTRIB_DB_CONFIG
protected ORemoteServerManager	remoteServerManager
static final String	REPLICATOR_USER
protected ODistributedStrategy	responseManagerFactory
protected CountDownLatch	serverStarted
protected OSignalHandler.OSignalListener	signalListener
protected Date	startedOn
protected ORemoteTaskFactoryManager	taskFactoryManager

Fields inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract

enabled

Fields inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

FILE_DISTRIBUTED_DB_CONFIG

Constructor Summary

Constructors

Constructor	Description
ODistributedPlugin()

Method Summary

Modifier and Type	Method	Description
protected void	assignNodeName()
protected void	backupCurrentDatabase(String iDatabaseName)
protected int	calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType, ODistributedConfiguration cfg, int totalServers, int totalMasterServers, int onlineMasters, boolean checkNodesAreOnline, String localNodeName)
protected void	checkForServerOnline(ODistributedRequest iRequest)
void	checkNodeInConfiguration(String databaseName, ODistributedConfiguration cfg)
void	closeRemoteServer(String node)
void	config(OServer oServer, OServerParameterConfiguration[] iParams)	Configures the handler.
void	connectToAllNodes(Set<String> clusterNodes)
void	dropConfig(String dbName)
void	dropOnAllServers(String dbName)
void	dumpServersStatus()	Avoids to dump the same configuration twice if it's unchanged since the last time.
protected void	dumpStats()
<T> T	executeInDistributedDatabaseLock(String databaseName, long timeoutLocking, OModifiableDistributedConfiguration lastCfg, OCallable<T,OModifiableDistributedConfiguration> iCallback)	Executes an operation protected by a distributed lock (one per database).
<T> T	executeInDistributedDatabaseLock(String databaseName, long timeoutLocking, Callable<T> iCallback)
Object	executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database)	Executes the request on local node.
void	executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	getActiveServerNotLocal()
Set<String>	getActiveServers()
Set<String>	getAvailableNodeNames(String databaseName)
Set<String>	getAvailableNodeNotLocalNames(String databaseName)
int	getAvailableNodes(String iDatabaseName)
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabaseImpl	getDatabase(String name)
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName)
Set<String>	getDatabases()
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
com.hazelcast.core.HazelcastInstance	getHazelcastInstance()
long	getLastClusterChangeOn()
static String	getListeningBinaryAddress(ONodeConfig cfg)
ONodeConfig	getLocalNodeConfiguration()
int	getLocalNodeId()
String	getLocalNodeName()
Set<String>	getManagedDatabases()
ODistributedMessageService	getMessageService()
String	getName()
long	getNextMessageIdCounter()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
int	getNodeIdByName(String node)
String	getNodeNameById(int id)
NODE_STATUS	getNodeStatus()
int	getNodesWithStatus(Collection<String> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)	Returns the nodes with the requested status.
ODocument	getOnlineDatabaseConfiguration(String databaseName)
List<String>	getOnlineNodes(String iDatabaseName)
List<String>	getOnlineNodesNotLocal(String iDatabaseName)
ORemoteServerController	getRemoteServer(String rNodeName)
ORemoteServerManager	getRemoteServerManager()
OServer	getServerInstance()
ORemoteTaskFactoryManager	getTaskFactoryManager()	Returns the task factory manager.
boolean	installDatabase(boolean iStartup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
protected void	installDatabaseFromNetwork(String dbPath, String databaseName, String iNode, ODistributedDatabaseChunk firstChunk)	Installs a database from the network.
protected void	installDatabaseOnLocalNode(String databaseName, String dbPath, String iNode, boolean incremental, OSyncReceiver receiver)
void	installNewDatabasesFromCluster()
Object	internalCheckNodeInConfig(String databaseName, OModifiableDistributedConfiguration lastCfg)
Boolean	internalInstallDatabase(boolean iStartup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
void	invokeOnDatabaseStatusChange(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)
boolean	isEnabled()
boolean	isNodeAvailable(String iNodeName)
boolean	isNodeAvailable(String iNodeName, String databaseName)	Available means not OFFLINE, so ONLINE or SYNCHRONIZING.
boolean	isNodeOnline(String iNodeName, String databaseName)	Returns true if the node status is ONLINE.
boolean	isNodeStatusEqualsTo(String iNodeName, String iDatabaseName, ODistributedServerManager.DB_STATUS... statuses)	Checks the node status if it's one of the statuses received as argument.
boolean	isOffline()
boolean	isSyncronizing(String databaseName)
boolean	isWriteQuorumPresent(String databaseName)	Returns true if the quorum is present in terms of number of available nodes for full replication only.
void	loadLocalDatabases()	Initializes all the available server's databases as distributed.
void	messageAfterOp(String op, ODistributedRequestId request)
void	messageBeforeOp(String op, ODistributedRequestId request)
void	messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)
void	messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
void	messageProcessStart(ODistributedRequest message)
void	messageReceived(ODistributedRequest request)
ODistributedRequestId	nextRequestId()
void	notifyClients(String databaseName)
void	notifyStarted()
void	onDatabaseEvent(String nodeName, String databaseName, ODistributedServerManager.DB_STATUS status)
void	onDbConfigUpdated(String databaseName, ODocument config)
void	onDbStatusOnline(String databaseName)
void	onNodeJoined(String joinedNodeName, com.hazelcast.core.Member member)
boolean	onNodeJoining(String joinedNodeName)
void	onServerRemoved(String nodeName)
void	publishDistributedConfiguration(String iDatabaseName, ODistributedConfiguration cfg)
void	reassignClustersOwnership(String iNode, String databaseName, boolean canCreateNewClusters)
ODistributedPlugin	registerLifecycleListener(ODistributedLifecycleListener iListener)
void	reloadRegisteredNodes()
void	removeDbFromClusterMetadata(String name)
boolean	removeNodeFromConfiguration(String nodeName, String databaseName, boolean removeOnlyDynamicServers, boolean statusOffline)
void	removeServer(String nodeLeftName, boolean removeOnlyDynamicServers)
protected boolean	requestDatabaseFullSync(boolean backupDatabase, String databaseName)
protected boolean	requestFullDatabase(String databaseName, boolean backupDatabase)
void	restartNode(String iNode)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodes, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodes, ORemoteTask iTask, ODistributedRequestId reqId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
void	sendShutdown()
ODistributedResponse	sendSingleRequest(String databaseName, String node, ORemoteTask iTask)	Sends a distributed request against multiple servers.
void	setDatabaseStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)
void	setDefaultDatabaseConfigFile(String iFile)
void	setDistributedStrategy(ODistributedStrategy streatgy)
void	setNodeStatus(NODE_STATUS iStatus)
void	shutdown()
void	startup()
void	stopNode(String iNode)
String	toString()
ODistributedPlugin	unregisterLifecycleListener(ODistributedLifecycleListener iListener)
boolean	updateCachedDatabaseConfiguration(String iDatabaseName, OModifiableDistributedConfiguration cfg)
void	updateLastClusterChange()
protected boolean	waitForLocalNode(ODistributedConfiguration cfg, Collection<String> iNodes)
protected ODistributedResponse	waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr)
void	waitUntilNodeOnline()
void	waitUntilNodeOnline(String nodeName, String databaseName)

Methods inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract

getContent, onAfterClientRequest, onBeforeClientRequest, onClientConnection, onClientDisconnection, onClientError

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.server.plugin.OServerPlugin

onSocketAccepted, onSocketDestroyed

Field Details

REPLICATOR_USER

public static final String REPLICATOR_USER

See Also:

• Constant Field Values

PAR_DEF_DISTRIB_DB_CONFIG

protected static final String PAR_DEF_DISTRIB_DB_CONFIG

See Also:

• Constant Field Values

NODE_NAME_ENV

protected static final String NODE_NAME_ENV

See Also:

• Constant Field Values

defaultDatabaseConfigFile

protected File defaultDatabaseConfigFile

listeners

protected List<ODistributedLifecycleListener> listeners

remoteServerManager

protected ORemoteServerManager remoteServerManager

localMessageIdCounter

protected AtomicLong localMessageIdCounter

DEPLOY_DB_MAX_RETRIES

protected static final int DEPLOY_DB_MAX_RETRIES

See Also:

• Constant Field Values

installingDatabases

protected Set<String> installingDatabases

messageService

protected volatile ODistributedMessageServiceImpl messageService

startedOn

protected Date startedOn

responseManagerFactory

protected ODistributedStrategy responseManagerFactory

taskFactoryManager

protected ORemoteTaskFactoryManager taskFactoryManager

serverStarted

protected CountDownLatch serverStarted

signalListener

protected OSignalHandler.OSignalListener signalListener

Constructor Details

ODistributedPlugin

public ODistributedPlugin()

Method Details

waitUntilNodeOnline

public void waitUntilNodeOnline()
                         throws InterruptedException

Specified by:

waitUntilNodeOnline in interface ODistributedServerManager

Throws:

InterruptedException

waitUntilNodeOnline

public void waitUntilNodeOnline(String nodeName,
 String databaseName)
                         throws InterruptedException

Specified by:

waitUntilNodeOnline in interface ODistributedServerManager

Throws:

InterruptedException

config

public void config(OServer oServer,
 OServerParameterConfiguration[] iParams)

Description copied from interface: OServerPlugin

Configures the handler. Called at startup.

Specified by:

config in interface OServerPlugin

Overrides:

config in class OServerPluginAbstract

getRemoteServerManager

public ORemoteServerManager getRemoteServerManager()

getDefaultDatabaseConfigFile

public File getDefaultDatabaseConfigFile()

Specified by:

getDefaultDatabaseConfigFile in interface ODistributedServerManager

executeInDistributedDatabaseLock

public <T> T executeInDistributedDatabaseLock(String databaseName,
 long timeoutLocking,
 OModifiableDistributedConfiguration lastCfg,
 OCallable<T,OModifiableDistributedConfiguration> iCallback)

Description copied from interface: ODistributedServerManager

Executes an operation protected by a distributed lock (one per database).

Specified by:

executeInDistributedDatabaseLock in interface ODistributedServerManager

Type Parameters:

T - Return type

Parameters:

databaseName - Database name

iCallback - Operation @return The operation's result of type T

executeInDistributedDatabaseLock

public <T> T executeInDistributedDatabaseLock(String databaseName,
 long timeoutLocking,
 Callable<T> iCallback)

isWriteQuorumPresent

public boolean isWriteQuorumPresent(String databaseName)

Description copied from interface: ODistributedServerManager

Returns true if the quorum is present in terms of number of available nodes for full replication only. With sharding, instead, the quorum may depend on the involved clusters.

Specified by:

isWriteQuorumPresent in interface ODistributedServerManager

Returns:

setDefaultDatabaseConfigFile

public void setDefaultDatabaseConfigFile(String iFile)

startup

public void startup()

Specified by:

startup in interface OService

Overrides:

startup in class OServerPluginAbstract

registerLifecycleListener

public ODistributedPlugin registerLifecycleListener(ODistributedLifecycleListener iListener)

Specified by:

registerLifecycleListener in interface ODistributedServerManager

unregisterLifecycleListener

public ODistributedPlugin unregisterLifecycleListener(ODistributedLifecycleListener iListener)

Specified by:

unregisterLifecycleListener in interface ODistributedServerManager

shutdown

public void shutdown()

Specified by:

shutdown in interface OService

Overrides:

shutdown in class OServerPluginAbstract

removeDbFromClusterMetadata

public void removeDbFromClusterMetadata(String name)

dropOnAllServers

public void dropOnAllServers(String dbName)

dropConfig

public void dropConfig(String dbName)

getName

public String getName()

Specified by:

getName in interface OService

sendShutdown

public void sendShutdown()

Specified by:

sendShutdown in interface OServerPlugin

Overrides:

sendShutdown in class OServerPluginAbstract

getServerInstance

public OServer getServerInstance()

Specified by:

getServerInstance in interface ODistributedServerManager

getLocalNodeConfiguration

public ONodeConfig getLocalNodeConfiguration()

Specified by:

getLocalNodeConfiguration in interface ODistributedServerManager

getDatabaseConfiguration

public ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)

Specified by:

getDatabaseConfiguration in interface ODistributedServerManager

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface ODistributedServerManager

sendRequest

public ODistributedResponse sendRequest(String iDatabaseName,
 Collection<String> iTargetNodes,
 ORemoteTask iTask)

Description copied from interface: ODistributedServerManager

Sends a distributed request against multiple servers.

Specified by:

sendRequest in interface ODistributedServerManager

Returns:

sendSingleRequest

public ODistributedResponse sendSingleRequest(String databaseName,
 String node,
 ORemoteTask iTask)

Description copied from interface: ODistributedServerManager

Sends a distributed request against multiple servers.

Specified by:

sendSingleRequest in interface ODistributedServerManager

Returns:

sendRequest

public ODistributedResponse sendRequest(String iDatabaseName,
 Collection<String> iTargetNodes,
 ORemoteTask iTask,
 ODistributedRequestId reqId,
 Object localResult,
 ODistributedResponseManagerFactory responseManagerFactory)

Specified by:

sendRequest in interface ODistributedServerManager

checkForServerOnline

protected void checkForServerOnline(ODistributedRequest iRequest)
                             throws ODistributedException

Throws:

ODistributedException

send2Nodes

public ODistributedResponse send2Nodes(ODistributedRequest iRequest,
 Collection<String> iNodes,
 ODistributedRequest.EXECUTION_MODE iExecutionMode,
 Object localResult,
 ODistributedResponseManagerFactory responseManagerFactory)

waitForResponse

protected ODistributedResponse waitForResponse(ODistributedRequest iRequest,
 ODistributedResponseManager currentResponseMgr)
                                        throws InterruptedException

Throws:

InterruptedException

calculateQuorum

protected int calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
 ODistributedConfiguration cfg,
 int totalServers,
 int totalMasterServers,
 int onlineMasters,
 boolean checkNodesAreOnline,
 String localNodeName)

send2Nodes

public ODistributedResponse send2Nodes(ODistributedRequest iRequest,
 Collection<String> iNodes,
 ODistributedRequest.EXECUTION_MODE iExecutionMode,
 Object localResult)

waitForLocalNode

protected boolean waitForLocalNode(ODistributedConfiguration cfg,
 Collection<String> iNodes)

executeOnLocalNodeFromRemote

public void executeOnLocalNodeFromRemote(ODistributedRequest request)

Specified by:

executeOnLocalNodeFromRemote in interface ODistributedServerManager

executeOnLocalNode

public Object executeOnLocalNode(ODistributedRequestId reqId,
 ORemoteTask task,
 ODatabaseDocumentInternal database)

Executes the request on local node. In case of error returns the Exception itself

Specified by:

executeOnLocalNode in interface ODistributedServerManager

getManagedDatabases

public Set<String> getManagedDatabases()

getLocalNodeName

public String getLocalNodeName()

Specified by:

getLocalNodeName in interface ODistributedServerManager

getOnlineNodes

public List<String> getOnlineNodes(String iDatabaseName)

Specified by:

getOnlineNodes in interface ODistributedServerManager

getOnlineNodesNotLocal

public List<String> getOnlineNodesNotLocal(String iDatabaseName)

Specified by:

getOnlineNodesNotLocal in interface ODistributedServerManager

reassignClustersOwnership

public void reassignClustersOwnership(String iNode,
 String databaseName,
 boolean canCreateNewClusters)

Specified by:

reassignClustersOwnership in interface ODistributedServerManager

isNodeAvailable

public boolean isNodeAvailable(String iNodeName,
 String databaseName)

Description copied from interface: ODistributedServerManager

Available means not OFFLINE, so ONLINE or SYNCHRONIZING.

Specified by:

isNodeAvailable in interface ODistributedServerManager

isNodeOnline

public boolean isNodeOnline(String iNodeName,
 String databaseName)

Description copied from interface: ODistributedServerManager

Returns true if the node status is ONLINE.

Specified by:

isNodeOnline in interface ODistributedServerManager

isNodeStatusEqualsTo

public boolean isNodeStatusEqualsTo(String iNodeName,
 String iDatabaseName,
 ODistributedServerManager.DB_STATUS... statuses)

Description copied from interface: ODistributedServerManager

Checks the node status if it's one of the statuses received as argument.

Specified by:

isNodeStatusEqualsTo in interface ODistributedServerManager

Parameters:

iNodeName - Node name

iDatabaseName - Database name

statuses - vararg of statuses

Returns:

true if the node's status is equals to one of the passed statuses, otherwise false

isNodeAvailable

public boolean isNodeAvailable(String iNodeName)

Specified by:

isNodeAvailable in interface ODistributedServerManager

getAvailableNodeNames

public Set<String> getAvailableNodeNames(String databaseName)

Specified by:

getAvailableNodeNames in interface ODistributedServerManager

getAvailableNodeNotLocalNames

public Set<String> getAvailableNodeNotLocalNames(String databaseName)

Specified by:

getAvailableNodeNotLocalNames in interface ODistributedServerManager

isOffline

public boolean isOffline()

Specified by:

isOffline in interface ODistributedServerManager

getLocalNodeId

public int getLocalNodeId()

Specified by:

getLocalNodeId in interface ODistributedServerManager

getNodesWithStatus

public int getNodesWithStatus(Collection<String> iNodes,
 String databaseName,
 ODistributedServerManager.DB_STATUS... statuses)

Returns the nodes with the requested status.

Specified by:

getNodesWithStatus in interface ODistributedServerManager

toString

public String toString()

Overrides:

toString in class Object

getMessageService

public ODistributedMessageService getMessageService()

Specified by:

getMessageService in interface ODistributedServerManager

getAvailableNodes

public int getAvailableNodes(String iDatabaseName)

Specified by:

getAvailableNodes in interface ODistributedServerManager

installDatabase

public boolean installDatabase(boolean iStartup,
 String databaseName,
 boolean forceDeployment,
 boolean tryWithDeltaFirst)

Specified by:

installDatabase in interface ODistributedServerManager

isSyncronizing

public boolean isSyncronizing(String databaseName)

Specified by:

isSyncronizing in interface ODistributedServerManager

internalInstallDatabase

public Boolean internalInstallDatabase(boolean iStartup,
 String databaseName,
 boolean forceDeployment,
 boolean tryWithDeltaFirst)

checkNodeInConfiguration

public void checkNodeInConfiguration(String databaseName,
 ODistributedConfiguration cfg)

internalCheckNodeInConfig

public Object internalCheckNodeInConfig(String databaseName,
 OModifiableDistributedConfiguration lastCfg)

requestFullDatabase

protected boolean requestFullDatabase(String databaseName,
 boolean backupDatabase)

requestDatabaseFullSync

protected boolean requestDatabaseFullSync(boolean backupDatabase,
 String databaseName)

backupCurrentDatabase

protected void backupCurrentDatabase(String iDatabaseName)

installDatabaseFromNetwork

protected void installDatabaseFromNetwork(String dbPath,
 String databaseName,
 String iNode,
 ODistributedDatabaseChunk firstChunk)

Installs a database from the network.

getTaskFactoryManager

public ORemoteTaskFactoryManager getTaskFactoryManager()

Description copied from interface: ODistributedServerManager

Returns the task factory manager. During first connect the minor version of the protocol is used.

Specified by:

getTaskFactoryManager in interface ODistributedServerManager

getActiveServers

public Set<String> getActiveServers()

Specified by:

getActiveServers in interface ODistributedServerManager

getActiveServerNotLocal

public Set<String> getActiveServerNotLocal()

Specified by:

getActiveServerNotLocal in interface ODistributedServerManager

getDistributedStrategy

public ODistributedStrategy getDistributedStrategy()

Specified by:

getDistributedStrategy in interface ODistributedServerManager

setDistributedStrategy

public void setDistributedStrategy(ODistributedStrategy streatgy)

Specified by:

setDistributedStrategy in interface ODistributedServerManager

updateCachedDatabaseConfiguration

public boolean updateCachedDatabaseConfiguration(String iDatabaseName,
 OModifiableDistributedConfiguration cfg)

Specified by:

updateCachedDatabaseConfiguration in interface ODistributedServerManager

publishDistributedConfiguration

public void publishDistributedConfiguration(String iDatabaseName,
 ODistributedConfiguration cfg)

Specified by:

publishDistributedConfiguration in interface ODistributedServerManager

notifyClients

public void notifyClients(String databaseName)

Specified by:

notifyClients in interface ODistributedServerManager

onDatabaseEvent

public void onDatabaseEvent(String nodeName,
 String databaseName,
 ODistributedServerManager.DB_STATUS status)

invokeOnDatabaseStatusChange

public void invokeOnDatabaseStatusChange(String iNode,
 String iDatabaseName,
 ODistributedServerManager.DB_STATUS iStatus)

assignNodeName

protected void assignNodeName()

installDatabaseOnLocalNode

protected void installDatabaseOnLocalNode(String databaseName,
 String dbPath,
 String iNode,
 boolean incremental,
 OSyncReceiver receiver)

nextRequestId

public ODistributedRequestId nextRequestId()

Specified by:

nextRequestId in interface ODistributedServerManager

stopNode

public void stopNode(String iNode)
              throws IOException

Throws:

IOException

restartNode

public void restartNode(String iNode)
                 throws IOException

Throws:

IOException

getNextMessageIdCounter

public long getNextMessageIdCounter()

Specified by:

getNextMessageIdCounter in interface ODistributedServerManager

updateLastClusterChange

public void updateLastClusterChange()

Specified by:

updateLastClusterChange in interface ODistributedServerManager

closeRemoteServer

public void closeRemoteServer(String node)

dumpServersStatus

public void dumpServersStatus()

Avoids to dump the same configuration twice if it's unchanged since the last time.

getListeningBinaryAddress

public static String getListeningBinaryAddress(ONodeConfig cfg)

messageReceived

public void messageReceived(ODistributedRequest request)

Specified by:

messageReceived in interface ODistributedServerManager

messageBeforeOp

public void messageBeforeOp(String op,
 ODistributedRequestId request)

Specified by:

messageBeforeOp in interface ODistributedServerManager

messageAfterOp

public void messageAfterOp(String op,
 ODistributedRequestId request)

Specified by:

messageAfterOp in interface ODistributedServerManager

messageCurrentPayload

public void messageCurrentPayload(ODistributedRequestId requestId,
 Object responsePayload)

Specified by:

messageCurrentPayload in interface ODistributedServerManager

messageProcessStart

public void messageProcessStart(ODistributedRequest message)

Specified by:

messageProcessStart in interface ODistributedServerManager

messageProcessEnd

public void messageProcessEnd(ODistributedRequest iRequest,
 Object responsePayload)

Specified by:

messageProcessEnd in interface ODistributedServerManager

loadLocalDatabases

public void loadLocalDatabases()

Initializes all the available server's databases as distributed.

installNewDatabasesFromCluster

public void installNewDatabasesFromCluster()

notifyStarted

public void notifyStarted()

dumpStats

protected void dumpStats()

getRemoteServer

public ORemoteServerController getRemoteServer(String rNodeName)
                                        throws IOException

Specified by:

getRemoteServer in interface ODistributedServerManager

Throws:

IOException

getLastClusterChangeOn

public long getLastClusterChangeOn()

Specified by:

getLastClusterChangeOn in interface ODistributedServerManager

getNodeStatus

public NODE_STATUS getNodeStatus()

Specified by:

getNodeStatus in interface ODistributedServerManager

setNodeStatus

public void setNodeStatus(NODE_STATUS iStatus)

Specified by:

setNodeStatus in interface ODistributedServerManager

onNodeJoined

public void onNodeJoined(String joinedNodeName,
 com.hazelcast.core.Member member)

connectToAllNodes

public void connectToAllNodes(Set<String> clusterNodes)
                       throws IOException

Throws:

IOException

removeServer

public void removeServer(String nodeLeftName,
 boolean removeOnlyDynamicServers)

Specified by:

removeServer in interface ODistributedServerManager

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
 String iDatabaseName)

Specified by:

getDatabaseStatus in interface ODistributedServerManager

setDatabaseStatus

public void setDatabaseStatus(String iNode,
 String iDatabaseName,
 ODistributedServerManager.DB_STATUS iStatus)

Specified by:

setDatabaseStatus in interface ODistributedServerManager

onServerRemoved

public void onServerRemoved(String nodeName)

onDbStatusOnline

public void onDbStatusOnline(String databaseName)

onDbConfigUpdated

public void onDbConfigUpdated(String databaseName,
 ODocument config)

onNodeJoining

public boolean onNodeJoining(String joinedNodeName)

getClusterConfiguration

public OClusterConfiguration getClusterConfiguration()

Specified by:

getClusterConfiguration in interface ODistributedServerManager

getNodeNameById

public String getNodeNameById(int id)

Specified by:

getNodeNameById in interface ODistributedServerManager

getNodeIdByName

public int getNodeIdByName(String node)

Specified by:

getNodeIdByName in interface ODistributedServerManager

getNodeConfigurationByUuid

public ONodeConfig getNodeConfigurationByUuid(String iNode,
 boolean useCache)

Specified by:

getNodeConfigurationByUuid in interface ODistributedServerManager

reloadRegisteredNodes

public void reloadRegisteredNodes()

removeNodeFromConfiguration

public boolean removeNodeFromConfiguration(String nodeName,
 String databaseName,
 boolean removeOnlyDynamicServers,
 boolean statusOffline)

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

getOnlineDatabaseConfiguration

public ODocument getOnlineDatabaseConfiguration(String databaseName)

Specified by:

getOnlineDatabaseConfiguration in interface ODistributedServerManager

getDatabase

public ODistributedDatabaseImpl getDatabase(String name)

Specified by:

getDatabase in interface ODistributedServerManager

getDatabases

public Set<String> getDatabases()

Specified by:

getDatabases in interface ODistributedServerManager