Uses of Interface
com.orientechnologies.orient.server.distributed.task.ORemoteTask

Packages that use ORemoteTask

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

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

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

Modifier and Type	Method and Description
ORemoteTask	ORemoteTaskFactory.createTask(int code)
ORemoteTask	OAsynchDistributedOperation.getTask()
ORemoteTask	ODistributedRequest.getTask()

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

Modifier and Type	Method and Description
void	ODistributedTxContext.addUndoTask(ORemoteTask undoTask)
Object	ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database)
ODistributedResponse	ODistributedServerManager.sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodeNames, ORemoteTask iTask, long messageId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback) Sends a distributed request against multiple servers.
ODistributedRequest	ODistributedRequest.setTask(ORemoteTask payload)

Method parameters in com.orientechnologies.orient.server.distributed with type arguments of type ORemoteTask

Modifier and Type	Method and Description
void	ODistributedTxContext.fix(ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks)

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

Constructor and Description
OAsynchDistributedOperation(String iDatabaseName, Set<String> iClusterNames, Collection<String> iNodes, ORemoteTask iTask, long iMessageId, Object iLocalResult, OCallable<Void,ODistributedRequestId> iAfterRequestCallback, OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback)
ODistributedRequest(ODistributedServerManager manager, int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload)

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

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

Modifier and Type	Class and Description
class	OSynchronizedTaskWrapper Task wrapper to manage synchronized operations like transactions.

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

Modifier and Type	Method and Description
void	ODistributedTxContextImpl.addUndoTask(ORemoteTask undoTask)
Object	ODistributedAbstractPlugin.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) Executes the request on local node.
ODistributedResponse	ODistributedAbstractPlugin.sendRequest(String iDatabaseName, Collection<String> iClusterNames, Collection<String> iTargetNodes, ORemoteTask iTask, long reqId, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)

Method parameters in com.orientechnologies.orient.server.distributed.impl with type arguments of type ORemoteTask

Modifier and Type	Method and Description
static void	ODistributedTxContextImpl.executeFix(Object me, ODistributedTxContext context, ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks, ODistributedRequestId requestId, ODistributedDatabase ddb)
void	ODistributedTxContextImpl.fix(ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks)

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

Constructor and Description
OSynchronizedTaskWrapper(CountDownLatch iLatch, String iNodeName, ORemoteTask iTask)

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

Classes in com.orientechnologies.orient.server.distributed.impl.task that implement ORemoteTask

Modifier and Type	Class and Description
class	OAbstract2pcTask Distributed two phase commit task.
class	OAbstractReadRecordTask Abstract class for distributed reads.
class	OAbstractSyncDatabaseTask Abstract task for synchronization of database from a remote node.
class	OClusterRepairInfoTask Returns the range of positions for a cluster.
class	OCompleted2pcTask Task to manage the end of distributed transaction when no fix is needed (OFixTxTask) and all the locks must be released.
class	OCompleted2pcTaskV1 Task to manage the end of distributed transaction when no fix is needed (OFixTxTask) and all the locks must be released.
class	OCopyDatabaseChunkTask Ask for a database chunk.
class	OCreateRecordTask Distributed create record task used for synchronization.
class	ODeleteRecordTask Distributed delete record task used for synchronization.
class	ODistributedLockTask Task to acquire and release a distributed exclusive lock across the entire cluster.
class	ODropDatabaseTask Distributed task to drop a database on all the servers.
class	OEnterpriseStatsTask Distributed message between server to exchange stats.
class	OFixCreateRecordTask Fix for distributed delete record task.
class	OFixUpdateRecordTask Fix a distributed updated.
class	OGossipTask Gossip message between server to exchange lock manager server and update latency table.
class	OReadRecordIfNotLatestTask
class	OReadRecordTask Execute a read of a record from a distributed node.
class	ORepairClusterTask Repairs a cluster through the distributed server.
class	ORepairRecordsTask Repairs records through the distributed server.
class	ORequestDatabaseConfigurationTask Task to request last database configuration across all the servers.
class	ORestartServerTask Distributed task to restart a node.
class	OResurrectRecordTask Distributed task to fix delete record in conflict on synchronization.
class	OScriptTask Executes a script on distributed servers.
class	OSQLCommandTask Distributed task used for synchronization.
class	OStartReplicationTask Start the replication with a server.
class	OStopServerTask Distributed task to stop a server.
class	OSyncClusterTask Ask for deployment of single cluster from a remote node.
class	OSyncDatabaseDeltaTask Ask for synchronization of delta of chanegs on database from a remote node.
class	OSyncDatabaseTask Ask for synchronization of database from a remote node.
class	OTxTask Distributed transaction task.
class	OUnreachableServerLocalTask Task executed when a server becomes unreachable.
class	OUpdateDatabaseConfigurationTask Task to update the database configuration across all the servers.
class	OUpdateDatabaseStatusTask Task to update the database status across all the servers.
class	OUpdateRecordTask Distributed updated record task used for synchronization.
class	OWaitForTask Task implementation that waits for a task to be completed.

Fields in com.orientechnologies.orient.server.distributed.impl.task with type parameters of type ORemoteTask

Modifier and Type	Field and Description
protected List<ORemoteTask>	OCompleted2pcTask.fixTasks

Methods in com.orientechnologies.orient.server.distributed.impl.task that return ORemoteTask

Modifier and Type	Method and Description
ORemoteTask	ODefaultRemoteTaskFactoryV1.createTask(int code)
ORemoteTask	ODefaultRemoteTaskFactoryV0.createTask(int code)
ORemoteTask	ODefaultRemoteTaskFactoryV2.createTask(int code)
ORemoteTask	OResurrectRecordTask.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	OAbstract2pcTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	ODeleteRecordTask.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	ORepairRecordsTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	OSQLCommandTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OResurrectRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OUpdateRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OAbstract2pcTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ODeleteRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ODistributedLockTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairClusterTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairRecordsTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)

Methods in com.orientechnologies.orient.server.distributed.impl.task that return types with arguments of type ORemoteTask

Modifier and Type	Method and Description
List<ORemoteTask>	OCompleted2pcTask.getFixTasks()

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

Modifier and Type	Method and Description
void	OCompleted2pcTask.addFixTask(ORemoteTask fixTask)
ORemoteTask	OResurrectRecordTask.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	OAbstract2pcTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)
ORemoteTask	ODeleteRecordTask.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	ORepairRecordsTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)

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

Classes in com.orientechnologies.orient.server.distributed.task that implement ORemoteTask

Modifier and Type	Class and Description
class	OAbstractCommandTask Base class for Replicated command tasks.
class	OAbstractRecordReplicatedTask Distributed create record task used for synchronization.
class	OAbstractRemoteTask Base class for Tasks to be executed remotely.
class	OAbstractReplicatedTask Base class for Replicated tasks.

Methods in com.orientechnologies.orient.server.distributed.task that return ORemoteTask

Modifier and Type	Method and Description
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)

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

Modifier and Type	Method and Description
ORemoteTask	OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest, ORemoteTask iOriginalTask, Object iBadResponse, Object iGoodResponse, String executorNodeName, ODistributedServerManager dManager)