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
com.orientechnologies.orient.distributed.context.coordination.action
com.orientechnologies.orient.distributed.context.coordination.dbs
com.orientechnologies.orient.distributed.context.coordination.message
com.orientechnologies.orient.distributed.context.coordination.message.operation
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)
OTransactionIdPromise	OTransactionIdPromise.retrySequence(ONodeId node)

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	OTransactionIdPromise.nextAccept(OTransactionIdPromise promise)
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()

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

Modifier and Type	Method	Description
void	ONodeState.cancelPromise(OTransactionIdPromise promise)
void	ONodeState.complete(OTransactionIdPromise promise)
void	ONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
Optional<ODistributedMessage>	ONodeState.receiveFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	ONodeState.receiveSuccess(OTransactionIdPromise promise)
void	ONodeState.success(ONodeId node, OTransactionIdPromise promise)
void	ONodeState.waitComplete(OTransactionIdPromise promise)

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

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

Modifier and Type	Method	Description
OTransactionIdPromise	OOperationStart.promise()	Returns the value of the promise record component.
OTransactionIdPromise	OResponseCollector.CompleteInfo.promise()	Returns the value of the promise record component.

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

Modifier and Type	Method	Description
Optional<OTransactionIdPromise>	OCoordinatedDistributedOps.startEstablish(Set<ONodeId> nodes, OCompleteAction action)
Optional<OTransactionIdPromise>	OCoordinatedDistributedOpsImpl.startEstablish(Set<ONodeId> nodes, OCompleteAction action)

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

Modifier and Type	Method	Description
void	OVersionPromise.accept(OTransactionIdPromise promise, OVersion version)
void	OCoordinatedDistributedOps.cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	OCoordinatedDistributedOpsImpl.cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	OCoordinatedDistributedOps.cancelPromise(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelPromise(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.completeExecution(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.completeExecution(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.confirmMerge(ONodeId node, OTransactionIdPromise promise, boolean accepted)
void	OCoordinatedDistributedOpsImpl.confirmMerge(ONodeId node, OTransactionIdPromise promise, boolean accepted)
Optional<ODistributedMessage>	OCoordinatedDistributedOps.consensusFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OCoordinatedDistributedOpsImpl.consensusFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OCoordinatedDistributedOps.consensusSuccess(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OCoordinatedDistributedOpsImpl.consensusSuccess(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
void	OCoordinatedDistributedOpsImpl.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
ODistributedMessage	OPromisedDistributedOps.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOps.getPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getPromised(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOpsImpl.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOps.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OAcceptResult>	OVersionPromise.promise(OTransactionIdPromise promise, OVersion version)
Optional<ODistributedMessage>	OPromisedDistributedOps.removeNotPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOpsImpl.removeNotPromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOps.removePromised(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OPromisedDistributedOpsImpl.removePromised(OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)

Constructors in com.orientechnologies.orient.distributed.context.coordination 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)	Creates an instance of a OOperationStart record class.
	OResponseCollectorImpl(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> activeNodes)
	OResponseCollectorMerge(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes, ONodeId mergeNode)

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

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

Modifier and Type	Method	Description
void	OCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
void	OStandardCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
void	OCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> optional)
void	OStandardCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
OResponseCollector	OCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
OResponseCollector	OMergeCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
OResponseCollector	OStandardCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
void	OCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	OStandardCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)

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

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

Modifier and Type	Method	Description
void	ODatabasesTopologyState.cancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name)
void	ODatabasesTopologyState.declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	ODatabasesTopologyState.validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum)

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	OMergeRequest.getPromise()
OTransactionIdPromise	OMergeResult.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)
	OMergeRequest(OTransactionIdPromise promise, OGroupId groupId)
	OMergeResult(ONodeId node, OTransactionIdPromise promise, boolean accepted)
	OProposeOp(OTransactionIdPromise promise, OOperationMessage op)
	OSuccessPropose(ONodeId nodeId, OTransactionIdPromise promise)

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

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

Modifier and Type	Method	Description
void	OAddDatabaseMember.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OAddTopologyMember.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	ODeclareDbMessage.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	ODropDbMessage.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OEstablishTopology.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OOperationMessage.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OSetDatabaseState.apply(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OAddDatabaseMember.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OAddTopologyMember.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	ODeclareDbMessage.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	ODropDbMessage.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OEstablishTopology.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OOperationMessage.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
void	OSetDatabaseState.cancel(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OAddDatabaseMember.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OAddTopologyMember.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODeclareDbMessage.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODropDbMessage.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OEstablishTopology.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OOperationMessage.validate(OrientDBDistributed ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OSetDatabaseState.validate(OrientDBDistributed ctx, 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	OrientDBDistributed.acceptMerge(OTransactionIdPromise promise, OGroupId group)
void	OrientDBDistributed.cancelDeclare(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	OrientDBDistributed.confirmMerge(ONodeId node, OTransactionIdPromise promise, boolean accepted)
void	OrientDBDistributed.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	OrientDBDistributed.promiseDeclare(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)

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)