Uses of Class
com.orientechnologies.orient.server.distributed.ODistributedRequestId

Packages that use ODistributedRequestId

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
com.orientechnologies.orient.server.hazelcast

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

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

Modifier and Type	Method and Description
ODistributedRequestId	ODistributedRequest.getId()
ODistributedRequestId	ODistributedResponseManager.getMessageId()
ODistributedRequestId	ODistributedResponseManagerImpl.getMessageId()
ODistributedRequestId	ODistributedTxContext.getReqId()
ODistributedRequestId	ODistributedResponse.getRequestId()

Methods in com.orientechnologies.orient.server.distributed that return types with arguments of type ODistributedRequestId

Modifier and Type	Method and Description
OCallable<Void,ODistributedRequestId>	OAsynchDistributedOperation.getAfterSendCallback()
OCallable<Object,OPair<ODistributedRequestId,Object>>	OAsynchDistributedOperation.getCallback()

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

Modifier and Type	Method and Description
Object	ODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database)
boolean	ODistributedDatabase.forceLockRecord(ORID record, ODistributedRequestId requestId) Force the locking of a record.
ODistributedResponseManager	ODistributedMessageService.getResponseManager(ODistributedRequestId reqId)
ODistributedTxContext	ODistributedDatabase.getTxContext(ODistributedRequestId requestId)
boolean	ODistributedDatabase.lockRecord(ORID record, ODistributedRequestId requestId, long timeout) 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.
default void	ODistributedServerManager.messageAfterOp(String op, ODistributedRequestId requestId)
default void	ODistributedServerManager.messageBeforeOp(String op, ODistributedRequestId requestId)
default void	ODistributedServerManager.messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)
default void	ODistributedLifecycleListener.onMessageAfterOp(String op, ODistributedRequestId requestId)
default void	ODistributedLifecycleListener.onMessageBeforeOp(String op, ODistributedRequestId requestId)
default void	ODistributedLifecycleListener.onMessageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)
ODistributedTxContext	ODistributedDatabase.popTxContext(ODistributedRequestId requestId)
ODistributedTxContext	ODistributedDatabase.registerTxContext(ODistributedRequestId reqId)
ODistributedTxContext	ODistributedDatabase.registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	ODistributedRequest.setId(ODistributedRequestId reqId)
void	ODistributedDatabase.unlockRecord(OIdentifiable record, ODistributedRequestId requestId) Unlocks the record previously locked through #lockRecord method.

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

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, OCallable<Void,ODistributedResponseManager> endCallback)
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.

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

Constructor and Description
ODistributedResponse(ODistributedResponseManager msg, ODistributedRequestId iRequestId, String executorNodeName, String senderNodeName, Object payload)

Constructor parameters in com.orientechnologies.orient.server.distributed with type arguments of type ODistributedRequestId

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)

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

Fields in com.orientechnologies.orient.server.distributed.impl declared as ODistributedRequestId

Modifier and Type	Field and Description
protected ODistributedRequestId	ODistributedDatabaseImpl.ODistributedLock.reqId

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

Modifier and Type	Field and Description
protected ConcurrentHashMap<ODistributedRequestId,ODistributedTxContext>	ODistributedDatabaseImpl.activeTxContexts

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

Modifier and Type	Method and Description
protected ODistributedRequestId	ODistributedStorage.acquireRecordLock(ORecordId rid)
ODistributedRequestId	ONewDistributedResponseManager.getMessageId()
ODistributedRequestId	ONewDistributedTxContextImpl.getReqId()
ODistributedRequestId	ODistributedTxContextImpl.getReqId()

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

Modifier and Type	Method and Description
ConcurrentHashMap<ODistributedRequestId,ODistributedTxContext>	ODistributedDatabaseImpl.getActiveTxContexts()

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

Modifier and Type	Method and Description
boolean	ODatabaseDocumentDistributed.beginDistributedTx(ODistributedRequestId requestId, OTransactionInternal tx, boolean local, int retryCount)
boolean	ODatabaseDocumentDistributed.commit2pc(ODistributedRequestId transactionId, boolean local, ODistributedRequestId requestId)
void	ODatabaseDocumentDistributed.commit2pcLocal(ODistributedRequestId transactionId) The Local commit is different from a remote commit due to local rid pre-allocation
Object	OSynchronizedTaskWrapper.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OWaitPartitionsReadyTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
boolean	OExecuteOnce.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
static void	ODistributedTxContextImpl.executeFix(Object me, ODistributedTxContext context, ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks, ODistributedRequestId requestId, ODistributedDatabase ddb)
Object	ODistributedAbstractPlugin.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) Executes the request on local node.
boolean	ODistributedDatabaseImpl.forceLockRecord(ORID rid, ODistributedRequestId requestId)
ODistributedResponseManager	ODistributedMessageServiceImpl.getResponseManager(ODistributedRequestId reqId)
ODistributedTxContext	ODistributedDatabaseImpl.getTxContext(ODistributedRequestId requestId)
boolean	ODistributedDatabaseImpl.lockRecord(ORID rid, ODistributedRequestId requestId, long timeout)
ODistributedTxContext	ODistributedDatabaseImpl.popTxContext(ODistributedRequestId requestId)
ODistributedTxContext	ODistributedDatabaseImpl.registerTxContext(ODistributedRequestId reqId)
ODistributedTxContext	ODistributedDatabaseImpl.registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
protected void	ODistributedStorage.releaseRecordLock(ORecordId rid, ODistributedRequestId requestId)
List<ORecordOperation>	ONewDistributedTransactionManager.retriedCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, ODistributedRequestId requestId)
boolean	ODatabaseDocumentDistributed.rollback2pc(ODistributedRequestId transactionId)
void	ODistributedDatabaseImpl.unlockRecord(OIdentifiable iRecord, ODistributedRequestId requestId)

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

Modifier and Type	Method and Description
ODistributedResponse	ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedResponse	ODistributedDatabaseImpl.send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback, ODistributedResponseManagerFactory responseManagerFactory)
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)

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

Constructor and Description
ODistributedTxContextImpl(ODistributedDatabase iDatabase, ODistributedRequestId iRequestId)
ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared, ODistributedRequestId reqId, OTransactionInternal tx)

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

Fields in com.orientechnologies.orient.server.distributed.impl.task declared as ODistributedRequestId

Modifier and Type	Field and Description
protected ODistributedRequestId	OCompleted2pcTask.requestId

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

Modifier and Type	Method and Description
ODistributedRequestId	OCompleted2pcTask.getRequestId()
ODistributedRequestId	OTransactionPhase2Task.getTransactionId()

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

Modifier and Type	Method and Description
protected Object	OSyncDatabaseDeltaTask.deltaBackup(ODistributedRequestId requestId, ODistributedServerManager iManager, ODatabaseDocumentInternal database, String databaseName)
Object	OCopyDatabaseChunkTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTransactionPhase2Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OClusterRepairInfoTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSQLCommandTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateDatabaseStatusTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncDatabaseDeltaTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OWaitForTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OFetchQueryPageTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCompleted2pcTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODistributedLockTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OStartReplicationTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager dManager, ODatabaseDocumentInternal database)
Object	ORestartServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OStopServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODropDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTxTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OTransactionPhase1Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORunQueryExecutionPlanTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OEnterpriseStatsTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCloseQueryTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORepairClusterTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OScriptTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OGossipTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ORequestDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncClusterTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OSyncDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUnreachableServerLocalTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OReadRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	ODeleteRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OResurrectRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OCreateRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OReadRecordIfNotLatestTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OAbstractReadRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OUpdateRecordTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
static OTransactionResultPayload	OTransactionPhase1Task.executeTransaction(ODistributedRequestId requestId, ODatabaseDocumentDistributed database, OTransactionInternal tx, boolean local, int retryCount)
ORemoteTask	ODeleteRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OSQLCommandTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OAbstract2pcTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairRecordsTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ODistributedLockTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OResurrectRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ODeleteRecordTask	OCreateRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	ORepairClusterTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
ORemoteTask	OUpdateRecordTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
OCompleted2pcTask	OCompleted2pcTask.init(ODistributedRequestId iRequestId, boolean iSuccess, int[] partitionKey)
OCompleted2pcTaskV1	OCompleted2pcTaskV1.init(ODistributedRequestId iRequestId, boolean iSuccess, int[] partitionKey)

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

Constructor and Description
OBackgroundBackup(OSyncDatabaseTask oSyncDatabaseTask, ODistributedServerManager iManager, ODatabaseDocumentInternal database, File resultedBackupFile, String finalBackupPath, OModifiableBoolean incremental, AtomicReference<ODistributedMomentum> momentum, ODistributedDatabase dDatabase, ODistributedRequestId requestId, File completedFile)
OTransactionPhase2Task(ODistributedRequestId transactionId, boolean success, int[] involvedClusters, OLogSequenceNumber lsn)

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

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

Modifier and Type	Method and Description
Object	NodeOperationTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)

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

Fields in com.orientechnologies.orient.server.distributed.task declared as ODistributedRequestId

Modifier and Type	Field and Description
protected ODistributedRequestId	ODistributedRecordLockedException.lockHolder

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

Modifier and Type	Method and Description
ODistributedRequestId	ODistributedRecordLockedException.getLockHolder()

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

Modifier and Type	Method and Description
Object	ORemoteTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
abstract Object	OAbstractRemoteTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
Object	OAbstractRecordReplicatedTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
abstract Object	OAbstractRecordReplicatedTask.executeRecordTask(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
ORemoteTask	OAbstractReplicatedTask.getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)

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

Constructor and Description
ODistributedRecordLockedException(String localNodeName, ORID iRid, ODistributedRequestId iLockingRequestId, long timeout)

Uses of ODistributedRequestId in com.orientechnologies.orient.server.hazelcast

Methods in com.orientechnologies.orient.server.hazelcast with parameters of type ODistributedRequestId

Modifier and Type	Method and Description
void	OHazelcastPlugin.messageAfterOp(String op, ODistributedRequestId request)
void	OHazelcastPlugin.messageBeforeOp(String op, ODistributedRequestId request)
void	OHazelcastPlugin.messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)