Package com.orientechnologies.orient.core.transaction

Class OTransactionSequenceManager

java.lang.Object

com.orientechnologies.orient.core.transaction.OTransactionSequenceManager

public class OTransactionSequenceManager
extends Object

Constructor Summary

Constructors

Constructor	Description
OTransactionSequenceManager(ONodeId coordinator, int size)

Method Summary

Modifier and Type	Method	Description
List<OTransactionId>	checkOtherStatus(OTransactionSequenceStatus sequenceStatus)
List<OTransactionId>	checkSelfStatus(OTransactionSequenceStatus sequenceStatus)
OTransactionSequenceStatus	currentStatus()
void	fill(OTransactionSequenceStatus data)
Optional<OTransactionIdPromise>	next()
OTransactionIdPromise	nextAt(int pos)	This is public only for testing purposes
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	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
boolean	notifyFailure(OTransactionIdPromise promise)
ValidationResult	notifySuccess(OTransactionIdPromise promise)
ValidationResult	validate(OTransactionIdPromise promise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OTransactionSequenceManager

public OTransactionSequenceManager(ONodeId coordinator,
 int size)

Method Details

fill

public void fill(OTransactionSequenceStatus data)

next

public Optional<OTransactionIdPromise> next()

nextDDL

public Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>> 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

Returns:

nextAt

public OTransactionIdPromise nextAt(int pos)

This is public only for testing purposes

Parameters:

pos -

Returns:

notifySuccess

public ValidationResult notifySuccess(OTransactionIdPromise promise)

validate

public ValidationResult validate(OTransactionIdPromise promise)

checkSelfStatus

public List<OTransactionId> checkSelfStatus(OTransactionSequenceStatus sequenceStatus)

checkOtherStatus

public List<OTransactionId> checkOtherStatus(OTransactionSequenceStatus sequenceStatus)

notifyFailure

public boolean notifyFailure(OTransactionIdPromise promise)

currentStatus

public OTransactionSequenceStatus currentStatus()