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(String 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<OTransactionId>	next()
void	notifyFailure(OTransactionId id)
OTxMetadataHolderImpl	notifySuccess(OTransactionId id)
ValidationResult	validateTransactionId(OTransactionId id)

Methods inherited from class java.lang.Object

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

Constructor Details

ODistributedSynchronizedSequence

public ODistributedSynchronizedSequence(String node,
 int size)

Method Details

validateTransactionId

public ValidationResult validateTransactionId(OTransactionId id)

notifyFailure

public void notifyFailure(OTransactionId id)

next

public Optional<OTransactionId> next()

notifySuccess

public OTxMetadataHolderImpl notifySuccess(OTransactionId id)

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)