Package com.orientechnologies.orient.distributed.db

Class OrientDBDistributed

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBEmbedded

com.orientechnologies.orient.distributed.db.OrientDBDistributed

All Implemented Interfaces:

OrientDBInternal, OSchedulerInternal, ODatabaseStateChangeListener, OOperationContext, ONetworkDiscover, OServerAware, AutoCloseable

public class OrientDBDistributed
extends OrientDBEmbedded
implements OServerAware, ODatabaseStateChangeListener, OOperationContext, ONetworkDiscover

Created by tglman on 08/08/17.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

OrientDBEmbedded.DatabaseFound

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	localMessageIdCounter

Fields inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

allGroups, basePath, bootTime, cachedPoolFactory, orient, pools, sharedContexts, threadsGroup

Constructor Summary

Constructors

Constructor	Description
OrientDBDistributed(String directoryPath, OrientDBConfig config, Orient instance)

Method Summary

Modifier and Type	Method	Description
void	acceptSync(OSyncId syncId, OSyncMode mode)
void	autoAssignAllocation(ODatabaseId dbId)
void	autoDeployIfNeed()
void	cancelMergeToNetwork(OTransactionIdPromise promise)
void	canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
void	checkNodeIsMaster(ONodeId localNodeId, String name, String operation)
void	close()	Close the factory with all related databases and pools.
void	closeRemoteServer(ONodeId node)
void	closeRemoteServer(String node)
<T> T	configOp(ODistributedConfigurationManager cm, String database, com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)
void	connected(ONodeId node, String url)
ORemoteServerController	connectRemoteServer(ONodeId node, String url)
void	coordinatedOperation(OOperationMessage operation, OCompleteExecution execution)
void	create(String name, String user, String password, ODatabaseType type, ODatabaseId id, OrientDBConfig config, ODatabaseTask<Void> createOps)
protected OSharedContextEmbedded	createSharedContext(OStorage storage)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Future<Optional<OAcceptResult>>	declareDatabaseFlow(String name, ODatabaseId dbId)
boolean	deltaSync(String dbName, InputStream backupStream, OrientDBConfig config)
void	disconnected(ONodeId node)
void	distributedDrop(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	distributedSetOnline(OSharedContextEmbedded ctx)
void	drop(String name, String user, String password)	Drop a database
static void	dropStorageFiles(OStorage storage)
void	dumpNodeInfo()
void	establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	firstConnect(ONodeId nodeId, ONodeStateNetwork state, boolean merge, ONodeInfo info)
int	getActiveDatabaseCount()
Set<String>	getActiveDatabases()
Set<String>	getAvailableNodeNames(String name)
Set<String>	getAvailableNodeNotLocalNames(String name)
OClusterConfiguration	getClusterConfiguration()
ODistributedConfigurationManager	getConfigurationManager(String database)
ODistributedDatabaseImpl	getDatabase(String iDatabaseName)
ODatabaseState	getDatabaseState(ODatabaseId dbId, ONodeId node)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(ONodeId nodeId, String dbName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String dbName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String node, String dbName)
ODistributedConfiguration	getDefaultDistributedConfiguration(String database)
ODistributedConfiguration	getDistributedConfiguration(String database)
Collection<ODistributedDatabaseImpl>	getDistributedDatabases()
ODistributedServerManager	getDistributedManager()
ODistributedConfiguration	getExistingDistributedConfiguration(String database)
ONodeConfig	getLocalNodeConfiguration()
ODistributedMessageService	getMessageService()
long	getNextMessageIdCounter()
ONodeId	getNodeId()
ONodeInfo	getNodeInfo()
String	getNodeName()
ONodeState	getNodeState()
int	getNodesWithStatus(Collection<String> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)	Returns the nodes with the requested status.
int	getOnlineMasters(String databaseName)
List<String>	getOnlineNodesNotLocal(String dbName)
OCoordinatedDistributedOps	getOps()
ODistributedConfigurationManager	getOrInitConfigurationManager(String database)
ODistributedConfiguration	getOrInitDistributedConfiguration(ODatabaseSession session)
ODistributedPlugin	getPlugin()
ORemoteServerController	getRemoteServer(ONodeId nodeId)
ORemoteServerController	getRemoteServer(String rNodeName)
OServer	getServer()
Optional<OSharedContextEmbedded>	getSharedDatabaseContext(String database)
ORemoteTaskFactoryManager	getTaskFactoryManager()
void	gracefulWaitFullStartup()
void	init(OServer server)
void	initDistributed(ONodeConfiguration config)
void	initDistributed(String nodeName, String groupIdPar, int miminumQuorum, String password)
Future<Boolean>	installDatabase(String databaseName, boolean force, boolean tryWithDeltaFirst)
void	internalDrop(String name)
boolean	isDatabaseOnline(String dbName)
protected boolean	isDistributedDisabled()
boolean	isDistributedDisabled(String storage)
boolean	isDistributedOnline()
boolean	isNodeAvailable(String targetNode, String databaseName)
boolean	isNodeMaster(String node, String databaseName)
boolean	isNodeOnline(String targetNode, String databaseName)
void	loadAllDatabases()
void	mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	mergeNodeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	mergeToNetwork(OTransactionIdPromise promise)
OStandardCompleteAction	newCompleteAction(OOperationMessage operation, OCompleteExecution execution)
protected ODatabaseDocumentEmbedded	newCreateSessionInstance(OStorage storage, OrientDBConfig config)
ONetworkMessage	newNetworkMessage()
ONetworkMessage	newNetworkMessageRequest()
ONetworkMessage	newNetworkMessageResponse()
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, String name)
ORecoordinateCompleteAction	newRecoordinateAction(OOperationMessage operation)
ORetryInfo	newRetryInfo()
protected ODatabaseDocumentEmbedded	newSessionInstance(String database, OrientDBConfig config)
void	nextBuffer(OSyncId syncId, boolean close)
ODistributedRequestId	nextRequestId()
boolean	nonBlockingSync(String name, ODatabaseId databaseId, InputStream backupStream, OrientDBConfig config)
protected ODatabaseDocumentEmbedded	onlyOpenNoAuthorization(String name)
void	onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state)
ODatabaseDocumentInternal	open(String name, String user, String password)	Open a database specified by name using the username and password if needed
ODatabaseDocumentInternal	open(String name, String user, String password, OrientDBConfig config)	Open a database specified by name using the username and password if needed, with specific configuration
void	receiveMessage(OStructuralMessage op)
void	receivePing(ONodeId nodeId, OTransactionSequenceStatus status)
void	receiveRecovery(List<OConfirmedRetryOp> ops)
boolean	receiveSync(String dbName, OSyncState state, InputStream inputStream, OrientDBConfig conf)
void	receiveSyncData(OSyncId syncId, byte[] data, long sequential, boolean finished)
void	reconciliateState()
void	recoordinateOperation(OTransactionIdPromise promise, OOperationMessage op)
void	registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
boolean	removeDatabaseMember(ODatabaseId databaseId, ONodeId node)
void	requestNext(OSyncState state, boolean close)
void	restartNode(String iNode)
void	retryExecution(ORetryOperation operation, OCompleteExecution exec, int delay, Optional<OAcceptResult> result)
void	retryMergeOperationMessages(ONodeId mergeNode, ONodeStateNetwork mergedState, ONodeStateNetwork original, OOperationMessage operation, OCompleteAction action, int delay)
void	retryOperation(OOperationMessage operation, OCompleteAction action, int delay)
Future<Optional<OAcceptResult>>	retryOperation(ORetryOperation operation)
void	saveDatabaseConfiguration(String database)
void	sendBuffer(OSyncState state, byte[] data, long sequential, boolean finished)
void	sendDatabase(OSyncId syncId, OCanSyncAccept mode)
void	sendEstablish(OGroupId groupId, Set<ONodeId> candidates, OCompleteExecution execution)
void	sendFirstConnects(Set<ONodeId> nodes)
void	sendMergeNodeAction(ONodeId node, ONodeStateNetwork state, OCompleteExecution execution)
void	sendMergeOperation(ONodeId requestToMerge, OCompleteExecution execution)
void	sendMessage(ONodeId node, OStructuralMessage op)
void	sendMessage(Set<ONodeId> set, OStructuralMessage op)
void	sendTopologyTransactions(ONodeId nodeId, List<OTransactionId> transactions)
Future<Optional<OAcceptResult>>	setDatabaseNodeRole(ODatabaseId databaseId, String serverName, String role)
Future<Optional<OAcceptResult>>	setDatabaseQuorum(ODatabaseId databaseId, int newQuorum)
void	setDatabaseStatus(ONodeId nodeId, String dbName, ODistributedServerManager.DB_STATUS status)
void	setDatabaseStatus(String dbName, ODistributedServerManager.DB_STATUS status)
void	setDistributedConfiguration(String database, OModifiableDistributedConfiguration distributedConfiguration)
void	setPlugin(ODistributedPlugin plugin)
void	stopNode(String iNode)
void	syncBackup(String name, OSyncState state, OutputStream output)
boolean	tryUpdatingDatabaseConfigurationLocally(String database, OModifiableDistributedConfiguration cfg)
ODistributedDatabaseImpl	unregisterDatabase(String iDatabaseName)
void	validateDatabaseStatus(String databaseName, OTransactionSequenceStatus status)
void	validateMergeToNetwork(OGroupId group, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
boolean	waitOnline(String database)

Methods inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

buildName, cachedPool, cachedPool, checkDatabaseName, checkOpen, create, create, createCachedDatabasePoolFactory, createSharedContext, delayExecute, endCommand, excutorBaseSize, excutorMaxSize, execute, execute, execute, executeNoAuthorization, executeNoAuthorizationOnActive, executeNoDb, executeServerStatement, executeServerStatement, exists, forceDatabaseClose, getBasePath, getBoolConfig, getConfigurations, getConnectionUrl, getDatabasePath, getDefaultEngine, getEngine, getIntConfig, getIoExecutor, getLongConfig, getOrCreateSharedContext, getScriptManager, getSecuritySystem, getStorage, getStorages, getSystemDatabase, initAutoClose, initCustomStorage, initEngines, internalClose, internalCreate, isEmbedded, isMemoryOnly, isOpen, listDatabases, listLodadedDatabases, networkRestore, open, openNoAuthenticate, openNoAuthorization, openPool, openPool, periodicExecute, poolOpen, preClose, removePool, removeShutdownHook, restore, restore, runOnThread, schedule, scheduleExecuteFrom, scheduleOnce, solveConfig, startCommand

Methods inherited from class java.lang.Object

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

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

newOrientDB, newOrientDBNoClose

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

delayExecute, scheduleFrom

Field Details

localMessageIdCounter

protected AtomicLong localMessageIdCounter

Constructor Details

OrientDBDistributed

public OrientDBDistributed(String directoryPath,
 OrientDBConfig config,
 Orient instance)

Method Details

init

public void init(OServer server)

Specified by:

init in interface OServerAware

initDistributed

public void initDistributed(ONodeConfiguration config)

initDistributed

public void initDistributed(String nodeName,
 String groupIdPar,
 int miminumQuorum,
 String password)

reconciliateState

public void reconciliateState()

onStateChange

public void onStateChange(ODatabaseId dbId,
 ONodeId nodeId,
 ODatabaseState state)

Specified by:

onStateChange in interface ODatabaseStateChangeListener

dumpNodeInfo

public void dumpNodeInfo()

autoAssignAllocation

public void autoAssignAllocation(ODatabaseId dbId)

loadAllDatabases

public void loadAllDatabases()

Specified by:

loadAllDatabases in interface OrientDBInternal

Overrides:

loadAllDatabases in class OrientDBEmbedded

getPlugin

public ODistributedPlugin getPlugin()

createSharedContext

protected OSharedContextEmbedded createSharedContext(OStorage storage)

Overrides:

createSharedContext in class OrientDBEmbedded

newSessionInstance

protected ODatabaseDocumentEmbedded newSessionInstance(String database,
 OrientDBConfig config)

Overrides:

newSessionInstance in class OrientDBEmbedded

isDistributedDisabled

public boolean isDistributedDisabled(String storage)

isDistributedDisabled

protected boolean isDistributedDisabled()

newCreateSessionInstance

protected ODatabaseDocumentEmbedded newCreateSessionInstance(OStorage storage,
 OrientDBConfig config)

Overrides:

newCreateSessionInstance in class OrientDBEmbedded

onlyOpenNoAuthorization

protected ODatabaseDocumentEmbedded onlyOpenNoAuthorization(String name)

Overrides:

onlyOpenNoAuthorization in class OrientDBEmbedded

newPooledSessionInstance

protected ODatabaseDocumentEmbedded newPooledSessionInstance(ODatabasePoolInternal pool,
 String name)

Overrides:

newPooledSessionInstance in class OrientDBEmbedded

setPlugin

public void setPlugin(ODistributedPlugin plugin)

nonBlockingSync

public boolean nonBlockingSync(String name,
 ODatabaseId databaseId,
 InputStream backupStream,
 OrientDBConfig config)

internalDrop

public void internalDrop(String name)

Specified by:

internalDrop in interface OrientDBInternal

Overrides:

internalDrop in class OrientDBEmbedded

drop

public void drop(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Drop a database

Specified by:

drop in interface OrientDBInternal

Overrides:

drop in class OrientDBEmbedded

Parameters:

name - database name

user - the username of a user allowed to drop a database, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

sendMessage

public void sendMessage(Set<ONodeId> set,
 OStructuralMessage op)

sendMessage

public void sendMessage(ONodeId node,
 OStructuralMessage op)

receiveMessage

public void receiveMessage(OStructuralMessage op)

open

public ODatabaseDocumentInternal open(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed

Specified by:

open in interface OrientDBInternal

Overrides:

open in class OrientDBEmbedded

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

Returns:

the opened database

open

public ODatabaseDocumentInternal open(String name,
 String user,
 String password,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed, with specific configuration

Specified by:

open in interface OrientDBInternal

Overrides:

open in class OrientDBEmbedded

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

config - database specific configuration that override the factory global settings where needed.

Returns:

the opened database

dropStorageFiles

public static void dropStorageFiles(OStorage storage)

getDistributedManager

public ODistributedServerManager getDistributedManager()

Specified by:

getDistributedManager in interface OServerAware

deltaSync

public boolean deltaSync(String dbName,
 InputStream backupStream,
 OrientDBConfig config)

Specified by:

deltaSync in interface OrientDBInternal

getNodeName

public String getNodeName()

getDatabase

public ODistributedDatabaseImpl getDatabase(String iDatabaseName)

getSharedDatabaseContext

public Optional<OSharedContextEmbedded> getSharedDatabaseContext(String database)

unregisterDatabase

public ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)

create

public void create(String name,
 String user,
 String password,
 ODatabaseType type,
 ODatabaseId id,
 OrientDBConfig config,
 ODatabaseTask<Void> createOps)

Specified by:

create in interface OrientDBInternal

Overrides:

create in class OrientDBEmbedded

declareDatabaseFlow

public Future<Optional<OAcceptResult>> declareDatabaseFlow(String name,
 ODatabaseId dbId)

retryOperation

public Future<Optional<OAcceptResult>> retryOperation(ORetryOperation operation)

retryExecution

public void retryExecution(ORetryOperation operation,
 OCompleteExecution exec,
 int delay,
 Optional<OAcceptResult> result)

getDatabaseState

public ODatabaseState getDatabaseState(ODatabaseId dbId,
 ONodeId node)

isDatabaseOnline

public boolean isDatabaseOnline(String dbName)

distributedSetOnline

public void distributedSetOnline(OSharedContextEmbedded ctx)

Overrides:

distributedSetOnline in class OrientDBEmbedded

getActiveDatabases

public Set<String> getActiveDatabases()

getDistributedDatabases

public Collection<ODistributedDatabaseImpl> getDistributedDatabases()

getOrInitDistributedConfiguration

public ODistributedConfiguration getOrInitDistributedConfiguration(ODatabaseSession session)

getOrInitConfigurationManager

public ODistributedConfigurationManager getOrInitConfigurationManager(String database)

getConfigurationManager

public ODistributedConfigurationManager getConfigurationManager(String database)

configOp

public <T> T configOp(ODistributedConfigurationManager cm,
 String database,
 com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)

getExistingDistributedConfiguration

public ODistributedConfiguration getExistingDistributedConfiguration(String database)

getDefaultDistributedConfiguration

public ODistributedConfiguration getDefaultDistributedConfiguration(String database)

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration(String database)

setDistributedConfiguration

public void setDistributedConfiguration(String database,
 OModifiableDistributedConfiguration distributedConfiguration)

saveDatabaseConfiguration

public void saveDatabaseConfiguration(String database)

tryUpdatingDatabaseConfigurationLocally

public boolean tryUpdatingDatabaseConfigurationLocally(String database,
 OModifiableDistributedConfiguration cfg)

close

public void close()

Description copied from interface: OrientDBInternal

Close the factory with all related databases and pools.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OrientDBInternal

Overrides:

close in class OrientDBEmbedded

getActiveDatabaseCount

public int getActiveDatabaseCount()

getMessageService

public ODistributedMessageService getMessageService()

newCompleteAction

public OStandardCompleteAction newCompleteAction(OOperationMessage operation,
 OCompleteExecution execution)

newRecoordinateAction

public ORecoordinateCompleteAction newRecoordinateAction(OOperationMessage operation)

newRetryInfo

public ORetryInfo newRetryInfo()

retryOperation

public void retryOperation(OOperationMessage operation,
 OCompleteAction action,
 int delay)

coordinatedOperation

public void coordinatedOperation(OOperationMessage operation,
 OCompleteExecution execution)

getNodeState

public ONodeState getNodeState()

getOps

public OCoordinatedDistributedOps getOps()

Specified by:

getOps in interface OOperationContext

newNetworkMessage

public ONetworkMessage newNetworkMessage()

Specified by:

newNetworkMessage in interface OrientDBInternal

firstConnect

public void firstConnect(ONodeId nodeId,
 ONodeStateNetwork state,
 boolean merge,
 ONodeInfo info)

connected

public void connected(ONodeId node,
 String url)

Specified by:

connected in interface ONetworkDiscover

registerNode

public void registerNode(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

Specified by:

registerNode in interface OOperationContext

declareDatabase

public void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<OAddNodeInfo> partecipants,
 int minimumQuorum)

Specified by:

declareDatabase in interface OOperationContext

acceptSync

public void acceptSync(OSyncId syncId,
 OSyncMode mode)

canSync

public void canSync(ONodeId sender,
 OSyncId syncId,
 OCanSyncAccept canSync)

receiveSync

public boolean receiveSync(String dbName,
 OSyncState state,
 InputStream inputStream,
 OrientDBConfig conf)

sendDatabase

public void sendDatabase(OSyncId syncId,
 OCanSyncAccept mode)

syncBackup

public void syncBackup(String name,
 OSyncState state,
 OutputStream output)

sendBuffer

public void sendBuffer(OSyncState state,
 byte[] data,
 long sequential,
 boolean finished)

receiveSyncData

public void receiveSyncData(OSyncId syncId,
 byte[] data,
 long sequential,
 boolean finished)

requestNext

public void requestNext(OSyncState state,
 boolean close)

nextBuffer

public void nextBuffer(OSyncId syncId,
 boolean close)

getNodeId

public ONodeId getNodeId()

Specified by:

getNodeId in interface OrientDBInternal

Overrides:

getNodeId in class OrientDBEmbedded

closeRemoteServer

public void closeRemoteServer(String node)

closeRemoteServer

public void closeRemoteServer(ONodeId node)

getRemoteServer

public ORemoteServerController getRemoteServer(ONodeId nodeId)

getRemoteServer

public ORemoteServerController getRemoteServer(String rNodeName)

connectRemoteServer

public ORemoteServerController connectRemoteServer(ONodeId node,
 String url)
                                            throws IOException

Throws:

IOException

setDatabaseStatus

public void setDatabaseStatus(ONodeId nodeId,
 String dbName,
 ODistributedServerManager.DB_STATUS status)

setDatabaseStatus

public void setDatabaseStatus(String dbName,
 ODistributedServerManager.DB_STATUS status)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(ONodeId nodeId,
 String dbName)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String node,
 String dbName)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String dbName)

getServer

public OServer getServer()

getNextMessageIdCounter

public long getNextMessageIdCounter()

installDatabase

public Future<Boolean> installDatabase(String databaseName,
 boolean force,
 boolean tryWithDeltaFirst)

getAvailableNodeNotLocalNames

public Set<String> getAvailableNodeNotLocalNames(String name)

getAvailableNodeNames

public Set<String> getAvailableNodeNames(String name)

getOnlineMasters

public int getOnlineMasters(String databaseName)

establish

public void establish(OGroupId groupId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

Specified by:

establish in interface OOperationContext

sendFirstConnects

public void sendFirstConnects(Set<ONodeId> nodes)

getOnlineNodesNotLocal

public List<String> getOnlineNodesNotLocal(String dbName)

getNodesWithStatus

public int getNodesWithStatus(Collection<String> iNodes,
 String databaseName,
 ODistributedServerManager.DB_STATUS... statuses)

Returns the nodes with the requested status.

isNodeOnline

public boolean isNodeOnline(String targetNode,
 String databaseName)

isNodeAvailable

public boolean isNodeAvailable(String targetNode,
 String databaseName)

sendMergeOperation

public void sendMergeOperation(ONodeId requestToMerge,
 OCompleteExecution execution)

autoDeployIfNeed

public void autoDeployIfNeed()

sendEstablish

public void sendEstablish(OGroupId groupId,
 Set<ONodeId> candidates,
 OCompleteExecution execution)

sendMergeNodeAction

public void sendMergeNodeAction(ONodeId node,
 ONodeStateNetwork state,
 OCompleteExecution execution)

retryMergeOperationMessages

public void retryMergeOperationMessages(ONodeId mergeNode,
 ONodeStateNetwork mergedState,
 ONodeStateNetwork original,
 OOperationMessage operation,
 OCompleteAction action,
 int delay)

validateMergeToNetwork

public void validateMergeToNetwork(OGroupId group,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

cancelMergeToNetwork

public void cancelMergeToNetwork(OTransactionIdPromise promise)

mergeToNetwork

public void mergeToNetwork(OTransactionIdPromise promise)

mergeNodeResult

public void mergeNodeResult(ONodeId node,
 OTransactionIdPromise promise,
 Optional<OAcceptResult> accepted)

disconnected

public void disconnected(ONodeId node)

recoordinateOperation

public void recoordinateOperation(OTransactionIdPromise promise,
 OOperationMessage op)

Specified by:

recoordinateOperation in interface OOperationContext

receivePing

public void receivePing(ONodeId nodeId,
 OTransactionSequenceStatus status)

checkNodeIsMaster

public void checkNodeIsMaster(ONodeId localNodeId,
 String name,
 String operation)

isNodeMaster

public boolean isNodeMaster(String node,
 String databaseName)

removeDatabaseMember

public boolean removeDatabaseMember(ODatabaseId databaseId,
 ONodeId node)

distributedDrop

public void distributedDrop(ODatabaseId dbId,
 OVersion version,
 OTransactionIdPromise promise)

Specified by:

distributedDrop in interface OOperationContext

waitOnline

public boolean waitOnline(String database)
                   throws InterruptedException

Specified by:

waitOnline in interface OrientDBInternal

Throws:

InterruptedException

mergeNode

public void mergeNode(ONodeId node,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

Specified by:

mergeNode in interface OOperationContext

setDatabaseNodeRole

public Future<Optional<OAcceptResult>> setDatabaseNodeRole(ODatabaseId databaseId,
 String serverName,
 String role)

setDatabaseQuorum

public Future<Optional<OAcceptResult>> setDatabaseQuorum(ODatabaseId databaseId,
 int newQuorum)

gracefulWaitFullStartup

public void gracefulWaitFullStartup()
                             throws InterruptedException

Specified by:

gracefulWaitFullStartup in interface OrientDBInternal

Throws:

InterruptedException

isDistributedOnline

public boolean isDistributedOnline()

Specified by:

isDistributedOnline in interface OrientDBInternal

getNodeInfo

public ONodeInfo getNodeInfo()

getClusterConfiguration

public OClusterConfiguration getClusterConfiguration()

getLocalNodeConfiguration

public ONodeConfig getLocalNodeConfiguration()

newNetworkMessageRequest

public ONetworkMessage newNetworkMessageRequest()

Specified by:

newNetworkMessageRequest in interface OrientDBInternal

newNetworkMessageResponse

public ONetworkMessage newNetworkMessageResponse()

Specified by:

newNetworkMessageResponse in interface OrientDBInternal

validateDatabaseStatus

public void validateDatabaseStatus(String databaseName,
 OTransactionSequenceStatus status)

sendTopologyTransactions

public void sendTopologyTransactions(ONodeId nodeId,
 List<OTransactionId> transactions)

receiveRecovery

public void receiveRecovery(List<OConfirmedRetryOp> ops)

nextRequestId

public ODistributedRequestId nextRequestId()

stopNode

public void stopNode(String iNode)

restartNode

public void restartNode(String iNode)

getTaskFactoryManager

public ORemoteTaskFactoryManager getTaskFactoryManager()