| 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.lock | |
| 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 |
OTxMetadataHolderImpl.getId() |
OTransactionId |
OTxMetadataHolder.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() |
| Modifier and Type | Method and Description |
|---|---|
OTxMetadataHolder |
ODistributedDatabase.commit(OTransactionId id) |
void |
ODistributedDatabase.rollback(OTransactionId id) |
ValidationResult |
ODistributedDatabase.validate(OTransactionId id) |
| Modifier and Type | Method and Description |
|---|---|
OTransactionId |
ODDLContextImpl.getAfterChangeId() |
OTransactionId |
ODDLContextImpl.getPreChangeId() |
OTransactionId |
ODDLContextImpl.getTransactionId() |
OTransactionId |
ONewDistributedTxContextImpl.getTransactionId() |
OTransactionId |
OLocalKeySource.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() |
| 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) |
OTransactionResultPayload |
ODatabaseDocumentDistributed.firstPhaseDDL(String query,
OTransactionId preChangeId,
OTransactionId afterChangeId,
ODistributedRequestId requestId) |
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) |
void |
ODistributedDatabaseImpl.trackTransactions(OTransactionId id) |
void |
ODistributedDatabaseImpl.untrackTransactions(OTransactionId id) |
ValidationResult |
ODistributedDatabaseImpl.validate(OTransactionId id) |
ValidationResult |
ODistributedSynchronizedSequence.validateTransactionId(OTransactionId id) |
| Constructor and Description |
|---|
ODDLContextImpl(String query,
OTransactionId preChangeId,
OTransactionId afterChangeId,
ODistributedRequestId requestId) |
OLocalKeySource(OTransactionId txId,
OTransactionInternal iTx,
ODatabaseDocumentDistributed database) |
ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared,
ODistributedRequestId reqId,
OTransactionInternal tx,
OTransactionId id) |
| Modifier and Type | Method and Description |
|---|---|
void |
OLockManager.lock(SortedSet<ORID> rids,
SortedSet<OTransactionUniqueKey> indexKeys,
OTransactionId txId,
OnLocksAcquired acquired) |
void |
OLockManagerImpl.lock(SortedSet<ORID> rids,
SortedSet<OTransactionUniqueKey> indexKeys,
OTransactionId transactionId,
OnLocksAcquired acquired) |
| Constructor and Description |
|---|
OTransactionIdLockKey(OTransactionId transactionId) |
| Modifier and Type | Method and Description |
|---|---|
OTransactionId |
OSQLCommandTaskFirstPhase.getAfterChangeId() |
OTransactionId |
OSQLCommandTaskFirstPhase.getPreChangeId() |
OTransactionId |
OTransactionPhase2Task.getTransactionId() |
OTransactionId |
OTransactionPhase1Task.getTransactionId() |
OTransactionId |
OLockKeySource.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 |
|---|
OSQLCommandTaskFirstPhase(String query,
OTransactionId preChangeId,
OTransactionId afterChangeId) |
OTransactionPhase1Task(List<ORecordOperation> ops,
OTransactionId transactionId) |
OTransactionPhase2Task(ODistributedRequestId firstPhaseId,
boolean success,
SortedSet<ORID> rids,
SortedSet<OTransactionUniqueKey> uniqueIndexKeys,
OLogSequenceNumber lsn,
OTransactionId transactionId) |
| Modifier and Type | Method and Description |
|---|---|
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() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
OTransactionSequenceManager.notifyFailure(OTransactionId id) |
ValidationResult |
OTransactionSequenceManager.notifySuccess(OTransactionId transactionId) |
ValidationResult |
OTransactionSequenceManager.validateTransactionId(OTransactionId transactionId) |
Copyright © 2009–2025 OrientDB. All rights reserved.