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.context.coordination.topology
com.orientechnologies.orient.distributed.db
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
OTransactionIdPromise	OTransactionSequenceManager.promised(int position)
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>	ODistributedSynchronizedSequence.next()
Optional<OTransactionIdPromise>	OTransactionSequenceManager.next()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedSynchronizedSequence.nextDDL()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	ODistributedSynchronizedSequence.nextDDL()
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)
void	ODistributedSynchronizedSequence.notifyFailure(OTransactionIdPromise id)
boolean	OTransactionSequenceManager.notifyFailure(OTransactionIdPromise promise)
OTxMetadataHolder	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.
SuccessResult	OTransactionSequenceManager.notifySuccess(OTransactionIdPromise promise)
ValidationResult	ODistributedSynchronizedSequence.validate(OTransactionIdPromise id)
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)
OConsensusSuccess	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	OConsensusSuccess.failure()	Returns the value of the failure record component.
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.addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	OVersionPromise.cancel(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	OCoordinatedDistributedOpsImpl.cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	OCoordinatedDistributedOps.cancelDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelEstablish(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelEstablish(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelMergeToNetwork(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelMergeToNetwork(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelPromise(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelPromise(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelRegisterNode(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelRegisterNode(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelUnregisterNode(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelUnregisterNode(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.completeExecution(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.completeExecution(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OCoordinatedDistributedOps.consensusFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	OCoordinatedDistributedOpsImpl.consensusFailure(OTransactionIdPromise promise)
OConsensusSuccess	OCoordinatedDistributedOps.consensusSuccess(OTransactionIdPromise promise)
OConsensusSuccess	OCoordinatedDistributedOpsImpl.consensusSuccess(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	OCoordinatedDistributedOpsImpl.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	OCoordinatedDistributedOps.dropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.dropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
Set<ONodeId>	OCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Set<ONodeId>	OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	OPromisedDistributedOps.finalize(OTransactionIdPromise promise)
void	OPromisedDistributedOpsImpl.finalize(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOps.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getNotPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOps.getPromised(OTransactionIdPromise promise)
ODistributedMessage	OPromisedDistributedOpsImpl.getPromised(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.mergeToNetwork(OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.mergeToNetwork(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOpsImpl.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOps.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OCoordinatedDistributedOpsImpl.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OCoordinatedDistributedOps.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OAcceptResult>	OVersionPromise.promise(OTransactionIdPromise promise, OVersion version)
Optional<OAcceptResult>	OCoordinatedDistributedOps.receiveRetry(OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.receiveRetry(OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, 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)
Optional<OOperationStart>	OCoordinatedDistributedOps.restart(OTransactionIdPromise current, OCompleteAction action)
Optional<OOperationStart>	OCoordinatedDistributedOpsImpl.restart(OTransactionIdPromise current, OCompleteAction action)
void	OCoordinatedDistributedOps.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.setDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.setTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
ODisconnectAction	OCoordinatedDistributedOps.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
ODisconnectAction	OCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateEstablish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateMergeToNetwork(OGroupId group, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise coordinator)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateMergeToNetwork(OGroupId group, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)

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.
	OConsensusSuccess(OTransactionIdPromise failure)
	OConsensusSuccess(ODistributedMessage success, OTransactionIdPromise failure, boolean missing, boolean applied)	Creates an instance of a OConsensusSuccess 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	ORecoordinateCompleteAction.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	OMergeCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
void	ORecoordinateCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
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	ORecoordinateCompleteAction.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	OMergeCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	ORecoordinateCompleteAction.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.addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.addMember(List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelAddMemer(List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelDrop(OTransactionIdPromise promise, OVersion version)
void	ODatabasesTopologyState.cancelDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelMerge(OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelMerge(OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name)
void	ODatabaseTopologyState.cancelQuorum(OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelRemoveDatabaseMembers(ODatabaseId dbId, OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelRemoveMemer(OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelRole(ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelSetState(ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	ODatabaseTopologyState.drop(OTransactionIdPromise promise, OVersion version)
void	ODatabasesTopologyState.dropDatabase(OTransactionIdPromise promise, ODatabaseId dbId, OVersion version)
void	ODatabasesTopologyState.mergeNetworkState(List<ODatabaseStateNetwork> network, OTransactionIdPromise promise)
void	ODatabaseTopologyState.mergeState(ODatabaseStateNetwork state, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.promiseMember(List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.promiseRemoveMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.promiseState(ODatabaseState state, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.removeMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.setDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.setQuorum(int newQuorum, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.setRole(ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.setState(ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateAddMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Optional<OAcceptResult>	ODatabaseTopologyState.validateDrop(OTransactionIdPromise promise, OVersion version)
Optional<OAcceptResult>	ODatabasesTopologyState.validateDropDatabase(OTransactionIdPromise promise, ODatabaseId dbId, OVersion version)
Optional<OAcceptResult>	ODatabaseTopologyState.validateMerge(OTransactionIdPromise promise, ODatabaseStateNetwork stateDb)
Optional<OAcceptResult>	ODatabasesTopologyState.validateMergeNode(List<ODatabaseStateNetwork> databases, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.validateMergeNode(OTransactionIdPromise promise, ODatabaseStateNetwork stateDb)
Optional<OAcceptResult>	ODatabasesTopologyState.validateMergeToNetwork(List<ODatabaseStateNetwork> original, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateRemoveMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.validateRole(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabaseTopologyState.validateSetQurum(int newQuorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)

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	OMergeConfirmOp.getPromise()
OTransactionIdPromise	OMergeFailOp.getPromise()
OTransactionIdPromise	OMergeRequest.getPromise()
OTransactionIdPromise	OMergeResult.getPromise()
OTransactionIdPromise	ORetryProposeOp.getPromise()
OTransactionIdPromise	OSuccessPropose.getPromise()
OTransactionIdPromise	OConfirmedRetryOp.getPromiseId()
OTransactionIdPromise	ODistributedMessage.getPromiseId()
OTransactionIdPromise	OProposeOp.getPromiseId()
OTransactionIdPromise	OConfirmedRetryOp.promiseId()	Returns the value of the promiseId record component.

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

Modifier	Constructor	Description
	OConfirmedRetryOp(OTransactionIdPromise promiseId, OOperationMessage op)	Creates an instance of a OConfirmedRetryOp record class.
	OConfirmOp(OTransactionIdPromise promise)
	OFailOp(OTransactionIdPromise promise)
	OFailPropose(ONodeId nodeId, OTransactionIdPromise promise, OAcceptResult acceptResult)
	OMergeConfirmOp(OTransactionIdPromise promise)
	OMergeFailOp(OTransactionIdPromise promise)
	OMergeRequest(OTransactionIdPromise promise, OGroupId groupId, ONodeStateNetwork state, ONodeStateNetwork original)
	OMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
	OProposeOp(OTransactionIdPromise promise, OOperationMessage op)
	ORetryProposeOp(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	OAddDatabaseMembers.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OAddTopologyMember.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	ODeclareDbMessage.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	ODropDbMessage.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OEstablishTopology.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OMergeNode.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OOperationMessage.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	ORemoveDatabaseMembers.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	ORemoveTopologyMember.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseMemberRole.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseQuorum.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseState.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetTopologyQuorum.apply(OOperationContext ctx, OTransactionIdPromise promise)
void	OAddDatabaseMembers.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OAddTopologyMember.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	ODeclareDbMessage.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	ODropDbMessage.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OEstablishTopology.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OMergeNode.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OOperationMessage.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	ORemoveDatabaseMembers.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	ORemoveTopologyMember.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseMemberRole.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseQuorum.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetDatabaseState.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OSetTopologyQuorum.cancel(OOperationContext ctx, OTransactionIdPromise promise)
void	OOperationContext.declareDatabase(OTransactionIdPromise promise, ODatabaseId id, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	OOperationContext.distributedDrop(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	OOperationContext.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	OOperationContext.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OOperationContext.recoordinateOperation(OTransactionIdPromise promise, OOperationMessage op)
void	OOperationContext.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OAddDatabaseMembers.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OAddTopologyMember.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODeclareDbMessage.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODropDbMessage.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OEstablishTopology.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OMergeNode.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OOperationMessage.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ORemoveDatabaseMembers.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	ORemoveTopologyMember.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OSetDatabaseMemberRole.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OSetDatabaseQuorum.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OSetDatabaseState.validate(OOperationContext ctx, OTransactionIdPromise promise)
Optional<OAcceptResult>	OSetTopologyQuorum.validate(OOperationContext ctx, OTransactionIdPromise promise)

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

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

Modifier and Type	Method	Description
void	OTopologyManager.applyMerge(OTopologyStateNetwork topology, OTransactionIdPromise promise)
void	OTopologyManager.cancelEstablish(OTransactionIdPromise promise)
void	OTopologyManager.cancelMerge(OTransactionIdPromise promise)
void	OTopologyManager.cancelRegisterPromise(OTransactionIdPromise promise)
void	OTopologyManager.cancelSetQuorum(int quorumToSet, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.cancelUnregisterPromise(OTransactionIdPromise promise)
Set<ONodeId>	OTopologyManager.finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	OTopologyManager.mergeNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.promiseRegister(ONodeId toAdd, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.promiseUnregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.register(ONodeId toRegister, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.setQuorum(int quorumToSet, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.unregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.validateMergeNode(OGroupId group, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.validateMergeToNetwork(OGroupId group, ONodeStateNetwork mergeState, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.validateSetQuorum(int quorumToSet, OVersion version, 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.cancelMergeToNetwork(OTransactionIdPromise promise)
void	OrientDBDistributed.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	OrientDBDistributed.distributedDrop(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	OrientDBDistributed.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	OrientDBDistributed.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OrientDBDistributed.mergeNodeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OrientDBDistributed.mergeToNetwork(OTransactionIdPromise promise)
void	OrientDBDistributed.recoordinateOperation(OTransactionIdPromise promise, OOperationMessage op)
void	OrientDBDistributed.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OrientDBDistributed.validateMergeToNetwork(OGroupId group, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)

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 with parameters of type OTransactionIdPromise

Modifier and Type	Method	Description
boolean	ODatabaseDocumentDistributed.beginDistributedTx(ODistributedRequestId requestId, OTransactionIdPromise id, OTransactionInternal tx, boolean isCoordinator, int retryCount)
protected OTransactionPhase1Task	ODistributedTxCoordinator.createTxPhase1Task(OTransactionIdPromise id, OTransactionInternal transaction)
OTransactionResultPayload	ODatabaseDocumentDistributed.firstPhaseDDL(String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId)
void	ODistributedTxCoordinator.tryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId)

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

Modifier	Constructor	Description
	ODDLContextImpl(OSharedContextDistributed shared, String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId)
	ONewDistributedTxContextImpl(OSharedContextDistributed 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	OSQLCommandTaskSecondPhase.getAfterChange()
OTransactionIdPromise	OSQLCommandTaskFirstPhase.getAfterChangeId()
OTransactionIdPromise	OSQLCommandTaskSecondPhase.getPreChange()
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)
	OSQLCommandTaskSecondPhase(ODistributedRequestId confirmSentRequest, OTransactionIdPromise preChange, OTransactionIdPromise afterChange, boolean apply)
	OTransactionPhase1Task(List<ORecordOperation> ops, OTransactionIdPromise promise, SortedSet<OTransactionUniqueKey> uniqueIndexKeys)
	OTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId)