com.orientechnologies.orient.server.distributed.impl

Class ODistributedAbstractPlugin

java.lang.Object

com.orientechnologies.orient.server.plugin.OServerPluginAbstract

com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

All Implemented Interfaces:

OService, OCommandOutputListener, ODatabaseLifecycleListener, ODistributedServerManager, OServerPlugin

Direct Known Subclasses:

OHazelcastPlugin

public abstract class ODistributedAbstractPlugin
extends OServerPluginAbstract
implements ODistributedServerManager, ODatabaseLifecycleListener, OCommandOutputListener

Abstract 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, ODistributedServerManager.NODE_STATUS

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

ODatabaseLifecycleListener.PRIORITY

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,com.hazelcast.core.Member>	activeNodes
protected ConcurrentMap<String,String>	activeNodesNamesByUuid
protected ConcurrentMap<String,String>	activeNodesUuidByName
protected ConcurrentMap<String,Long>	autoRemovalOfServers
protected OClusterOwnershipAssignmentStrategy	clusterAssignmentStrategy
protected File	defaultDatabaseConfigFile
protected static int	DEPLOY_DB_MAX_RETRIES
protected TimerTask	haStatsTask
protected TimerTask	healthCheckerTask
protected Set<String>	installingDatabases
protected long	lastClusterChangeOn
protected List<ODistributedLifecycleListener>	listeners
protected AtomicLong	localMessageIdCounter
protected ODistributedMessageServiceImpl	messageService
protected static String	NODE_NAME_ENV
protected int	nodeId
protected String	nodeName
protected String	nodeUuid
protected static String	PAR_DEF_DISTRIB_DB_CONFIG
protected TimerTask	publishLocalNodeConfigurationTask
protected List<String>	registeredNodeById
protected ConcurrentMap<String,Integer>	registeredNodeByName
protected ConcurrentMap<String,ORemoteServerController>	remoteServers
static String	REPLICATOR_USER
protected ODistributedStrategy	responseManagerFactory
protected OServer	serverInstance
protected CountDownLatch	serverStarted
protected Date	startedOn
protected ODistributedServerManager.NODE_STATUS	status
protected ConcurrentMap<String,ODistributedStorage>	storages
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 and Description
protected	ODistributedAbstractPlugin()

Method Summary

Modifier and Type	Method and Description
protected void	assignNodeName()
protected void	backupCurrentDatabase(String iDatabaseName)
protected void	checkIntegrityOfLastTransactions(ODistributedDatabaseImpl distrDatabase)
boolean	checkNodeStatus(ODistributedServerManager.NODE_STATUS iStatus2Check)
void	closeRemoteServer(String node)
void	config(OServer oServer, OServerParameterConfiguration[] iParams) Configures the handler.
protected void	dumpServersStatus() Avoids to dump the same configuration twice if it's unchanged since the last time.
<T> T	executeInDistributedDatabaseLock(String databaseName, long timeoutLocking, OModifiableDistributedConfiguration lastCfg, OCallable<T,OModifiableDistributedConfiguration> iCallback) Executes an operation protected by a distributed lock (one per database).
Object	executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) Executes the request on local node.
void	executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	getAvailableNodeNames(String iDatabaseName)
int	getAvailableNodes(Collection<String> iNodes, String databaseName) Returns the available nodes (not offline) and clears the node list by removing the offline nodes.
int	getAvailableNodes(String iDatabaseName)
ODocument	getClusterConfiguration()
protected File	getClusterOwnedExclusivelyByCurrentNode(String dbPath, String iDatabaseName)
ODistributedConflictResolverFactory	getConflictResolverFactory()
String	getCoordinatorServer() Deprecated.
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName)
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName, boolean createIfNotPresent)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
long	getLastClusterChangeOn()
static String	getListeningBinaryAddress(ODocument cfg)
ODocument	getLocalNodeConfiguration()
int	getLocalNodeId()
String	getLocalNodeName()
ODistributedLockManagerExecutor	getLockManagerExecutor()
ODistributedLockManagerRequester	getLockManagerRequester()
String	getLockManagerServer()
Set<String>	getManagedDatabases()
ODistributedMessageServiceImpl	getMessageService()
String	getName()
long	getNextMessageIdCounter()
int	getNodeIdByName(String name)
String	getNodeName(com.hazelcast.core.Member iMember)
String	getNodeName(com.hazelcast.core.Member iMember, boolean useCache)
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)
List<String>	getOnlineNodes(String iDatabaseName)
ODatabaseLifecycleListener.PRIORITY	getPriority()
abstract String	getPublicAddress()
OServer	getServerInstance()
ODocument	getStats()
ODistributedStorage	getStorage(String dbName)
ODistributedStorage	getStorage(String dbName, OAbstractPaginatedStorage wrapped)
ODistributedStorage	getStorageIfExists(String dbName)
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 backup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
boolean	installDatabase(boolean backup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst, boolean manualSync)
protected void	installDatabaseFromNetwork(String dbPath, String databaseName, ODistributedDatabaseImpl distrDatabase, String iNode, ODistributedDatabaseChunk firstChunk, boolean delta, File uniqueClustersBackupDirectory, OModifiableDistributedConfiguration cfg) Installs a database from the network.
protected ODatabaseDocumentInternal	installDatabaseOnLocalNode(String databaseName, String dbPath, String iNode, boolean delta, File uniqueClustersBackupDirectory, OModifiableDistributedConfiguration cfg, boolean incremental, OSyncReceiver receiver)
boolean	isEnabled()
boolean	isNodeAvailable(String iNodeName)
boolean	isNodeAvailable(String iNodeName, String iDatabaseName) Available means not OFFLINE, so ONLINE or SYNCHRONIZING.
boolean	isNodeOnline(String iNodeName, String iDatabaseName) 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)
abstract void	notifyClients(String databaseName)
void	onClose(ODatabaseInternal iDatabase) Remove myself as hook.
void	onCreateClass(ODatabaseInternal iDatabase, OClass iClass)
protected void	onDatabaseEvent(String nodeName, String databaseName, ODistributedServerManager.DB_STATUS status)
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	onOpen(ODatabaseInternal iDatabase) Auto register myself as hook.
void	reassignClustersOwnership(String iNode, String databaseName, OModifiableDistributedConfiguration cfg, boolean canCreateNewClusters)
protected void	rebalanceClusterOwnership(String iNode, ODatabaseInternal iDatabase, OModifiableDistributedConfiguration cfg, boolean canCreateNewClusters)
ODistributedAbstractPlugin	registerLifecycleListener(ODistributedLifecycleListener iListener)
void	registerNewDatabaseIfNeeded(String dbName, ODistributedConfiguration cfg)
void	removeStorage(String name)
boolean	requestDatabaseDelta(ODistributedDatabaseImpl distrDatabase, String databaseName, OModifiableDistributedConfiguration cfg)
protected boolean	requestDatabaseFullSync(ODistributedDatabaseImpl distrDatabase, boolean backupDatabase, String databaseName, boolean iAskToAllNodes, OModifiableDistributedConfiguration cfg)
protected boolean	requestFullDatabase(ODistributedDatabaseImpl distrDatabase, String databaseName, boolean backupDatabase, OModifiableDistributedConfiguration cfg)
void	restartNode(String iNode)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback) 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, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback, ODistributedResponseManagerFactory responseManagerFactory)
void	sendShutdown()
void	setDefaultDatabaseConfigFile(String iFile)
void	setDistributedStrategy(ODistributedStrategy streatgy)
void	setNodeStatus(ODistributedServerManager.NODE_STATUS iStatus)
void	shutdown()
void	startup()
void	stopNode(String iNode)
String	toString()
ODistributedAbstractPlugin	unregisterLifecycleListener(ODistributedLifecycleListener iListener)
boolean	updateCachedDatabaseConfiguration(String iDatabaseName, OModifiableDistributedConfiguration cfg)
void	updateLastClusterChange()
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.distributed.ODistributedServerManager

convertException, electNewLockManager, getActiveServers, getClusterTime, getConfigurationMap, getDatabaseStatus, getNodeConfigurationByUuid, getRemoteServer, isWriteQuorumPresent, messageAfterOp, messageBeforeOp, messageCurrentPayload, messagePartitionCalculate, messageProcessEnd, messageProcessStart, messageReceived, removeServer, setDatabaseStatus, updateCachedDatabaseConfiguration

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

onCreate

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

onSocketAccepted, onSocketDestroyed

Field Detail

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

serverInstance

protected OServer serverInstance

nodeUuid

protected String nodeUuid

nodeName

protected String nodeName

nodeId

protected int nodeId

defaultDatabaseConfigFile

protected File defaultDatabaseConfigFile

storages

protected final ConcurrentMap<String,ODistributedStorage> storages

status

protected volatile ODistributedServerManager.NODE_STATUS status

lastClusterChangeOn

protected long lastClusterChangeOn

listeners

protected List<ODistributedLifecycleListener> listeners

remoteServers

protected final ConcurrentMap<String,ORemoteServerController> remoteServers

publishLocalNodeConfigurationTask

protected TimerTask publishLocalNodeConfigurationTask

haStatsTask

protected TimerTask haStatsTask

healthCheckerTask

protected TimerTask healthCheckerTask

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

activeNodes

protected ConcurrentMap<String,com.hazelcast.core.Member> activeNodes

activeNodesNamesByUuid

protected ConcurrentMap<String,String> activeNodesNamesByUuid

activeNodesUuidByName

protected ConcurrentMap<String,String> activeNodesUuidByName

registeredNodeById

protected final List<String> registeredNodeById

registeredNodeByName

protected final ConcurrentMap<String,Integer> registeredNodeByName

autoRemovalOfServers

protected ConcurrentMap<String,Long> autoRemovalOfServers

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

Constructor Detail

ODistributedAbstractPlugin

protected ODistributedAbstractPlugin()

Method Detail

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

getLockManagerServer

public String getLockManagerServer()

Specified by:

getLockManagerServer in interface ODistributedServerManager

getDefaultDatabaseConfigFile

public File getDefaultDatabaseConfigFile()

Specified by:

getDefaultDatabaseConfigFile in interface ODistributedServerManager

setDefaultDatabaseConfigFile

public void setDefaultDatabaseConfigFile(String iFile)

startup

public void startup()

Specified by:

startup in interface OService

Overrides:

startup in class OServerPluginAbstract

registerLifecycleListener

public ODistributedAbstractPlugin registerLifecycleListener(ODistributedLifecycleListener iListener)

Specified by:

registerLifecycleListener in interface ODistributedServerManager

unregisterLifecycleListener

public ODistributedAbstractPlugin unregisterLifecycleListener(ODistributedLifecycleListener iListener)

Specified by:

unregisterLifecycleListener in interface ODistributedServerManager

shutdown

public void shutdown()

Specified by:

shutdown in interface OService

Overrides:

shutdown in class OServerPluginAbstract

getLockManagerRequester

public ODistributedLockManagerRequester getLockManagerRequester()

Specified by:

getLockManagerRequester in interface ODistributedServerManager

getLockManagerExecutor

public ODistributedLockManagerExecutor getLockManagerExecutor()

Specified by:

getLockManagerExecutor in interface ODistributedServerManager

onOpen

public void onOpen(ODatabaseInternal iDatabase)

Auto register myself as hook.

Specified by:

onOpen in interface ODatabaseLifecycleListener

registerNewDatabaseIfNeeded

public void registerNewDatabaseIfNeeded(String dbName,
                                        ODistributedConfiguration cfg)

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

removeStorage

public void removeStorage(String name)

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

getNodeName

public String getNodeName(com.hazelcast.core.Member iMember)

getNodeName

public String getNodeName(com.hazelcast.core.Member iMember,
                          boolean useCache)

updateCachedDatabaseConfiguration

public boolean updateCachedDatabaseConfiguration(String iDatabaseName,
                                                 OModifiableDistributedConfiguration cfg)

getDatabaseConfiguration

public ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)

Specified by:

getDatabaseConfiguration in interface ODistributedServerManager

getDatabaseConfiguration

public ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName,
                                                          boolean createIfNotPresent)

Specified by:

getDatabaseConfiguration in interface ODistributedServerManager

getServerInstance

public OServer getServerInstance()

Specified by:

getServerInstance in interface ODistributedServerManager

getClusterConfiguration

public ODocument getClusterConfiguration()

Specified by:

getClusterConfiguration in interface ODistributedServerManager

getPublicAddress

public abstract String getPublicAddress()

getLocalNodeConfiguration

public ODocument getLocalNodeConfiguration()

Specified by:

getLocalNodeConfiguration in interface ODistributedServerManager

isEnabled

public boolean isEnabled()

Specified by:

isEnabled 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 iStatus2Check)

Specified by:

checkNodeStatus 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,
                                        OCallable<Void,ODistributedRequestId> iAfterSentCallback,
                                        OCallable<Void,ODistributedResponseManager> endCallback)

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,
                                        OCallable<Void,ODistributedRequestId> iAfterSentCallback,
                                        OCallable<Void,ODistributedResponseManager> endCallback,
                                        ODistributedResponseManagerFactory responseManagerFactory)

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

getLocalNodeId

public int getLocalNodeId()

Specified by:

getLocalNodeId 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

getStats

public ODocument getStats()

Specified by:

getStats in interface ODistributedServerManager

getNodeNameById

public String getNodeNameById(int id)

Specified by:

getNodeNameById in interface ODistributedServerManager

getNodeIdByName

public int getNodeIdByName(String name)

Specified by:

getNodeIdByName 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

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 iDatabaseName)

Description copied from interface: ODistributedServerManager

Available means not OFFLINE, so ONLINE or SYNCHRONIZING.

Specified by:

isNodeAvailable 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

isNodeOnline

public boolean isNodeOnline(String iNodeName,
                            String iDatabaseName)

Description copied from interface: ODistributedServerManager

Returns true if the node status is ONLINE.

Specified by:

isNodeOnline in interface ODistributedServerManager

isOffline

public boolean isOffline()

Specified by:

isOffline in interface ODistributedServerManager

getAvailableNodes

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

Returns the available nodes (not offline) and clears the node list by removing the offline nodes.

Specified by:

getAvailableNodes 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

getLastClusterChangeOn

public long getLastClusterChangeOn()

Specified by:

getLastClusterChangeOn 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

getOnlineNodes

public List<String> getOnlineNodes(String iDatabaseName)

Specified by:

getOnlineNodes in interface ODistributedServerManager

installDatabase

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

Specified by:

installDatabase in interface ODistributedServerManager

installDatabase

public boolean installDatabase(boolean backup,
                               String databaseName,
                               boolean forceDeployment,
                               boolean tryWithDeltaFirst,
                               boolean manualSync)

requestFullDatabase

protected boolean requestFullDatabase(ODistributedDatabaseImpl distrDatabase,
                                      String databaseName,
                                      boolean backupDatabase,
                                      OModifiableDistributedConfiguration cfg)

requestDatabaseDelta

public boolean requestDatabaseDelta(ODistributedDatabaseImpl distrDatabase,
                                    String databaseName,
                                    OModifiableDistributedConfiguration cfg)

checkIntegrityOfLastTransactions

protected void checkIntegrityOfLastTransactions(ODistributedDatabaseImpl distrDatabase)

requestDatabaseFullSync

protected boolean requestDatabaseFullSync(ODistributedDatabaseImpl distrDatabase,
                                          boolean backupDatabase,
                                          String databaseName,
                                          boolean iAskToAllNodes,
                                          OModifiableDistributedConfiguration cfg)

getClusterOwnedExclusivelyByCurrentNode

protected File getClusterOwnedExclusivelyByCurrentNode(String dbPath,
                                                       String iDatabaseName)

backupCurrentDatabase

protected void backupCurrentDatabase(String iDatabaseName)

installDatabaseFromNetwork

protected void installDatabaseFromNetwork(String dbPath,
                                          String databaseName,
                                          ODistributedDatabaseImpl distrDatabase,
                                          String iNode,
                                          ODistributedDatabaseChunk firstChunk,
                                          boolean delta,
                                          File uniqueClustersBackupDirectory,
                                          OModifiableDistributedConfiguration cfg)

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

installClustersOfClass

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

Guarantees that each class has own master cluster.

getDistributedStrategy

public ODistributedStrategy getDistributedStrategy()

Specified by:

getDistributedStrategy in interface ODistributedServerManager

setDistributedStrategy

public void setDistributedStrategy(ODistributedStrategy streatgy)

Specified by:

setDistributedStrategy in interface ODistributedServerManager

executeInDistributedDatabaseLock

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

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

notifyClients

public abstract void notifyClients(String databaseName)

Specified by:

notifyClients in interface ODistributedServerManager

onDatabaseEvent

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

rebalanceClusterOwnership

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

assignNodeName

protected void assignNodeName()

installDatabaseOnLocalNode

protected ODatabaseDocumentInternal installDatabaseOnLocalNode(String databaseName,
                                                               String dbPath,
                                                               String iNode,
                                                               boolean delta,
                                                               File uniqueClustersBackupDirectory,
                                                               OModifiableDistributedConfiguration cfg,
                                                               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

getAvailableNodeNames

public Set<String> getAvailableNodeNames(String iDatabaseName)

Specified by:

getAvailableNodeNames in interface ODistributedServerManager

getNextMessageIdCounter

public long getNextMessageIdCounter()

Specified by:

getNextMessageIdCounter in interface ODistributedServerManager

closeRemoteServer

public void closeRemoteServer(String node)

isRelatedToLocalServer

protected boolean isRelatedToLocalServer(ODatabaseInternal iDatabase)

dumpServersStatus

protected void dumpServersStatus()

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

getStorageIfExists

public ODistributedStorage getStorageIfExists(String dbName)

getStorage

public ODistributedStorage getStorage(String dbName)

Specified by:

getStorage in interface ODistributedServerManager

getStorage

public ODistributedStorage getStorage(String dbName,
                                      OAbstractPaginatedStorage wrapped)

getConflictResolverFactory

public ODistributedConflictResolverFactory getConflictResolverFactory()

Specified by:

getConflictResolverFactory in interface ODistributedServerManager

getListeningBinaryAddress

public static String getListeningBinaryAddress(ODocument cfg)