Package com.orientechnologies.orient.server.distributed.impl.task.transaction

Class OTransactionSequenceManager

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.task.transaction.OTransactionSequenceManager

public class OTransactionSequenceManager
extends Object

Constructor Summary

Constructors

Constructor	Description
OTransactionSequenceManager(String node, 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<OTransactionId>	next()
OTransactionId	nextAt(int pos)	This is public only for testing purposes
boolean	notifyFailure(OTransactionId id)
ValidationResult	notifySuccess(OTransactionId transactionId)
ValidationResult	validateTransactionId(OTransactionId transactionId)

Methods inherited from class java.lang.Object

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

Constructor Details

OTransactionSequenceManager

public OTransactionSequenceManager(String node,
 int size)

Method Details

fill

public void fill(OTransactionSequenceStatus data)

next

public Optional<OTransactionId> next()

nextAt

public OTransactionId nextAt(int pos)

This is public only for testing purposes

Parameters:

pos -

Returns:

notifySuccess

public ValidationResult notifySuccess(OTransactionId transactionId)

validateTransactionId

public ValidationResult validateTransactionId(OTransactionId transactionId)

checkSelfStatus

public List<OTransactionId> checkSelfStatus(OTransactionSequenceStatus sequenceStatus)

checkOtherStatus

public List<OTransactionId> checkOtherStatus(OTransactionSequenceStatus sequenceStatus)

notifyFailure

public boolean notifyFailure(OTransactionId id)

currentStatus

public OTransactionSequenceStatus currentStatus()