| Modifier and Type | Method and Description |
|---|---|
ORemoteTask |
ORemoteTaskFactory.createTask(int code) |
ORemoteTask |
ODistributedRequest.getTask() |
ORemoteTask |
OAsynchDistributedOperation.getTask() |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedTxContext.addUndoTask(ORemoteTask undoTask) |
Serializable |
ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId,
ORemoteTask task,
ODatabaseDocumentTx 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)
Sends a distributed request against multiple servers.
|
ODistributedRequest |
ODistributedRequest.setTask(ORemoteTask payload) |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedTxContext.fix(ODatabaseDocumentTx database,
List<ORemoteTask> fixTasks) |
| 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(ORemoteTaskFactory taskFactory,
int senderNodeId,
long msgSequence,
String databaseName,
ORemoteTask payload,
ODistributedRequest.EXECUTION_MODE iExecutionMode) |
| Modifier and Type | Class and Description |
|---|---|
class |
OSynchronizedTaskWrapper
Task wrapper to manage synchronized operations like transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedTxContextImpl.addUndoTask(ORemoteTask undoTask) |
Serializable |
ODistributedAbstractPlugin.executeOnLocalNode(ODistributedRequestId reqId,
ORemoteTask task,
ODatabaseDocumentTx 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
ODistributedTxContextImpl.fix(ODatabaseDocumentTx database,
List<ORemoteTask> fixTasks) |
| Constructor and Description |
|---|
OSynchronizedTaskWrapper(CountDownLatch iLatch,
String iNodeName,
ORemoteTask iTask) |
| Modifier and Type | Class and Description |
|---|---|
class |
OCompletedTxTask
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 |
OReadRecordIfNotLatestTask |
class |
OReadRecordTask
Execute a read of a record from a distributed node.
|
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 |
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 |
OUpdateRecordTask
Distributed updated record task used for synchronization.
|
| Modifier and Type | Method and Description |
|---|---|
void |
OCompletedTxTask.addFixTask(ORemoteTask fixTask) |
ORemoteTask |
OUpdateRecordTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
OTxTask.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 |
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) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
ORemoteTask |
OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
ORemoteTask |
OAbstractReplicatedTask.getUndoTask(ODistributedRequestId reqId) |
| Modifier and Type | Method and Description |
|---|---|
ORemoteTask |
OAbstractReplicatedTask.getFixTask(ODistributedRequest iRequest,
ORemoteTask iOriginalTask,
Object iBadResponse,
Object iGoodResponse,
String executorNodeName,
ODistributedServerManager dManager) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.