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

Class ODistributedPlugin

java.lang.Object

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

All Implemented Interfaces:

OService, ODistributedServerManager, OServerPlugin

public class ODistributedPlugin
extends Object
implements OServerPlugin, ODistributedServerManager

Plugin to manage the distributed environment.

Author:

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

Nested Class Summary

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

ODistributedServerManager.DB_STATUS

Field Summary

Fields

Modifier and Type	Field	Description
protected File	defaultDatabaseConfigFile
protected static final int	DEPLOY_DB_MAX_RETRIES
protected boolean	enabled
protected Set<String>	installingDatabases
protected List<ODistributedLifecycleListener>	listeners
protected static final String	NODE_NAME_ENV
protected static final String	PAR_DEF_DISTRIB_DB_CONFIG
protected OSignalHandler.OSignalListener	signalListener

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

FILE_DISTRIBUTED_DB_CONFIG

Constructor Summary

Constructors

Constructor	Description
ODistributedPlugin()

Method Summary

Modifier and Type	Method	Description
protected void	assignNodeName()
void	closeRemoteServer(ONodeId node)
void	config(OServer oServer, OServerParameterConfiguration[] iParams)	Configures the handler.
void	dumpServersStatus()	Avoids to dump the same configuration twice if it's unchanged since the last time.
protected void	dumpStats()
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabaseImpl	getDatabase(String name)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(ONodeId iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
static String	getListeningBinaryAddress(ONodeConfig cfg)
String	getLocalNodeName()
ODistributedMessageService	getMessageService()
String	getName()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
OServer	getServerInstance()
void	invokeOnDatabaseStatusChange(String node, String databaseName, ODistributedServerManager.DB_STATUS status)
boolean	isEnabled()
void	notifyClients(String databaseName)
void	notifyNodeJoined(ONodeId joinedNodeName)
void	notifyNodeLeft(ONodeId joinedNodeName)
void	onDatabaseEvent(String nodeName, String databaseName, ODistributedServerManager.DB_STATUS status)
void	onNodeJoined(ONodeId joinedNodeId, String url)
void	onServerRemoved(ONodeId nodeName)
ODistributedPlugin	registerLifecycleListener(ODistributedLifecycleListener iListener)
void	sendShutdown()
void	setDefaultDatabaseConfigFile(String iFile)
void	shutdown()
void	startup()
String	toString()
ODistributedPlugin	unregisterLifecycleListener(ODistributedLifecycleListener iListener)

Methods inherited from class java.lang.Object

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

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

getConfigClass, getContent, onAfterClientRequest, onBeforeClientRequest, onClientConnection, onClientDisconnection, onClientError, onSocketAccepted, onSocketDestroyed

Field Details

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

enabled

protected boolean enabled

defaultDatabaseConfigFile

protected File defaultDatabaseConfigFile

listeners

protected List<ODistributedLifecycleListener> listeners

DEPLOY_DB_MAX_RETRIES

protected static final int DEPLOY_DB_MAX_RETRIES

See Also:

• Constant Field Values

installingDatabases

protected Set<String> installingDatabases

signalListener

protected OSignalHandler.OSignalListener signalListener

Constructor Details

ODistributedPlugin

public ODistributedPlugin()

Method Details

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

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

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

getName

public String getName()

Specified by:

getName in interface OService

sendShutdown

public void sendShutdown()

Specified by:

sendShutdown in interface OServerPlugin

getServerInstance

public OServer getServerInstance()

Specified by:

getServerInstance in interface ODistributedServerManager

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface ODistributedServerManager

getLocalNodeName

public String getLocalNodeName()

Specified by:

getLocalNodeName in interface ODistributedServerManager

toString

public String toString()

Overrides:

toString in class Object

getMessageService

public ODistributedMessageService getMessageService()

Specified by:

getMessageService 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 node,
 String databaseName,
 ODistributedServerManager.DB_STATUS status)

assignNodeName

protected void assignNodeName()

closeRemoteServer

public void closeRemoteServer(ONodeId node)

dumpServersStatus

public void dumpServersStatus()

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

getListeningBinaryAddress

public static String getListeningBinaryAddress(ONodeConfig cfg)

dumpStats

protected void dumpStats()

onNodeJoined

public void onNodeJoined(ONodeId joinedNodeId,
 String url)

notifyNodeJoined

public void notifyNodeJoined(ONodeId joinedNodeName)

notifyNodeLeft

public void notifyNodeLeft(ONodeId joinedNodeName)

getDatabaseStatus

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

Specified by:

getDatabaseStatus in interface ODistributedServerManager

onServerRemoved

public void onServerRemoved(ONodeId nodeName)

getClusterConfiguration

public OClusterConfiguration getClusterConfiguration()

Specified by:

getClusterConfiguration in interface ODistributedServerManager

getNodeConfigurationByUuid

public ONodeConfig getNodeConfigurationByUuid(String iNode,
 boolean useCache)

Specified by:

getNodeConfigurationByUuid in interface ODistributedServerManager

getDatabase

public ODistributedDatabaseImpl getDatabase(String name)

Specified by:

getDatabase in interface ODistributedServerManager