Uses of Class
com.orientechnologies.orient.core.transaction.OTransactionIdPromise

Packages that use OTransactionIdPromise

Package	Description
com.orientechnologies.orient.core.transaction
com.orientechnologies.orient.distributed.context
com.orientechnologies.orient.distributed.context.coordination.message
com.orientechnologies.orient.distributed.db
com.orientechnologies.orient.server.distributed
com.orientechnologies.orient.server.distributed.impl
com.orientechnologies.orient.server.distributed.impl.task

Uses of OTransactionIdPromise in com.orientechnologies.orient.core.transaction

Methods in com.orientechnologies.orient.core.transaction that return OTransactionIdPromise

Modifier and Type	Method	Description
OTransactionIdPromise	OTransactionSequenceManager.nextAt(int pos)	This is public only for testing purposes
static OTransactionIdPromise	OTransactionIdPromise.readNetwork(DataInput input)

Methods in com.orientechnologies.orient.core.transaction that return types with arguments of type OTransactionIdPromise

Modifier and Type	Method	Description
Optional<OTransactionIdPromise>	OTransactionSequenceManager.next()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	OTransactionSequenceManager.nextDDL()	As today DDLs are not atomic, so we used two sequential for pre-operation and post operation to assert that the DDL was completed, as soon as DDLs will be atomic we can revert to a single sequential
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	OTransactionSequenceManager.nextDDL()	As today DDLs are not atomic, so we used two sequential for pre-operation and post operation to assert that the DDL was completed, as soon as DDLs will be atomic we can revert to a single sequential

Methods in com.orientechnologies.orient.core.transaction with parameters of type OTransactionIdPromise

Modifier and Type	Method	Description
boolean	OTransactionSequenceManager.notifyFailure(OTransactionIdPromise promise)
ValidationResult	OTransactionSequenceManager.notifySuccess(OTransactionIdPromise promise)
ValidationResult	OTransactionSequenceManager.validate(OTransactionIdPromise promise)

Uses of OTransactionIdPromise in com.orientechnologies.orient.distributed.context

Methods in com.orientechnologies.orient.distributed.context that return OTransactionIdPromise

Modifier and Type	Method	Description
OTransactionIdPromise	ODistributedResponse.getPromise()
OTransactionIdPromise	OOperationStart.promise()	Returns the value of the promise record component.
OTransactionIdPromise	OResponseCollector.CompleteInfo.promise()	Returns the value of the promise record component.
OTransactionIdPromise	ONodeState.startEnstablish(Set<ONodeId> nodes, OCompleteAction action)

Methods in com.orientechnologies.orient.distributed.context with parameters of type OTransactionIdPromise

Modifier and Type	Method	Description
void	ONodeState.complete(OTransactionIdPromise promise)
void	OCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all)
void	OCoordinatedDistributedOps.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOpsImpl.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	ONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODistributedMessage	OPromisedDistributedOps.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOps.getPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	ONodeState.receiveFailure(OTransactionIdPromise promise)
ODistributedMessage	ONodeState.receiveSuccess(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOps.removeNotPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOpsImpl.removeNotPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOps.removePromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOpsImpl.removePromised(OTransactionIdPromise promise)
OOperationStart	OCoordinatedDistributedOps.start(OTransactionIdPromise promise, OCompleteAction action)
OOperationStart	OCoordinatedDistributedOpsImpl.start(OTransactionIdPromise promise, OCompleteAction action)
void	OCoordinatedDistributedOps.startEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action)
void	OCoordinatedDistributedOpsImpl.startEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action)
void	OCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	OCoordinatedDistributedOps.success(ONodeId node, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.success(ONodeId node, OTransactionIdPromise promise)
void	ONodeState.success(ONodeId node, OTransactionIdPromise promise)
void	ONodeState.waitComplete(OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context with parameters of type OTransactionIdPromise

Modifier	Constructor	Description
	CompleteInfo(OCompleteAction action, OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)	Creates an instance of a CompleteInfo record class.
	OOperationStart(OTransactionIdPromise promise, Set<ONodeId> nodes, Future<Optional<OAcceptResult>> result)	Creates an instance of a OOperationStart record class.
	OResponseCollector(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> activeNodes)

Uses of OTransactionIdPromise in com.orientechnologies.orient.distributed.context.coordination.message

Methods in com.orientechnologies.orient.distributed.context.coordination.message that return OTransactionIdPromise

Modifier and Type	Method	Description
OTransactionIdPromise	OConfirmOp.getPromise()
OTransactionIdPromise	OFailOp.getPromise()
OTransactionIdPromise	OFailPropose.getPromise()
OTransactionIdPromise	OSuccessPropose.getPromise()
OTransactionIdPromise	ODistributedMessage.getPromiseId()
OTransactionIdPromise	OProposeOp.getPromiseId()

Constructors in com.orientechnologies.orient.distributed.context.coordination.message with parameters of type OTransactionIdPromise

Modifier	Constructor	Description
	OConfirmOp(OTransactionIdPromise promise)
	OFailOp(OTransactionIdPromise promise)
	OFailPropose(ONodeId nodeId, OTransactionIdPromise promise, OAcceptResult acceptResult)
	OProposeOp(OTransactionIdPromise promise, OOperationMessage op)
	OSuccessPropose(ONodeId nodeId, OTransactionIdPromise promise)

Uses of OTransactionIdPromise in com.orientechnologies.orient.distributed.db

Methods in com.orientechnologies.orient.distributed.db with parameters of type OTransactionIdPromise

Modifier and Type	Method	Description
void	OStandardCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all)
void	OStandardCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)

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

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

Modifier and Type	Method	Description
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedDatabase.nextDDLId()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedDatabase.nextDDLId()
Optional<OTransactionIdPromise>	ODistributedDatabase.nextId()

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

Modifier and Type	Method	Description
OTxMetadataHolder	ODistributedDatabase.commit(OTransactionIdPromise id)
void	ODistributedDatabase.rollback(OTransactionIdPromise id)
ValidationResult	ODistributedDatabase.validate(OTransactionIdPromise id)

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

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

Modifier and Type	Method	Description
OTransactionIdPromise	ODDLContextImpl.getAfterChangePromise()
OTransactionIdPromise	ODDLContextImpl.getPreChangePromise()
OTransactionIdPromise	ONewDistributedTxContextImpl.getPromise()

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

Modifier and Type	Method	Description
Optional<OTransactionIdPromise>	ODistributedSynchronizedSequence.next()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedSynchronizedSequence.nextDDL()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedSynchronizedSequence.nextDDL()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedDatabaseImpl.nextDDLId()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedDatabaseImpl.nextDDLId()
Optional<OTransactionIdPromise>	ODistributedDatabaseImpl.nextId()

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

Modifier and Type	Method	Description
boolean	ODatabaseDocumentDistributed.beginDistributedTx(ODistributedRequestId requestId, OTransactionIdPromise id, OTransactionInternal tx, boolean isCoordinator, int retryCount)
OTxMetadataHolder	ODistributedDatabaseImpl.commit(OTransactionIdPromise id)
protected OTransactionPhase1Task	ODistributedTxCoordinator.createTxPhase1Task(OTransactionIdPromise id, OTransactionInternal transaction)
OTransactionResultPayload	ODatabaseDocumentDistributed.firstPhaseDDL(String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId)
void	ODistributedSynchronizedSequence.notifyFailure(OTransactionIdPromise id)
OTxMetadataHolderImpl	ODistributedSynchronizedSequence.notifySuccess(OTransactionIdPromise id)	This make sure that there is a synchronization between the apply of the status of transactions sequence and the logging of it in the database, to avoid to have in the status a transaction that has not yet been logged.
void	ODistributedDatabaseImpl.rollback(OTransactionIdPromise id)
void	ODistributedTxCoordinator.tryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId)
ValidationResult	ODistributedDatabaseImpl.validate(OTransactionIdPromise id)
ValidationResult	ODistributedSynchronizedSequence.validate(OTransactionIdPromise id)

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

Modifier	Constructor	Description
	ODDLContextImpl(ODistributedDatabase shared, String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId)
	ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared, ODistributedRequestId reqId, OTransactionInternal tx, OTransactionIdPromise id)

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

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

Modifier and Type	Method	Description
OTransactionIdPromise	OSQLCommandTaskFirstPhase.getAfterChangeId()
OTransactionIdPromise	OSQLCommandTaskFirstPhase.getPreChangeId()
OTransactionIdPromise	OTransactionPhase1Task.getPromise()

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

Modifier and Type	Method	Description
static OTransactionResultPayload	OTransactionPhase1Task.executeTransaction(ODistributedRequestId requestId, OTransactionIdPromise id, ODatabaseDocumentDistributed database, OTransactionInternal tx, boolean isCoordinator, int retryCount)
void	OTransactionPhase1Task.init(OTransactionIdPromise transactionId, OTransactionInternal tx)

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

Modifier	Constructor	Description
	OSQLCommandTaskFirstPhase(String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId)
	OTransactionPhase1Task(List<ORecordOperation> ops, OTransactionIdPromise promise, SortedSet<OTransactionUniqueKey> uniqueIndexKeys)
	OTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId)