Package com.orientechnologies.orient.core.transaction

Class ODistributedSynchronizedSequence

java.lang.Object

com.orientechnologies.orient.core.transaction.ODistributedSynchronizedSequence

public class ODistributedSynchronizedSequence
extends Object

Constructor Summary

Constructors

Constructor	Description
ODistributedSynchronizedSequence(ONodeId node, int size)

Method Summary

Modifier and Type	Method	Description
List<OTransactionId>	checkSelfStatus(OTransactionSequenceStatus status)
OTransactionSequenceStatus	currentStatus()
long	debugStatus(int position)
void	fill(Optional<byte[]> lastMetadata)
OTxMetadataHolder	localSuccess()
boolean	missingDDL(OTransactionSequenceStatus lastState)
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
Optional<OTransactionIdPromise>	next()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	nextDDL()
void	notifyFailure(OTransactionIdPromise id)
OTxMetadataHolder	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.
ValidationResult	validate(OTransactionIdPromise id)

Methods inherited from class java.lang.Object

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

Constructor Details

ODistributedSynchronizedSequence

public ODistributedSynchronizedSequence(ONodeId node,
 int size)

Method Details

validate

public ValidationResult validate(OTransactionIdPromise id)

notifyFailure

public void notifyFailure(OTransactionIdPromise id)

next

public Optional<OTransactionIdPromise> next()

nextDDL

public Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>> nextDDL()

notifySuccess

public OTxMetadataHolder 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.

Parameters:

id -

Returns:

missingTransactions

public List<OTransactionId> missingTransactions(OTransactionSequenceStatus lastState)

missingDDL

public boolean missingDDL(OTransactionSequenceStatus lastState)

fill

public void fill(Optional<byte[]> lastMetadata)

currentStatus

public OTransactionSequenceStatus currentStatus()

checkSelfStatus

public List<OTransactionId> checkSelfStatus(OTransactionSequenceStatus status)

debugStatus

public long debugStatus(int position)

localSuccess

public OTxMetadataHolder localSuccess()