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

Class ODistributedPlugin

java.lang.Object

com.orientechnologies.orient.server.plugin.OServerPluginAbstract

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

All Implemented Interfaces:

OService, ODistributedServerManager, OServerPlugin

Direct Known Subclasses:

OHazelcastPlugin

public class ODistributedPlugin
extends OServerPluginAbstract
implements ODistributedServerManager

Plugin to manage the distributed environment.

Author:

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

Nested Class Summary

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

ODistributedServerManager.DB_STATUS

Field Summary

Fields

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

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

enabled

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

FILE_DISTRIBUTED_DB_CONFIG

Constructor Summary

Constructors

Constructor	Description
ODistributedPlugin()

Method Summary

Modifier and Type	Method	Description
protected void	assignNodeName()
protected int	calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType, ODistributedConfiguration cfg, int totalServers, int totalMasterServers, int onlineMasters, boolean checkNodesAreOnline, String localNodeName)
protected void	checkForServerOnline(ODistributedRequest iRequest)
void	closeRemoteServer(String node)
void	config(OServer oServer, OServerParameterConfiguration[] iParams)	Configures the handler.
void	connectToAllNodes(Set<String> clusterNodes)
void	dumpServersStatus()	Avoids to dump the same configuration twice if it's unchanged since the last time.
protected void	dumpStats()
Set<String>	getActiveServers()
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabaseImpl	getDatabase(String name)
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
com.hazelcast.core.HazelcastInstance	getHazelcastInstance()
long	getLastClusterChangeOn()
static String	getListeningBinaryAddress(ONodeConfig cfg)
ONodeConfig	getLocalNodeConfiguration()
String	getLocalNodeName()
ODistributedMessageService	getMessageService()
String	getName()
long	getNextMessageIdCounter()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
ORemoteServerController	getRemoteServer(String rNodeName)
OServer	getServerInstance()
void	invokeOnDatabaseStatusChange(String node, String databaseName, ODistributedServerManager.DB_STATUS status)
boolean	isEnabled()
ODistributedRequestId	nextRequestId()
void	notifyClients(String databaseName)
void	notifyNodeJoined(String joinedNodeName)
void	notifyNodeLeft(String joinedNodeName)
void	onDatabaseEvent(String nodeName, String databaseName, ODistributedServerManager.DB_STATUS status)
void	onNodeJoined(String joinedNodeName, String url, com.hazelcast.core.Member member)
void	onServerRemoved(String nodeName)
ODistributedPlugin	registerLifecycleListener(ODistributedLifecycleListener iListener)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodes, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodes, ORemoteTask iTask, ODistributedRequestId reqId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
void	sendShutdown()
ODistributedResponse	sendSingleRequest(String databaseName, String node, ORemoteTask iTask)	Sends a distributed request against multiple servers.
void	setDefaultDatabaseConfigFile(String iFile)
void	setDistributedStrategy(ODistributedStrategy streatgy)
void	shutdown()
void	startup()
String	toString()
ODistributedPlugin	unregisterLifecycleListener(ODistributedLifecycleListener iListener)
void	updateLastClusterChange()
protected boolean	waitForLocalNode(ODistributedConfiguration cfg, Collection<String> iNodes)
protected ODistributedResponse	waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr)

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

getContent, onAfterClientRequest, onBeforeClientRequest, onClientConnection, onClientDisconnection, onClientError

Methods inherited from class java.lang.Object

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

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

onSocketAccepted, onSocketDestroyed

Field Details

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

DEPLOY_DB_MAX_RETRIES

protected static final int DEPLOY_DB_MAX_RETRIES

See Also:

• Constant Field Values

installingDatabases

protected Set<String> installingDatabases

responseManagerFactory

protected ODistributedStrategy responseManagerFactory

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

Overrides:

config in class OServerPluginAbstract

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

getName

public String getName()

Specified by:

getName in interface OService

sendShutdown

public void sendShutdown()

Specified by:

sendShutdown in interface OServerPlugin

Overrides:

sendShutdown in class OServerPluginAbstract

getServerInstance

public OServer getServerInstance()

Specified by:

getServerInstance in interface ODistributedServerManager

getLocalNodeConfiguration

public ONodeConfig getLocalNodeConfiguration()

Specified by:

getLocalNodeConfiguration in interface ODistributedServerManager

getDatabaseConfiguration

public ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)

Specified by:

getDatabaseConfiguration in interface ODistributedServerManager

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface ODistributedServerManager

sendRequest

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

Description copied from interface: ODistributedServerManager

Sends a distributed request against multiple servers.

Specified by:

sendRequest in interface ODistributedServerManager

Parameters:

iDatabaseName -

iTargetNodes -

iTask -

Returns:

sendSingleRequest

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

Description copied from interface: ODistributedServerManager

Sends a distributed request against multiple servers.

Specified by:

sendSingleRequest in interface ODistributedServerManager

Parameters:

databaseName -

node -

iTask -

Returns:

sendRequest

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

Specified by:

sendRequest in interface ODistributedServerManager

checkForServerOnline

protected void checkForServerOnline(ODistributedRequest iRequest)
                             throws ODistributedException

Throws:

ODistributedException

send2Nodes

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

waitForResponse

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

Throws:

InterruptedException

calculateQuorum

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

send2Nodes

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

waitForLocalNode

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

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

getActiveServers

public Set<String> getActiveServers()

Specified by:

getActiveServers in interface ODistributedServerManager

getDistributedStrategy

public ODistributedStrategy getDistributedStrategy()

Specified by:

getDistributedStrategy in interface ODistributedServerManager

setDistributedStrategy

public void setDistributedStrategy(ODistributedStrategy streatgy)

Specified by:

setDistributedStrategy in interface ODistributedServerManager

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

nextRequestId

public ODistributedRequestId nextRequestId()

Specified by:

nextRequestId in interface ODistributedServerManager

getNextMessageIdCounter

public long getNextMessageIdCounter()

Specified by:

getNextMessageIdCounter in interface ODistributedServerManager

updateLastClusterChange

public void updateLastClusterChange()

Specified by:

updateLastClusterChange in interface ODistributedServerManager

closeRemoteServer

public void closeRemoteServer(String node)

dumpServersStatus

public void dumpServersStatus()

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

getListeningBinaryAddress

public static String getListeningBinaryAddress(ONodeConfig cfg)

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

onNodeJoined

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

notifyNodeJoined

public void notifyNodeJoined(String joinedNodeName)

notifyNodeLeft

public void notifyNodeLeft(String joinedNodeName)

connectToAllNodes

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

Throws:

IOException

getDatabaseStatus

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

Specified by:

getDatabaseStatus in interface ODistributedServerManager

onServerRemoved

public void onServerRemoved(String 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

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

getDatabase

public ODistributedDatabaseImpl getDatabase(String name)

Specified by:

getDatabase in interface ODistributedServerManager