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, OCommandOutputListener, ODatabaseLifecycleListener, ODistributedServerManager, OServerPlugin

Direct Known Subclasses:

OHazelcastPlugin

public class ODistributedPlugin
extends OServerPluginAbstract
implements ODistributedServerManager, ODatabaseLifecycleListener, OCommandOutputListener

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.core.db.ODatabaseLifecycleListener

ODatabaseLifecycleListener.PRIORITY

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

ODistributedServerManager.DB_STATUS, ODistributedServerManager.NODE_STATUS

Field Summary

Fields

Modifier and Type	Field	Description
protected OClusterOwnershipAssignmentStrategy	clusterAssignmentStrategy
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

Modifier	Constructor	Description
protected	ODistributedPlugin()

Method Summary

Modifier and Type	Method	Description
protected void	assignNodeName()
protected void	backupCurrentDatabase(String iDatabaseName)
protected int	calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType, Collection<String> clusterNames, ODistributedConfiguration cfg, int totalServers, int totalMasterServers, int onlineMasters, boolean checkNodesAreOnline, String localNodeName)
protected void	checkForServerOnline(ODistributedRequest iRequest)
void	checkNodeInConfiguration(String databaseName, ODistributedConfiguration cfg)
boolean	checkNodeStatus(ODistributedServerManager.NODE_STATUS status)
void	closeRemoteServer(String node)
void	config(OServer oServer, OServerParameterConfiguration[] iParams)	Configures the handler.
void	connectToAllNodes(Set<String> clusterNodes)
Throwable	convertException(Throwable original)
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>	getActiveServers()
Set<String>	getAvailableNodeNames(String databaseName)
int	getAvailableNodes(String iDatabaseName)
int	getAvailableNodes(Collection<String> iNodes, String databaseName)
ODocument	getClusterConfiguration()
long	getClusterTime()	Returns the cluster-wide time in milliseconds.
String	getCoordinatorServer()	Deprecated.
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(ODocument cfg)
ODocument	getLocalNodeConfiguration()
int	getLocalNodeId()
String	getLocalNodeName()
ODistributedLockManager	getLockManagerExecutor()
ODistributedLockManager	getLockManagerRequester()
Set<String>	getManagedDatabases()
ODistributedMessageServiceImpl	getMessageService()
String	getName()
long	getNextMessageIdCounter()
ODocument	getNodeConfigurationByUuid(String iNode, boolean useCache)
int	getNodeIdByName(String node)
String	getNodeNameById(int id)
ODistributedServerManager.NODE_STATUS	getNodeStatus()
int	getNodesWithStatus(Collection<String> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)	Returns the nodes with the requested status.
String	getNodeUuidByName(String name)
ODocument	getOnlineDatabaseConfiguration(String databaseName)
List<String>	getOnlineNodes(String iDatabaseName)
ODatabaseLifecycleListener.PRIORITY	getPriority()
ORemoteServerController	getRemoteServer(String rNodeName)
OServer	getServerInstance()
ODocument	getStats()
ORemoteTaskFactoryManager	getTaskFactoryManager()	Returns the task factory manager.
int	getTotalNodes(String iDatabaseName)
boolean	installClustersOfClass(ODatabaseInternal iDatabase, OClass iClass, OModifiableDistributedConfiguration cfg)	Guarantees that each class has own master cluster.
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()
void	internalAddCluster(ODatabaseInternal iDatabase, OClass clazz, String newClusterName)
Object	internalCheckNodeInConfig(String databaseName, OModifiableDistributedConfiguration lastCfg)
Boolean	internalInstallDatabase(boolean iStartup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
Boolean	internalRebalanceClusters(ODatabaseInternal iDatabase, OClass iClass, OModifiableDistributedConfiguration lastCfg)
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()
protected boolean	isRelatedToLocalServer(ODatabaseInternal iDatabase)
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	messagePartitionCalculate(ODistributedRequest request, Set<Integer> involvedWorkerQueues)
void	messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
void	messageProcessStart(ODistributedRequest message)
void	messageReceived(ODistributedRequest request)
void	notifyClients(String databaseName)
void	notifyStarted()
void	onClose(ODatabaseInternal iDatabase)	Remove myself as hook.
void	onCreate(ODatabaseInternal iDatabase)
void	onCreateClass(ODatabaseInternal iDatabase, OClass iClass)
void	onCreateView(ODatabaseInternal iDatabase, OView view)
void	onDatabaseEvent(String nodeName, String databaseName, ODistributedServerManager.DB_STATUS status)
void	onDbConfigUpdated(String databaseName, ODocument config)
void	onDbStatusOnline(String databaseName)
void	onDrop(ODatabaseInternal iDatabase)
void	onDropClass(ODatabaseInternal iDatabase, OClass iClass)
void	onLocalNodeConfigurationRequest(ODocument iConfiguration)	Event called during the retrieving of distributed configuration, usually at startup and when the cluster shape changes.
void	onMessage(String iText)
void	onNodeJoined(String joinedNodeName, com.hazelcast.core.Member member)
boolean	onNodeJoining(String joinedNodeName)
void	onOpen(ODatabaseInternal iDatabase)	Auto register myself as hook.
void	onServerRemoved(String nodeName)
void	publishDistributedConfiguration(String iDatabaseName, ODistributedConfiguration cfg)
void	reassignClustersOwnership(String iNode, String databaseName, OModifiableDistributedConfiguration cfg, boolean canCreateNewClusters)
protected void	rebalanceClusterOwnership(String iNode, String databaseName, OModifiableDistributedConfiguration cfg, 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> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult)	Sends a distributed request against multiple servers.
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
void	sendShutdown()
void	setDatabaseStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)
void	setDefaultDatabaseConfigFile(String iFile)
void	setDistributedStrategy(ODistributedStrategy streatgy)
void	setNodeStatus(ODistributedServerManager.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> iClusterNames, 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.core.db.ODatabaseLifecycleListener

onDropView

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

clusterAssignmentStrategy

protected OClusterOwnershipAssignmentStrategy clusterAssignmentStrategy

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

protected 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

getPriority

public ODatabaseLifecycleListener.PRIORITY getPriority()

Specified by:

getPriority in interface ODatabaseLifecycleListener

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

getCoordinatorServer

@Deprecated
public String getCoordinatorServer()

Deprecated.

Specified by:

getCoordinatorServer in interface ODistributedServerManager

getDefaultDatabaseConfigFile

public File getDefaultDatabaseConfigFile()

Specified by:

getDefaultDatabaseConfigFile in interface ODistributedServerManager

getLockManagerRequester

public ODistributedLockManager getLockManagerRequester()

Specified by:

getLockManagerRequester in interface ODistributedServerManager

getLockManagerExecutor

public ODistributedLockManager getLockManagerExecutor()

Specified by:

getLockManagerExecutor 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

onOpen

public void onOpen(ODatabaseInternal iDatabase)

Auto register myself as hook.

Specified by:

onOpen in interface ODatabaseLifecycleListener

onClose

public void onClose(ODatabaseInternal iDatabase)

Remove myself as hook.

Specified by:

onClose in interface ODatabaseLifecycleListener

onDrop

public void onDrop(ODatabaseInternal iDatabase)

Specified by:

onDrop in interface ODatabaseLifecycleListener

removeDbFromClusterMetadata

public void removeDbFromClusterMetadata(String name)

dropOnAllServers

public void dropOnAllServers(String dbName)

dropConfig

public void dropConfig(String dbName)

onDropClass

public void onDropClass(ODatabaseInternal iDatabase,
 OClass iClass)

Specified by:

onDropClass in interface ODatabaseLifecycleListener

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 ODocument 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> iClusterNames,
 Collection<String> iTargetNodes,
 ORemoteTask iTask,
 long reqId,
 ODistributedRequest.EXECUTION_MODE iExecutionMode,
 Object localResult)

Description copied from interface: ODistributedServerManager

Sends a distributed request against multiple servers.

Specified by:

sendRequest in interface ODistributedServerManager

reqId - Message Id as long

localResult - It's the result of the request executed locally

Returns:

sendRequest

public ODistributedResponse sendRequest(String iDatabaseName,
 Collection<String> iClusterNames,
 Collection<String> iTargetNodes,
 ORemoteTask iTask,
 long reqId,
 ODistributedRequest.EXECUTION_MODE iExecutionMode,
 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> iClusterNames,
 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,
 Collection<String> clusterNames,
 ODistributedConfiguration cfg,
 int totalServers,
 int totalMasterServers,
 int onlineMasters,
 boolean checkNodesAreOnline,
 String localNodeName)

send2Nodes

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

waitForLocalNode

protected boolean waitForLocalNode(ODistributedConfiguration cfg,
 Collection<String> iClusterNames,
 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

onLocalNodeConfigurationRequest

public void onLocalNodeConfigurationRequest(ODocument iConfiguration)

Description copied from interface: ODatabaseLifecycleListener

Event called during the retrieving of distributed configuration, usually at startup and when the cluster shape changes. You can use this event to enrich the ODocument sent to the client with custom properties.

Specified by:

onLocalNodeConfigurationRequest in interface ODatabaseLifecycleListener

onCreateClass

public void onCreateClass(ODatabaseInternal iDatabase,
 OClass iClass)

Specified by:

onCreateClass in interface ODatabaseLifecycleListener

onCreateView

public void onCreateView(ODatabaseInternal iDatabase,
 OView view)

Specified by:

onCreateView in interface ODatabaseLifecycleListener

getStats

public ODocument getStats()

Specified by:

getStats in interface ODistributedServerManager

convertException

public Throwable convertException(Throwable original)

Specified by:

convertException in interface ODistributedServerManager

getOnlineNodes

public List<String> getOnlineNodes(String iDatabaseName)

Specified by:

getOnlineNodes in interface ODistributedServerManager

reassignClustersOwnership

public void reassignClustersOwnership(String iNode,
 String databaseName,
 OModifiableDistributedConfiguration cfg,
 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

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 ODistributedMessageServiceImpl getMessageService()

Specified by:

getMessageService in interface ODistributedServerManager

getTotalNodes

public int getTotalNodes(String iDatabaseName)

Specified by:

getTotalNodes in interface ODistributedServerManager

getAvailableNodes

public int getAvailableNodes(String iDatabaseName)

Specified by:

getAvailableNodes in interface ODistributedServerManager

getAvailableNodes

public int getAvailableNodes(Collection<String> iNodes,
 String databaseName)

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

installClustersOfClass

public boolean installClustersOfClass(ODatabaseInternal iDatabase,
 OClass iClass,
 OModifiableDistributedConfiguration cfg)

Guarantees that each class has own master cluster.

internalRebalanceClusters

public Boolean internalRebalanceClusters(ODatabaseInternal iDatabase,
 OClass iClass,
 OModifiableDistributedConfiguration lastCfg)

internalAddCluster

public void internalAddCluster(ODatabaseInternal iDatabase,
 OClass clazz,
 String newClusterName)

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)

rebalanceClusterOwnership

protected void rebalanceClusterOwnership(String iNode,
 String databaseName,
 OModifiableDistributedConfiguration cfg,
 boolean canCreateNewClusters)

assignNodeName

protected void assignNodeName()

installDatabaseOnLocalNode

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

onMessage

public void onMessage(String iText)

Specified by:

onMessage in interface OCommandOutputListener

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

getNodeUuidByName

public String getNodeUuidByName(String name)

Specified by:

getNodeUuidByName in interface ODistributedServerManager

updateLastClusterChange

public void updateLastClusterChange()

Specified by:

updateLastClusterChange in interface ODistributedServerManager

closeRemoteServer

public void closeRemoteServer(String node)

isRelatedToLocalServer

protected boolean isRelatedToLocalServer(ODatabaseInternal iDatabase)

dumpServersStatus

public void dumpServersStatus()

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

getClusterTime

public long getClusterTime()

Description copied from interface: ODistributedServerManager

Returns the cluster-wide time in milliseconds.

Cluster tries to keep a cluster-wide time which might be different than the member's own system time. Cluster-wide time is -almost- the same on all members of the cluster.

Specified by:

getClusterTime in interface ODistributedServerManager

getListeningBinaryAddress

public static String getListeningBinaryAddress(ODocument cfg)

messageReceived

public void messageReceived(ODistributedRequest request)

Specified by:

messageReceived in interface ODistributedServerManager

messagePartitionCalculate

public void messagePartitionCalculate(ODistributedRequest request,
 Set<Integer> involvedWorkerQueues)

Specified by:

messagePartitionCalculate 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 ODistributedServerManager.NODE_STATUS getNodeStatus()

Specified by:

getNodeStatus in interface ODistributedServerManager

setNodeStatus

public void setNodeStatus(ODistributedServerManager.NODE_STATUS iStatus)

Specified by:

setNodeStatus in interface ODistributedServerManager

checkNodeStatus

public boolean checkNodeStatus(ODistributedServerManager.NODE_STATUS status)

Specified by:

checkNodeStatus 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

onCreate

public void onCreate(ODatabaseInternal iDatabase)

Specified by:

onCreate in interface ODatabaseLifecycleListener

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 ODocument 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 ODocument 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