| Package | Description |
|---|---|
| com.orientechnologies.orient.server.distributed | |
| com.orientechnologies.orient.server.distributed.task |
| Modifier and Type | Method and Description |
|---|---|
ODistributedRequestId |
ODistributedRequest.getId() |
ODistributedRequestId |
ODistributedTxContext.getReqId() |
ODistributedRequestId |
ODistributedResponse.getRequestId() |
ODistributedRequestId |
ODistributedDatabase.lockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord,
ODistributedRequestId iRequestId)
Locks the record to be sure distributed transactions never work concurrently against the same records in the meanwhile the
transaction is executed and the OCompleteTxTask is not arrived.
|
| Modifier and Type | Method and Description |
|---|---|
com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> |
OAsynchDistributedOperation.getAfterSendCallback() |
com.orientechnologies.common.util.OCallable<Object,com.orientechnologies.common.util.OPair<ODistributedRequestId,Object>> |
OAsynchDistributedOperation.getCallback() |
| Modifier and Type | Method and Description |
|---|---|
Serializable |
ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId,
ORemoteTask task,
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database) |
ODistributedRequestId |
ODistributedDatabase.lockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord,
ODistributedRequestId iRequestId)
Locks the record to be sure distributed transactions never work concurrently against the same records in the meanwhile the
transaction is executed and the OCompleteTxTask is not arrived.
|
ODistributedTxContext |
ODistributedDatabase.popTxContext(ODistributedRequestId requestId) |
ODistributedTxContext |
ODistributedDatabase.registerTxContext(ODistributedRequestId reqId) |
void |
ODistributedRequest.setId(ODistributedRequestId reqId) |
void |
ODistributedDatabase.unlockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord,
ODistributedRequestId requestId)
Unlocks the record previously locked through #lockRecord method.
|
| Modifier and Type | Method and Description |
|---|---|
ODistributedResponse |
ODistributedDatabase.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
ODistributedResponse |
ODistributedServerManager.sendRequest(String iDatabaseName,
Collection<String> iClusterNames,
Collection<String> iTargetNodeNames,
ORemoteTask iTask,
long messageId,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterSentCallback)
Sends a distributed request against multiple servers.
|
| Constructor and Description |
|---|
ODistributedResponse(ODistributedRequestId iRequestId,
String executorNodeName,
String senderNodeName,
Serializable payload) |
| Constructor and Description |
|---|
OAsynchDistributedOperation(String iDatabaseName,
Set<String> iClusterNames,
Collection<String> iNodes,
ORemoteTask iTask,
long iMessageId,
Object iLocalResult,
com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
com.orientechnologies.common.util.OCallable<Object,com.orientechnologies.common.util.OPair<ODistributedRequestId,Object>> iCallback) |
OAsynchDistributedOperation(String iDatabaseName,
Set<String> iClusterNames,
Collection<String> iNodes,
ORemoteTask iTask,
long iMessageId,
Object iLocalResult,
com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
com.orientechnologies.common.util.OCallable<Object,com.orientechnologies.common.util.OPair<ODistributedRequestId,Object>> iCallback) |
| Modifier and Type | Field and Description |
|---|---|
protected ODistributedRequestId |
ODistributedRecordLockedException.lockHolder |
| Modifier and Type | Method and Description |
|---|---|
ODistributedRequestId |
ODistributedRecordLockedException.getLockHolder() |
| Modifier and Type | Method and Description |
|---|---|
abstract Object |
OAbstractRemoteTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database) |
Object |
ORemoteTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database) |
Object |
OAbstractRecordReplicatedTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database) |
abstract Object |
OAbstractRecordReplicatedTask.executeRecordTask(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx database) |
ORemoteTask |
OAbstractReplicatedTask.getUndoTask(ODistributedRequestId reqId) |
| Constructor and Description |
|---|
ODistributedRecordLockedException(com.orientechnologies.orient.core.id.ORID iRid,
ODistributedRequestId iLockingRequestId) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.