Uses of Class
com.orientechnologies.orient.server.distributed.ODistributedRequestId
Packages that use ODistributedRequestId
Package
Description
-
Uses of ODistributedRequestId in com.orientechnologies.agent.operation
Methods in com.orientechnologies.agent.operation that return ODistributedRequestId -
Uses of ODistributedRequestId in com.orientechnologies.orient.server.distributed
Methods in com.orientechnologies.orient.server.distributed that return ODistributedRequestIdModifier and TypeMethodDescriptionODistributedRequest.getId()ODistributedResponseManager.getMessageId()ODistributedResponseManagerImpl.getMessageId()ODistributedTxContext.getReqId()ODistributedResponse.getRequestId()ODistributedServerManager.nextRequestId()Methods in com.orientechnologies.orient.server.distributed that return types with arguments of type ODistributedRequestIdModifier and TypeMethodDescriptionOAsynchDistributedOperation.getAfterSendCallback()OAsynchDistributedOperation.getCallback()Methods in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequestIdModifier and TypeMethodDescriptionODistributedServerManager.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) ODistributedDatabase.getTxContext(ODistributedRequestId requestId) default voidODistributedServerManager.messageAfterOp(String op, ODistributedRequestId requestId) default voidODistributedServerManager.messageBeforeOp(String op, ODistributedRequestId requestId) default voidODistributedServerManager.messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload) default voidODistributedLifecycleListener.onMessageAfterOp(String op, ODistributedRequestId requestId) default voidODistributedLifecycleListener.onMessageBeforeOp(String op, ODistributedRequestId requestId) default voidODistributedLifecycleListener.onMessageCurrentPayload(ODistributedRequestId requestId, Object responsePayload) ODistributedDatabase.popTxContext(ODistributedRequestId requestId) voidODistributedDatabase.reEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay) ODistributedDatabase.registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx) ODistributedServerManager.sendRequest(String iDatabaseName, Collection<String> iTargetNodeNames, ORemoteTask iTask, ODistributedRequestId messageId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory) Constructors in com.orientechnologies.orient.server.distributed with parameters of type ODistributedRequestIdModifierConstructorDescriptionODistributedRequest(ODistributedServerManager manager, ODistributedRequestId requestId, String databaseName, ORemoteTask payload) ODistributedResponse(ODistributedResponseManager msg, ODistributedRequestId iRequestId, String executorNodeName, String senderNodeName, Object payload) Constructor parameters in com.orientechnologies.orient.server.distributed with type arguments of type ODistributedRequestIdModifierConstructorDescriptionOAsynchDistributedOperation(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 with type parameters of type ODistributedRequestIdModifier and TypeFieldDescriptionprotected Map<ODistributedRequestId,ODistributedTxContext> ODistributedDatabaseImpl.activeTxContextsMethods in com.orientechnologies.orient.server.distributed.impl that return ODistributedRequestIdModifier and TypeMethodDescriptionODistributedTxResponseManagerImpl.getMessageId()ODDLContextImpl.getReqId()ONewDistributedTxContextImpl.getReqId()ODistributedPlugin.nextRequestId()Methods in com.orientechnologies.orient.server.distributed.impl that return types with arguments of type ODistributedRequestIdMethods in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedRequestIdModifier and TypeMethodDescriptionbooleanODatabaseDocumentDistributed.beginDistributedTx(ODistributedRequestId requestId, OTransactionIdPromise id, OTransactionInternal tx, boolean isCoordinator, int retryCount) booleanODatabaseDocumentDistributed.commit2pc(ODistributedRequestId transactionId, boolean isCoordinator, ODistributedRequestId requestId) voidODatabaseDocumentDistributed.commit2pcLocal(ODistributedRequestId transactionId) The Local commit is different from a remote commit due to local rid pre-allocationODistributedPlugin.executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database) Executes the request on local node.ODatabaseDocumentDistributed.firstPhaseDDL(String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId) ODistributedDatabaseImpl.getTxContext(ODistributedRequestId requestId) voidODistributedPlugin.messageAfterOp(String op, ODistributedRequestId request) voidODistributedPlugin.messageBeforeOp(String op, ODistributedRequestId request) voidODistributedPlugin.messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload) ODistributedDatabaseImpl.popTxContext(ODistributedRequestId requestId) voidODistributedDatabaseImpl.reEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay) voidODatabaseDocumentDistributed.register(ODistributedRequestId requestId, ODistributedDatabase localDistributedDatabase, ODistributedTxContext txContext) ODistributedDatabaseImpl.registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx) booleanODatabaseDocumentDistributed.rollback2pc(ODistributedRequestId transactionId) voidODatabaseDocumentDistributed.secondPhaseDDL(ODistributedRequestId confirmSentRequest, boolean apply) ODistributedPlugin.sendRequest(String iDatabaseName, Collection<String> iTargetNodes, ORemoteTask iTask, ODistributedRequestId reqId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory) static booleanODistributedDatabaseImpl.sendResponseBack(Object current, ODistributedServerManager manager, ODistributedRequestId iRequestId, Object responsePayload) voidODistributedTxCoordinator.tryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId) Constructors in com.orientechnologies.orient.server.distributed.impl with parameters of type ODistributedRequestIdModifierConstructorDescriptionODDLContextImpl(ODistributedDatabase shared, String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId) ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared, ODistributedRequestId reqId, OTransactionInternal tx, OTransactionIdPromise id) -
Uses of ODistributedRequestId in com.orientechnologies.orient.server.distributed.impl.task
Methods in com.orientechnologies.orient.server.distributed.impl.task that return ODistributedRequestIdModifier and TypeMethodDescriptionOSQLCommandTaskSecondPhase.getConfirmSentRequest()OTransactionPhase2Task.getFirstPhaseId()Methods in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ODistributedRequestIdModifier and TypeMethodDescriptionOCloseQueryTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OCopyDatabaseChunkTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) ODropDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OEnterpriseStatsTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OFetchQueryPageTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OGossipTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) ORequestDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) ORestartServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) ORunQueryExecutionPlanTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OSQLCommandTaskFirstPhase.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OSQLCommandTaskSecondPhase.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OStopServerTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OSyncClusterTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OSyncDatabaseNewDeltaTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OSyncDatabaseTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OTransactionPhase1Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OTransactionPhase2Task.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OUnreachableServerLocalTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OUpdateDatabaseConfigurationTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) OUpdateDatabaseSequenceStatusTask.execute(ODistributedRequestId msgId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) static OTransactionResultPayloadOTransactionPhase1Task.executeTransaction(ODistributedRequestId requestId, OTransactionIdPromise id, ODatabaseDocumentDistributed database, OTransactionInternal tx, boolean isCoordinator, int retryCount) Constructors in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ODistributedRequestIdModifierConstructorDescriptionOBackgroundBackup(OSyncDatabaseTask oSyncDatabaseTask, ODistributedServerManager iManager, ODatabaseDocumentInternal database, File resultedBackupFile, String finalBackupPath, ODistributedRequestId requestId) OSQLCommandTaskSecondPhase(ODistributedRequestId confirmSentRequest, boolean apply) OTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId) -
Uses of ODistributedRequestId in com.orientechnologies.orient.server.distributed.operation
Methods in com.orientechnologies.orient.server.distributed.operation with parameters of type ODistributedRequestIdModifier and TypeMethodDescriptionNodeOperationTask.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 ODistributedRequestIdModifier and TypeFieldDescriptionprotected ODistributedRequestIdODistributedRecordLockedException.lockHolderMethods in com.orientechnologies.orient.server.distributed.task that return ODistributedRequestIdMethods in com.orientechnologies.orient.server.distributed.task with parameters of type ODistributedRequestIdModifier and TypeMethodDescriptionORemoteTask.execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) Constructors in com.orientechnologies.orient.server.distributed.task with parameters of type ODistributedRequestIdModifierConstructorDescriptionODistributedRecordLockedException(String localNodeName, ORID iRid, ODistributedRequestId iLockingRequestId, long timeout)