Package | Description |
---|---|
com.orientechnologies.orient.core.storage.impl.local |
Contains all the class involved on the "local" implementation of the OStorage interface.
|
com.orientechnologies.orient.core.tx | |
com.orientechnologies.orient.server.distributed | |
com.orientechnologies.orient.server.distributed.impl | |
com.orientechnologies.orient.server.distributed.impl.task | |
com.orientechnologies.orient.server.distributed.impl.task.transaction |
Modifier and Type | Method and Description |
---|---|
Optional<OBackgroundNewDelta> |
OAbstractPaginatedStorage.extractTransactionsFromWal(List<OTransactionId> transactionsMetadata) |
Modifier and Type | Method and Description |
---|---|
OTransactionId |
OTxMetadataHolder.getId() |
OTransactionId |
OTxMetadataHolderImpl.getId() |
OTransactionId |
OTransactionData.getTransactionId() |
static OTransactionId |
OTransactionId.read(DataInput input) |
Constructor and Description |
---|
OTransactionData(OTransactionId transactionId) |
OTxMetadataHolderImpl(CountDownLatch request,
OTransactionId id,
OTransactionSequenceStatus status) |
Modifier and Type | Method and Description |
---|---|
OTransactionId |
ODistributedTxContext.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
List<OTransactionId> |
ODistributedDatabase.missingTransactions(OTransactionSequenceStatus lastState) |
Optional<OTransactionId> |
ODistributedDatabase.nextId() |
Optional<OTransactionId> |
ODistributedDatabase.validate(OTransactionId id) |
Modifier and Type | Method and Description |
---|---|
OTxMetadataHolder |
ODistributedDatabase.commit(OTransactionId id) |
void |
ODistributedDatabase.rollback(OTransactionId id) |
Optional<OTransactionId> |
ODistributedDatabase.validate(OTransactionId id) |
Modifier and Type | Method and Description |
---|---|
OTransactionId |
ONewDistributedTxContextImpl.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
List<OTransactionId> |
ODistributedSynchronizedSequence.checkSelfStatus(OTransactionSequenceStatus status) |
List<OTransactionId> |
ODistributedDatabaseImpl.missingTransactions(OTransactionSequenceStatus lastState) |
List<OTransactionId> |
ODistributedSynchronizedSequence.missingTransactions(OTransactionSequenceStatus lastState) |
Optional<OTransactionId> |
ODistributedSynchronizedSequence.next() |
Optional<OTransactionId> |
ODistributedDatabaseImpl.nextId() |
Optional<OTransactionId> |
ODistributedDatabaseImpl.validate(OTransactionId id) |
Optional<OTransactionId> |
ODistributedSynchronizedSequence.validateTransactionId(OTransactionId id) |
Modifier and Type | Method and Description |
---|---|
boolean |
ODatabaseDocumentDistributed.beginDistributedTx(ODistributedRequestId requestId,
OTransactionId id,
OTransactionInternal tx,
boolean local,
int retryCount) |
OTxMetadataHolder |
ODistributedDatabaseImpl.commit(OTransactionId id) |
protected OTransactionPhase1Task |
ONewDistributedTransactionManager.createTxTask(OTransactionId id,
OTransactionInternal transaction,
Set<String> nodes) |
void |
ODistributedSynchronizedSequence.notifyFailure(OTransactionId id) |
OTxMetadataHolderImpl |
ODistributedSynchronizedSequence.notifySuccess(OTransactionId id) |
void |
ONewDistributedTransactionManager.retriedCommit(ODatabaseDocumentDistributed database,
OTransactionInternal iTx,
OTransactionId txId,
ODistributedRequestId requestId) |
void |
ODistributedDatabaseImpl.rollback(OTransactionId id) |
Optional<OTransactionId> |
ODistributedDatabaseImpl.validate(OTransactionId id) |
Optional<OTransactionId> |
ODistributedSynchronizedSequence.validateTransactionId(OTransactionId id) |
Constructor and Description |
---|
OInvalidSequentialException(OTransactionId expected) |
ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared,
ODistributedRequestId reqId,
OTransactionInternal tx,
OTransactionId id) |
Modifier and Type | Method and Description |
---|---|
OTransactionId |
OTransactionPhase1Task.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
static OTransactionResultPayload |
OTransactionPhase1Task.executeTransaction(ODistributedRequestId requestId,
OTransactionId id,
ODatabaseDocumentDistributed database,
OTransactionInternal tx,
boolean local,
int retryCount) |
void |
OTransactionPhase1Task.init(OTransactionId transactionId,
OTransactionInternal operations) |
Constructor and Description |
---|
OTransactionPhase1Task(List<ORecordOperation> ops,
OTransactionId transactionId) |
Modifier and Type | Method and Description |
---|---|
OTransactionId |
OTxInvalidSequential.getCurrent() |
OTransactionId |
OTransactionSequenceManager.nextAt(int pos)
This is publuc only for testing purposes
|
Modifier and Type | Method and Description |
---|---|
List<OTransactionId> |
OTransactionSequenceManager.checkOtherStatus(OTransactionSequenceStatus sequenceStatus) |
List<OTransactionId> |
OTransactionSequenceManager.checkSelfStatus(OTransactionSequenceStatus sequenceStatus) |
Optional<OTransactionId> |
OTransactionSequenceManager.next() |
List<OTransactionId> |
OTransactionSequenceManager.notifySuccess(OTransactionId transactionId) |
Optional<OTransactionId> |
OTransactionSequenceManager.validateTransactionId(OTransactionId transactionId) |
Modifier and Type | Method and Description |
---|---|
boolean |
OTransactionSequenceManager.notifyFailure(OTransactionId id) |
List<OTransactionId> |
OTransactionSequenceManager.notifySuccess(OTransactionId transactionId) |
void |
OTxInvalidSequential.setCurrent(OTransactionId current) |
Optional<OTransactionId> |
OTransactionSequenceManager.validateTransactionId(OTransactionId transactionId) |
Constructor and Description |
---|
OTxInvalidSequential(OTransactionId current) |
Copyright © 2009–2020 OrientDB. All rights reserved.