ODistributedAbstractPlugin (OrientDB 2.2.1-SNAPSHOT API)

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 Map<String,com.hazelcast.core.Member>`	`activeNodes`
`protected Map<String,String>`	`activeNodesNamesByMemberId`
`protected OClusterOwnershipAssignmentStrategy`	`clusterAssignmentStrategy`
`protected File`	`defaultDatabaseConfigFile`
`protected static int`	`DEPLOY_DB_MAX_RETRIES`
`protected boolean`	`enabled`
`protected long`	`lastClusterChangeOn`
`protected Map<String,Long>`	`lastLSNWriting`
`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 Map<String,Integer>`	`registeredNodeByName`
`protected ConcurrentMap<String,ORemoteServerController>`	`remoteServers`
`static String`	`REPLICATOR_USER`
`protected OServer`	`serverInstance`
`protected Date`	`startedOn`
`protected ODistributedServerManager.NODE_STATUS`	`status`
`protected ConcurrentHashMap<String,ODistributedStorage>`	`storages`
`protected ORemoteTaskFactory`	`taskFactory`

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

Constructor Summary

Constructors
Constructor and Description

ODistributedAbstractPlugin()

Constructors
Constructor and Description
`ODistributedAbstractPlugin()`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`protected void`	`assignNodeName()`
`protected void`	`backupCurrentDatabase(String iDatabaseName)`
`boolean`	`checkNodeStatus(ODistributedServerManager.NODE_STATUS iStatus2Check)`
`protected 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.
`protected boolean`	`electCurrentNodeAsNewCoordinator(ODistributedConfiguration cfg, String nodeLeftName, String databaseName)` Elects current node as new coordinator.
`protected boolean`	`electCurrentNodeAsNewCoordinator(String nodeLeftName, String nodeToElect, String databaseName, ODistributedConfiguration cfg)`
`<T> T`	`executeInDistributedDatabaseLock(String databaseName, OCallable<T,ODistributedConfiguration> iCallback)` Executes an operation protected by a distributed lock (one per database).
`Serializable`	`executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentTx database)` Executes the request on local node.
`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 String`	`getCoordinatorServer(ODistributedConfiguration cfg)`
`ODistributedConfiguration`	`getDatabaseConfiguration(String iDatabaseName)`
`File`	`getDistributedConfigFile(String iDatabaseName)`
`long`	`getLastClusterChangeOn()`
`protected abstract ODistributedConfiguration`	`getLastDatabaseConfiguration(String databaseName)`
`ODocument`	`getLocalNodeConfiguration()`
`int`	`getLocalNodeId()`
`String`	`getLocalNodeName()`
`Set<String>`	`getManagedDatabases()`
`ODistributedMessageServiceImpl`	`getMessageService()`
`String`	`getName()`
`long`	`getNextMessageIdCounter()`
`int`	`getNodeIdByName(String name)`
`String`	`getNodeName(com.hazelcast.core.Member iMember)`
`String`	`getNodeNameById(int id)`
`ODistributedServerManager.NODE_STATUS`	`getNodeStatus()`
`ODatabaseLifecycleListener.PRIORITY`	`getPriority()`
`ORemoteServerController`	`getRemoteServer(String rNodeName)`
`OServer`	`getServerInstance()`
`ODocument`	`getStats()`
`protected ODistributedStorage`	`getStorage(String dbName)`
`ORemoteTaskFactory`	`getTaskFactory()`
`boolean`	`installClustersOfClass(ODatabaseInternal iDatabase, OClass iClass)` Guarantees that each class has own master cluster.
`boolean`	`installDatabase(boolean iStartup, String databaseName, ODocument config)`
`protected Set<String>`	`installDatabaseFromNetwork(String dbPath, String databaseName, ODistributedDatabaseImpl distrDatabase, String iNode, ODistributedDatabaseChunk firstChunk, boolean delta)` Returns the clusters where sync is required.
`protected ODatabaseDocumentTx`	`installDatabaseOnLocalNode(String databaseName, String dbPath, String iNode, String iDatabaseCompressedFile, boolean delta)`
`protected void`	`installDbClustersLocalStrategy(ODatabaseInternal iDatabase)`
`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`	`isOffline()`
`protected boolean`	`isRelatedToLocalServer(ODatabaseInternal iDatabase)`
`protected ODocument`	`loadDatabaseConfiguration(String iDatabaseName, File file, boolean writeCfgToDisk)`
`void`	`onClose(ODatabaseInternal iDatabase)` Remove myself as hook.
`void`	`onCreateClass(ODatabaseInternal iDatabase, OClass iClass)`
`protected void`	`onDatabaseEvent(ODocument config, String databaseName)`
`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`	`propagateSchemaChanges(ODatabaseInternal iDatabase)` Guarantees, foreach class, that has own master cluster.
`protected boolean`	`reassignClustersOwnership(String iNode, ODistributedConfiguration cfg, String databaseName, Set<String> clustersWithNotAvailableOwner, boolean rebalance)`
`protected boolean`	`rebalanceClusterOwnership(String iNode, ODatabaseInternal iDatabase, ODistributedConfiguration cfg, Set<String> clustersWithNotAvailableOwner, boolean rebalance)`
`ODistributedAbstractPlugin`	`registerLifecycleListener(ODistributedLifecycleListener iListener)`
`boolean`	`requestDatabaseDelta(ODistributedDatabaseImpl distrDatabase, String databaseName)`
`protected boolean`	`requestDatabaseFullSync(ODistributedDatabaseImpl distrDatabase, boolean backupDatabase, String databaseName, boolean iAskToAllNodes)`
`protected boolean`	`requestFullDatabase(ODistributedDatabaseImpl distrDatabase, String databaseName, boolean backupDatabase)`
`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)` Sends a distributed request against multiple servers.
`void`	`sendShutdown()`
`void`	`setDefaultDatabaseConfigFile(String iFile)`
`void`	`setNodeStatus(ODistributedServerManager.NODE_STATUS iStatus)`
`void`	`shutdown()`
`void`	`startup()`
`void`	`stopNode(String iNode)`
`String`	`toString()`
`ODistributedAbstractPlugin`	`unregisterLifecycleListener(ODistributedLifecycleListener iListener)`
`boolean`	`updateCachedDatabaseConfiguration(String iDatabaseName, ODocument cfg, boolean iSaveToDisk)`
`void`	`updateLastClusterChange()`
`void`	`waitUntilNodeOnline()`
`void`	`waitUntilNodeOnline(String nodeName, String databaseName)`
`protected long`	`writeDatabaseChunk(int iChunkId, ODistributedDatabaseChunk chunk, OutputStream out)`

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, getConfigurationMap, getDatabaseStatus, getLock, getNodeConfigurationByUuid, setDatabaseStatus, updateCachedDatabaseConfiguration

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

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

enabled
```
protected boolean enabled
```

nodeName
```
protected String nodeName
```

nodeId
```
protected int nodeId
```

defaultDatabaseConfigFile

protected File defaultDatabaseConfigFile

storages

protected ConcurrentHashMap<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

localMessageIdCounter

protected AtomicLong localMessageIdCounter

clusterAssignmentStrategy

protected OClusterOwnershipAssignmentStrategy clusterAssignmentStrategy

lastLSNWriting

protected Map<String,Long> lastLSNWriting

DEPLOY_DB_MAX_RETRIES
```
protected static final int DEPLOY_DB_MAX_RETRIES
```
See Also:

Constant Field Values

activeNodes

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

activeNodesNamesByMemberId

protected Map<String,String> activeNodesNamesByMemberId

registeredNodeById

protected List<String> registeredNodeById

registeredNodeByName

protected Map<String,Integer> registeredNodeByName

messageService

protected ODistributedMessageServiceImpl messageService

startedOn
```
protected Date startedOn
```

taskFactory

protected ORemoteTaskFactory taskFactory

nodeUuid
```
protected String nodeUuid
```

Constructor Detail
- ODistributedAbstractPlugin
```
public ODistributedAbstractPlugin()
```

Method Detail

getLastDatabaseConfiguration

protected abstract ODistributedConfiguration getLastDatabaseConfiguration(String databaseName)

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

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

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

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)

updateCachedDatabaseConfiguration

public boolean updateCachedDatabaseConfiguration(String iDatabaseName,
                                                 ODocument cfg,
                                                 boolean iSaveToDisk)

getDatabaseConfiguration
```
public ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)
```
Specified by:

getDatabaseConfiguration in interface ODistributedServerManager

getDistributedConfigFile

public File getDistributedConfigFile(String iDatabaseName)

getServerInstance
```
public OServer getServerInstance()
```
Specified by:

getServerInstance in interface ODistributedServerManager

loadDatabaseConfiguration

protected ODocument loadDatabaseConfiguration(String iDatabaseName,
                                              File file,
                                              boolean writeCfgToDisk)

getClusterConfiguration
```
public ODocument getClusterConfiguration()
```
Specified by:

getClusterConfiguration in interface ODistributedServerManager

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)

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:

executeOnLocalNode

public Serializable executeOnLocalNode(ODistributedRequestId reqId,
                                       ORemoteTask task,
                                       ODatabaseDocumentTx database)

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

Specified by:: executeOnLocalNode in interface ODistributedServerManager

getRemoteServer

public ORemoteServerController getRemoteServer(String rNodeName)
                                        throws IOException

Specified by:: getRemoteServer in interface ODistributedServerManager
Throws:: IOException

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

updateLastClusterChange
```
public void updateLastClusterChange()
```
Specified by:

updateLastClusterChange in interface ODistributedServerManager

electCurrentNodeAsNewCoordinator

protected boolean electCurrentNodeAsNewCoordinator(ODistributedConfiguration cfg,
                                                   String nodeLeftName,
                                                   String databaseName)

Elects current node as new coordinator.

Parameters:: cfg -; nodeLeftName -

electCurrentNodeAsNewCoordinator

protected boolean electCurrentNodeAsNewCoordinator(String nodeLeftName,
                                                   String nodeToElect,
                                                   String databaseName,
                                                   ODistributedConfiguration cfg)

reassignClustersOwnership

protected boolean reassignClustersOwnership(String iNode,
                                            ODistributedConfiguration cfg,
                                            String databaseName,
                                            Set<String> clustersWithNotAvailableOwner,
                                            boolean rebalance)

getCoordinatorServer

protected String getCoordinatorServer(ODistributedConfiguration cfg)

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

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

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

getAvailableNodes
```
public int getAvailableNodes(String iDatabaseName)
```
Specified by:

getAvailableNodes in interface ODistributedServerManager

installDatabase

public boolean installDatabase(boolean iStartup,
                               String databaseName,
                               ODocument config)

requestFullDatabase

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

requestDatabaseDelta

public boolean requestDatabaseDelta(ODistributedDatabaseImpl distrDatabase,
                                    String databaseName)

requestDatabaseFullSync

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

backupCurrentDatabase

protected void backupCurrentDatabase(String iDatabaseName)

installDatabaseFromNetwork

protected Set<String> installDatabaseFromNetwork(String dbPath,
                                                 String databaseName,
                                                 ODistributedDatabaseImpl distrDatabase,
                                                 String iNode,
                                                 ODistributedDatabaseChunk firstChunk,
                                                 boolean delta)

Returns the clusters where sync is required.

getTaskFactory
```
public ORemoteTaskFactory getTaskFactory()
```
Specified by:

getTaskFactory in interface ODistributedServerManager

propagateSchemaChanges
```
public void propagateSchemaChanges(ODatabaseInternal iDatabase)
```
Guarantees, foreach class, that has own master cluster.

Specified by:

propagateSchemaChanges in interface ODistributedServerManager

installClustersOfClass

public boolean installClustersOfClass(ODatabaseInternal iDatabase,
                                      OClass iClass)

Guarantees that each class has own master cluster.

executeInDistributedDatabaseLock
```
public <T> T executeInDistributedDatabaseLock(String databaseName,
                                              OCallable<T,ODistributedConfiguration> iCallback)
```
Executes an operation protected by a distributed lock (one per database).

Type Parameters:

T - Return type

Parameters:

databaseName - Database name

iCallback - Operation

Returns:

The operation's result of type T

onDatabaseEvent

protected void onDatabaseEvent(ODocument config,
                               String databaseName)

onDatabaseEvent

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

rebalanceClusterOwnership

protected boolean rebalanceClusterOwnership(String iNode,
                                            ODatabaseInternal iDatabase,
                                            ODistributedConfiguration cfg,
                                            Set<String> clustersWithNotAvailableOwner,
                                            boolean rebalance)

installDbClustersLocalStrategy

protected void installDbClustersLocalStrategy(ODatabaseInternal iDatabase)

assignNodeName
```
protected void assignNodeName()
```

writeDatabaseChunk

protected long writeDatabaseChunk(int iChunkId,
                                  ODistributedDatabaseChunk chunk,
                                  OutputStream out)
                           throws IOException

Throws:: IOException

installDatabaseOnLocalNode

protected ODatabaseDocumentTx installDatabaseOnLocalNode(String databaseName,
                                                         String dbPath,
                                                         String iNode,
                                                         String iDatabaseCompressedFile,
                                                         boolean delta)

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

protected 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.

getStorage

protected ODistributedStorage getStorage(String dbName)

Class ODistributedAbstractPlugin

Nested Class Summary

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

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

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

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

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

Field Detail

REPLICATOR_USER

PAR_DEF_DISTRIB_DB_CONFIG

NODE_NAME_ENV

serverInstance

enabled

nodeName

nodeId

defaultDatabaseConfigFile

storages

status

lastClusterChangeOn

listeners

remoteServers

publishLocalNodeConfigurationTask

localMessageIdCounter

clusterAssignmentStrategy

lastLSNWriting

DEPLOY_DB_MAX_RETRIES

activeNodes

activeNodesNamesByMemberId

registeredNodeById

registeredNodeByName

messageService

startedOn

taskFactory

nodeUuid

Constructor Detail

ODistributedAbstractPlugin

Method Detail

getLastDatabaseConfiguration

waitUntilNodeOnline

waitUntilNodeOnline

getPriority

config

setDefaultDatabaseConfigFile

startup

registerLifecycleListener

unregisterLifecycleListener

shutdown

onOpen

onClose

onDrop

onDropClass

getName

sendShutdown

getNodeName

updateCachedDatabaseConfiguration

getDatabaseConfiguration

getDistributedConfigFile

getServerInstance

loadDatabaseConfiguration

getClusterConfiguration

getLocalNodeConfiguration

isEnabled

getNodeStatus

setNodeStatus

checkNodeStatus

sendRequest

executeOnLocalNode

getRemoteServer

getManagedDatabases

getLocalNodeName

getLocalNodeId

onLocalNodeConfigurationRequest

onCreateClass

getStats

getNodeNameById