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

Class ODistributedSynchronizedSequence

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.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()
void	fill(Optional<byte[]> lastMetadata)
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
Optional<OTransactionIdPromise>	next()
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	nextDDL()
void	notifyFailure(OTransactionIdPromise id)
OTxMetadataHolderImpl	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 OTxMetadataHolderImpl 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)

fill

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

currentStatus

public OTransactionSequenceStatus currentStatus()

checkSelfStatus

public List<OTransactionId> checkSelfStatus(OTransactionSequenceStatus status)