Uses of Interface
com.orientechnologies.orient.server.distributed.ODistributedServerManager

Packages that use ODistributedServerManager

Package	Description
com.orientechnologies.orient.server
com.orientechnologies.orient.server.distributed
com.orientechnologies.orient.server.distributed.conflict
com.orientechnologies.orient.server.distributed.impl
com.orientechnologies.orient.server.distributed.impl.metadata
com.orientechnologies.orient.server.distributed.impl.task
com.orientechnologies.orient.server.distributed.operation
com.orientechnologies.orient.server.distributed.task
com.orientechnologies.orient.server.hazelcast

Uses of ODistributedServerManager in com.orientechnologies.orient.server

Fields in com.orientechnologies.orient.server declared as ODistributedServerManager

Modifier and Type	Field and Description
protected ODistributedServerManager	OServer.distributedManager

Methods in com.orientechnologies.orient.server that return ODistributedServerManager

Modifier and Type	Method and Description
ODistributedServerManager	OServer.getDistributedManager()

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed

Methods in com.orientechnologies.orient.server.distributed that return ODistributedServerManager

Modifier and Type	Method and Description
ODistributedServerManager	ORemoteServerChannel.getManager()
ODistributedServerManager	ODistributedDatabase.getManager()
ODistributedServerManager	ODistributedServerManager.registerLifecycleListener(ODistributedLifecycleListener iListener)
ODistributedServerManager	ODistributedServerManager.unregisterLifecycleListener(ODistributedLifecycleListener iListener)

Methods in com.orientechnologies.orient.server.distributed with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
Set<ORecordId>	ODistributedTxContext.cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
Set<String>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes, String databaseName, Object localResult)

Constructors in com.orientechnologies.orient.server.distributed with parameters of type ODistributedServerManager

Constructor and Description
ODistributedRequest(ODistributedServerManager manager)
ODistributedRequest(ODistributedServerManager manager, int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload)
ODistributedResponseManagerImpl(ODistributedServerManager iManager, ODistributedRequest iRequest, Collection<String> expectedResponses, Set<String> iNodesConcurInQuorum, int iTotalExpectedResponses, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, long iTotalTimeout, boolean iGroupResponsesByResult, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedSyncConfiguration(ODistributedServerManager manager, String databaseName, File file)
ORemoteServerChannel(ODistributedServerManager manager, String iServer, String iURL, String user, String passwd, int currentProtocolVersion)
ORemoteServerController(ODistributedServerManager manager, String iServer, String iURL, String user, String passwd)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.conflict

Methods in com.orientechnologies.orient.server.distributed.conflict with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
ODistributedConflictResolver.OConflictResult	OQuorumDistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates)
ODistributedConflictResolver.OConflictResult	OContentDistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates)
ODistributedConflictResolver.OConflictResult	ODistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> groupedServerValues) Called on distributed conflict.
ODistributedConflictResolver.OConflictResult	ODCDistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates)
ODistributedConflictResolver.OConflictResult	OVersionDistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates)
ODistributedConflictResolver.OConflictResult	OMajorityDistributedConflictResolver.onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.impl

Classes in com.orientechnologies.orient.server.distributed.impl that implement ODistributedServerManager

Modifier and Type	Class and Description
class	ODistributedAbstractPlugin Abstract plugin to manage the distributed environment.

Fields in com.orientechnologies.orient.server.distributed.impl declared as ODistributedServerManager

Modifier and Type	Field and Description
protected ODistributedServerManager	ODistributedWorker.manager

Methods in com.orientechnologies.orient.server.distributed.impl that return ODistributedServerManager

Modifier and Type	Method and Description
ODistributedServerManager	ODistributedStorage.getDistributedManager()
ODistributedServerManager	ODistributedDatabaseImpl.getManager()

Methods in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
static void	ODistributedTransactionManager.acquireMultipleRecordLocks(Object iThis, ODistributedServerManager dManager, List<ORecordId> recordsToLock, ODistributedStorageEventListener eventListener, ODistributedTxContext reqContext, long timeout)
Set<ORecordId>	ONewDistributedTxContextImpl.cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
Set<ORecordId>	ODistributedTxContextImpl.cancel(ODistributedServerManager dManager, ODatabaseDocumentInternal database)
Object	OSynchronizedTaskWrapper.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OWaitPartitionsReadyTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
boolean	OExecuteOnce.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
static String	ODistributedOutput.formatClusterTable(ODistributedServerManager manager, String databaseName, ODistributedConfiguration cfg, int totalConfiguredServers)
static String	ODistributedOutput.formatServerStatus(ODistributedServerManager manager, ODocument distribCfg)
static String	ODistributedOutput.getCompactServerStatus(ODistributedServerManager manager, ODocument distribCfg) Create a compact string with all the relevant information.
Set<String>	ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, ODistributedConfiguration cfg, ODistributedRequest request, Collection<String> iNodes, String databaseName, Object localResult)
static boolean	ODistributedWorker.sendResponseBack(Object current, ODistributedServerManager manager, ODistributedRequest iRequest, Object responsePayload)

Constructors in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedServerManager

Constructor and Description
OClusterHealthChecker(ODistributedServerManager manager, long healthCheckerEveryMs)
OConflictResolverDatabaseRepairer(ODistributedServerManager manager, String databaseName)
ODistributedLockManagerExecutor(ODistributedServerManager manager)
ODistributedLockManagerRequester(ODistributedServerManager manager)
ONewDistributedTransactionManager(ODistributedStorage storage, ODistributedServerManager manager, ODistributedDatabase iDDatabase)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.impl.metadata

Methods in com.orientechnologies.orient.server.distributed.impl.metadata with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
ODistributedConfiguration	OClassDistributed.readConfiguration(ODatabaseDocumentDistributed db, ODistributedServerManager manager)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.impl.task

Methods in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
protected ODistributedDatabase	OSyncDatabaseDeltaTask.checkIfCurrentDatabaseIsNotOlder(ODistributedServerManager iManager, String databaseName, ODatabaseDocumentInternal database)
protected ODistributedDatabase	OSyncDatabaseTask.checkIfCurrentDatabaseIsNotOlder(ODistributedServerManager iManager, String databaseName, ODatabaseDocumentInternal database)
void	ODistributedLockTask.checkIsValid(ODistributedServerManager dManager)
protected ODistributedDatabase	OAbstractSyncDatabaseTask.databaseIsOld(ODistributedServerManager iManager, String databaseName, ODistributedDatabase dDatabase)
protected Object	OSyncDatabaseDeltaTask.deltaBackup(ODistributedRequestId requestId, ODistributedServerManager iManager, ODatabaseDocumentInternal database, String databaseName)
Object	OCopyDatabaseChunkTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTransactionPhase2Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OClusterRepairInfoTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSQLCommandTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateDatabaseStatusTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncDatabaseDeltaTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OWaitForTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OFetchQueryPageTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCompleted2pcTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODistributedLockTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OStartReplicationTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager dManager, ODatabaseDocumentInternal database)
Object	ORestartServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OStopServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODropDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTxTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTransactionPhase1Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORunQueryExecutionPlanTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OEnterpriseStatsTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCloseQueryTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORepairClusterTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OScriptTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OGossipTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORequestDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncClusterTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUnreachableServerLocalTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OReadRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODeleteRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OResurrectRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCreateRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OReadRecordIfNotLatestTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OAbstractReadRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
ORemoteTask	ODeleteRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OAbstract2pcTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	ORepairRecordsTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OResurrectRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OCreateRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNode, ODistributedServerManager dManager)
ORemoteTask	ORepairClusterTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OUpdateRecordTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	ODeleteRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OSQLCommandTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OAbstract2pcTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairRecordsTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ODistributedLockTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OResurrectRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ODeleteRecordTask	OCreateRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairClusterTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OUpdateRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
void	ODistributedLockTask.undo(ODistributedServerManager iManager)

Constructors in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ODistributedServerManager

Constructor and Description
OBackgroundBackup(OSyncDatabaseTask oSyncDatabaseTask, ODistributedServerManager iManager, ODatabaseDocumentInternal database, File resultedBackupFile, String finalBackupPath, OModifiableBoolean incremental, AtomicReference<ODistributedMomentum> momentum, ODistributedDatabase dDatabase, ODistributedRequestId requestId, File completedFile)
ORemoteTaskFactoryManagerImpl(ODistributedServerManager dManager)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.operation

Methods in com.orientechnologies.orient.server.distributed.operation with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
void	NodeOperationTask.checkIsValid(ODistributedServerManager dManager)
Object	NodeOperationTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
NodeOperationResponse	NodeOperation.execute(OServer iServer, ODistributedServerManager iManager)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.distributed.task

Methods in com.orientechnologies.orient.server.distributed.task with parameters of type ODistributedServerManager

Modifier and Type	Method and Description
void	ORemoteTask.checkIsValid(ODistributedServerManager dManager) Checks the request is still valid.
void	OAbstractRemoteTask.checkIsValid(ODistributedServerManager dManager)
Object	ORemoteTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
abstract Object	OAbstractRemoteTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OAbstractRecordReplicatedTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
abstract Object	OAbstractRecordReplicatedTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
ORemoteTask	OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OAbstractReplicatedTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)

Uses of ODistributedServerManager in com.orientechnologies.orient.server.hazelcast

Classes in com.orientechnologies.orient.server.hazelcast that implement ODistributedServerManager

Modifier and Type	Class and Description
class	OHazelcastPlugin Hazelcast implementation for clustering.