| Modifier and Type | Method and Description |
|---|---|
ODistributedRequestId |
ODistributedRequest.getId() |
ODistributedRequestId |
ODistributedTxContext.getReqId() |
ODistributedRequestId |
ODistributedResponse.getRequestId() |
ODistributedRequestId |
ODistributedDatabase.lockRecord(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 |
|---|---|
OCallable<Void,ODistributedRequestId> |
OAsynchDistributedOperation.getAfterSendCallback() |
OCallable<Object,OPair<ODistributedRequestId,Object>> |
OAsynchDistributedOperation.getCallback() |
| Modifier and Type | Method and Description |
|---|---|
Serializable |
ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId,
ORemoteTask task,
ODatabaseDocumentTx database) |
ODistributedRequestId |
ODistributedDatabase.lockRecord(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(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,
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,
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,
OCallable<Void,ODistributedRequestId> iAfterRequestCallback,
OCallable<Object,OPair<ODistributedRequestId,Object>> iCallback) |
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) |
| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentHashMap<ODistributedRequestId,ODistributedTxContextImpl> |
ODistributedDatabaseImpl.activeTxContexts |
protected ConcurrentHashMap<ORID,ODistributedRequestId> |
ODistributedDatabaseImpl.lockManager |
| Modifier and Type | Method and Description |
|---|---|
protected ODistributedRequestId |
ODistributedStorage.acquireRecordLock(ORecordId rid) |
ODistributedRequestId |
ODistributedResponseManager.getMessageId() |
ODistributedRequestId |
ODistributedTxContextImpl.getReqId() |
ODistributedRequestId |
ODistributedDatabaseImpl.lockRecord(OIdentifiable iRecord,
ODistributedRequestId iRequestId) |
| Modifier and Type | Method and Description |
|---|---|
Object |
OSynchronizedTaskWrapper.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
Serializable |
ODistributedAbstractPlugin.executeOnLocalNode(ODistributedRequestId reqId,
ORemoteTask task,
ODatabaseDocumentTx database)
Executes the request on local node.
|
ODistributedRequestId |
ODistributedDatabaseImpl.lockRecord(OIdentifiable iRecord,
ODistributedRequestId iRequestId) |
ODistributedTxContext |
ODistributedDatabaseImpl.popTxContext(ODistributedRequestId requestId) |
protected boolean |
ODistributedTransactionManager.processCommitResult(String localNodeName,
OTransaction iTx,
OTxTask txTask,
Set<String> involvedClusters,
Iterable<ORecordOperation> tmpEntries,
Collection<String> nodes,
int autoRetryDelay,
ODistributedRequestId reqId,
ODistributedResponse dResponse,
boolean isLastRetry) |
ODistributedTxContext |
ODistributedDatabaseImpl.registerTxContext(ODistributedRequestId reqId) |
void |
ODistributedDatabaseImpl.unlockRecord(OIdentifiable iRecord,
ODistributedRequestId requestId) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ODistributedTransactionManager.executeAsyncTx(Set<String> nodes,
OTxTaskResult localResult,
Set<String> involvedClusters,
OAbstractReplicatedTask txTask,
long messageId,
String localNodeName,
OCallable<Void,ODistributedRequestId> afterSendCallback) |
ODistributedResponse |
ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedRequest.EXECUTION_MODE iExecutionMode,
Object localResult,
OCallable<Void,ODistributedRequestId> iAfterSentCallback) |
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) |
| Constructor and Description |
|---|
ODistributedTxContextImpl(ODistributedDatabase iDatabase,
ODistributedRequestId iRequestId) |
| Constructor and Description |
|---|
OCompletedTxTask(ODistributedRequestId iRequestId,
boolean iSuccess) |
| 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 |
|---|---|
Object |
OAbstractRecordReplicatedTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
abstract Object |
OAbstractRemoteTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
Object |
ORemoteTask.execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
abstract Object |
OAbstractRecordReplicatedTask.executeRecordTask(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
ORemoteTask |
OAbstractReplicatedTask.getUndoTask(ODistributedRequestId reqId) |
| Constructor and Description |
|---|
ODistributedRecordLockedException(ORID iRid,
ODistributedRequestId iLockingRequestId) |
Copyright © 2009–2016 Orient Technologies. All rights reserved.