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.operation
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
Object	ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database)
void	ODistributedDatabase.reEnqueue(int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
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)

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.
class	OWaitPartitionsReadyTask

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

Modifier and Type	Method and Description
ORemoteTask	OWaitPartitionsReadyTask.getInternal()
ORemoteTask	OExecuteOnce.getToRun()

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

Modifier and Type	Method and Description
Object	ODistributedAbstractPlugin.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) Executes the request on local node.
ODistributedResponse	ODatabaseDocumentDistributed.executeTaskOnNode(ORemoteTask task, String nodeName)
ODistributedResponseManager	ODistributedDatabaseImpl.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
void	ODistributedDatabaseImpl.reEnqueue(int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
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)
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, ODistributedResponseManagerFactory responseManagerFactory)
void	ODistributedDatabaseImpl.waitIsReady(ORemoteTask task)

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

Constructor and Description
OExecuteOnce(CountDownLatch start, ORemoteTask toRun)
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	OAbstractSyncDatabaseTask Abstract task for synchronization of database from a remote node.
class	OCloseQueryTask Created by luigidellaquila on 28/06/17.
class	OCopyDatabaseChunkTask Ask for a database chunk.
class	ODropDatabaseTask Distributed task to drop a database on all the servers.
class	OEnterpriseStatsTask Distributed message between server to exchange stats.
class	OFetchQueryPageTask Created by luigidellaquila on 28/06/17.
class	OGossipTask Task to manage the end of distributed transaction when no fix is needed (OFixTxTask) and all the locks must be released.
class	ONewSQLCommandTask
class	ORequestDatabaseConfigurationTask Task to request last database configuration across all the servers.
class	ORestartServerTask Distributed task to restart a node.
class	ORunQueryExecutionPlanTask Created by luigidellaquila on 23/06/17.
class	OScriptTask Executes a script on distributed servers.
class	OSQLCommandTask Distributed task used for synchronization.
class	OStopServerTask Distributed task to stop a server.
class	OSyncClusterTask Ask for deployment of single cluster from a remote node.
class	OSyncDatabaseNewDeltaTask
class	OSyncDatabaseTask Ask for synchronization of database from a remote node.
class	OTransactionPhase1Task
class	OTransactionPhase2Task
class	OUnreachableServerLocalTask Task executed when a server becomes unreachable.
class	OUpdateDatabaseConfigurationTask Task to update the database configuration across all the servers.
class	OUpdateDatabaseSequenceStatusTask
class	OUpdateDatabaseStatusTask Task to update the database status across all the servers.

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

Modifier and Type	Method and Description
ORemoteTask	ODefaultRemoteTaskFactoryV3.createTask(int code)
ORemoteTask	OSQLCommandTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)

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

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

Modifier and Type	Class and Description
class	NodeOperationTask

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