Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
OCacheEntry.getEndLSN() |
OLogSequenceNumber |
OCacheEntryImpl.getEndLSN() |
OLogSequenceNumber |
OCachePointer.getEndLSN() |
Modifier and Type | Method and Description |
---|---|
OCacheEntry |
OReadCache.allocateNewPage(long fileId,
OWriteCache writeCache,
OLogSequenceNumber startLSN) |
OCacheEntry |
OReadCache.loadForWrite(long fileId,
long pageIndex,
boolean checkPinnedPages,
OWriteCache writeCache,
boolean verifyChecksums,
OLogSequenceNumber startLSN) |
void |
OCacheEntry.setEndLSN(OLogSequenceNumber endLSN) |
void |
OCacheEntryImpl.setEndLSN(OLogSequenceNumber endLSN) |
void |
OWriteCache.updateDirtyPagesTable(OCachePointer pointer,
OLogSequenceNumber startLSN) |
Modifier and Type | Method and Description |
---|---|
OCacheEntry |
AsyncReadCache.allocateNewPage(long fileId,
OWriteCache writeCache,
OLogSequenceNumber startLSN) |
OCacheEntry |
AsyncReadCache.loadForWrite(long fileId,
long pageIndex,
boolean checkPinnedPages,
OWriteCache writeCache,
boolean verifyChecksums,
OLogSequenceNumber startLSN) |
Modifier and Type | Method and Description |
---|---|
void |
OWOWCache.updateDirtyPagesTable(OCachePointer pointer,
OLogSequenceNumber startLSN) |
Modifier and Type | Method and Description |
---|---|
protected OLogSequenceNumber |
OLocalPaginatedStorage.copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
long startSegment) |
Modifier and Type | Method and Description |
---|---|
protected abstract OLogSequenceNumber |
OAbstractPaginatedStorage.copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
long startSegment) |
OLogSequenceNumber |
OBackgroundDelta.getEndLsn() |
OLogSequenceNumber |
OAbstractPaginatedStorage.getLSN() |
protected OLogSequenceNumber |
OAbstractPaginatedStorage.restoreFrom(OLogSequenceNumber lsn,
OWriteAheadLog writeAheadLog,
boolean wcRestoreMode) |
Modifier and Type | Method and Description |
---|---|
protected OLogSequenceNumber |
OAbstractPaginatedStorage.restoreFrom(OLogSequenceNumber lsn,
OWriteAheadLog writeAheadLog,
boolean wcRestoreMode) |
protected void |
OAbstractPaginatedStorage.serializeDeltaContent(OutputStream stream,
OCommandOutputListener outputListener,
SortedSet<ORID> sortedRids,
OLogSequenceNumber lsn) |
Constructor and Description |
---|
OBackgroundDelta(OAbstractPaginatedStorage storage,
OCommandOutputListener outputListener,
SortedSet<ORID> sortedRids,
OLogSequenceNumber lsn,
OLogSequenceNumber endLsn) |
OBackgroundDelta(OLogSequenceNumber endLsn) |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
OAtomicOperation.commitChanges(OWriteAheadLog writeAheadLog) |
OLogSequenceNumber |
OCacheEntryChanges.getEndLSN() |
Modifier and Type | Method and Description |
---|---|
void |
OCacheEntryChanges.setEndLSN(OLogSequenceNumber endLSN) |
Modifier and Type | Method and Description |
---|---|
static OLogSequenceNumber |
ODurablePage.getLogSequenceNumber(int offset,
byte[] data)
DO NOT DELETE THIS METHOD IT IS USED IN ENTERPRISE STORAGE
|
static OLogSequenceNumber |
ODurablePage.getLogSequenceNumberFromPage(ByteBuffer buffer) |
OLogSequenceNumber |
ODurablePage.getLsn() |
OLogSequenceNumber |
ODurablePage.getLSN() |
Modifier and Type | Method and Description |
---|---|
void |
ODurablePage.setLsn(OLogSequenceNumber lsn) |
static void |
ODurablePage.setPageLSN(OLogSequenceNumber lsn,
OCacheEntry cacheEntry) |
Modifier and Type | Field and Description |
---|---|
protected OLogSequenceNumber |
OAbstractWALRecord.lsn |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
OLogSegment.begin() |
OLogSequenceNumber |
OMemoryWriteAheadLog.begin() |
OLogSequenceNumber |
OWriteAheadLog.begin() |
OLogSequenceNumber |
OMemoryWriteAheadLog.begin(long segmentId) |
OLogSequenceNumber |
OWriteAheadLog.begin(long segmentId) |
OLogSequenceNumber |
OLogSegment.end() |
OLogSequenceNumber |
OMemoryWriteAheadLog.end() |
OLogSequenceNumber |
OWriteAheadLog.end() |
OLogSequenceNumber |
OMemoryWriteAheadLog.getFlushedLsn() |
OLogSequenceNumber |
OFuzzyCheckpointStartRecord.getFlushedLsn() |
OLogSequenceNumber |
OWriteAheadLog.getFlushedLsn() |
OLogSequenceNumber |
OAbstractWriteAheadLog.getLastCheckpoint() |
OLogSequenceNumber |
OWriteAheadLog.getLastCheckpoint() |
OLogSequenceNumber |
OWALRecord.getLsn() |
OLogSequenceNumber |
OAbstractWALRecord.getLsn() |
OLogSequenceNumber |
OFuzzyCheckpointStartRecord.getLsn() |
OLogSequenceNumber |
OLogSegment.getNextLSN(OLogSequenceNumber lsn)
Returns LSN of the record which follows after the record with passed in LSN.
|
OLogSequenceNumber |
OAbstractCheckPointStartRecord.getPreviousCheckpoint() |
OLogSequenceNumber |
OMemoryWriteAheadLog.log(WriteableWALRecord record) |
OLogSequenceNumber |
OWriteAheadLog.log(WriteableWALRecord record) |
OLogSequenceNumber |
OMemoryWriteAheadLog.logAtomicOperationEndRecord(long operationUnitId,
boolean rollback,
OLogSequenceNumber startLsn,
Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) |
OLogSequenceNumber |
OWriteAheadLog.logAtomicOperationEndRecord(long operationUnitId,
boolean rollback,
OLogSequenceNumber startLsn,
Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) |
OLogSequenceNumber |
OMemoryWriteAheadLog.logAtomicOperationStartRecord(boolean isRollbackSupported,
long unitId) |
OLogSequenceNumber |
OWriteAheadLog.logAtomicOperationStartRecord(boolean isRollbackSupported,
long unitId) |
OLogSequenceNumber |
OMemoryWriteAheadLog.logAtomicOperationStartRecord(boolean isRollbackSupported,
long unitId,
byte[] metadata) |
OLogSequenceNumber |
OWriteAheadLog.logAtomicOperationStartRecord(boolean isRollbackSupported,
long unitId,
byte[] metadata) |
OLogSequenceNumber |
OAbstractWriteAheadLog.logFullCheckpointEnd() |
OLogSequenceNumber |
OWriteAheadLog.logFullCheckpointEnd() |
OLogSequenceNumber |
OAbstractWriteAheadLog.logFullCheckpointStart() |
OLogSequenceNumber |
OWriteAheadLog.logFullCheckpointStart() |
OLogSequenceNumber |
OAbstractWriteAheadLog.logFuzzyCheckPointEnd() |
OLogSequenceNumber |
OWriteAheadLog.logFuzzyCheckPointEnd() |
OLogSequenceNumber |
OAbstractWriteAheadLog.logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) |
OLogSequenceNumber |
OWriteAheadLog.logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) |
OLogSequenceNumber |
OLogSegment.logRecord(byte[] record)
Appends new records to the WAL segment and returns LSN of it.
|
Modifier and Type | Method and Description |
---|---|
void |
OMemoryWriteAheadLog.addCutTillLimit(OLogSequenceNumber lsn) |
void |
OWriteAheadLog.addCutTillLimit(OLogSequenceNumber lsn)
Adds LSN after which WAL log should be preserved.
|
void |
OMemoryWriteAheadLog.addEventAt(OLogSequenceNumber lsn,
Runnable event) |
void |
OWriteAheadLog.addEventAt(OLogSequenceNumber lsn,
Runnable event)
Adds the event to fire when this write ahead log instances reaches the given LSN.
|
int |
OLogSequenceNumber.compareTo(OLogSequenceNumber otherNumber) |
boolean |
OMemoryWriteAheadLog.cutTill(OLogSequenceNumber lsn) |
boolean |
OWriteAheadLog.cutTill(OLogSequenceNumber lsn)
Cut WAL content till passed in value of LSN at maximum in many cases smaller portion of WAL may
be cut.
|
OLogSequenceNumber |
OLogSegment.getNextLSN(OLogSequenceNumber lsn)
Returns LSN of the record which follows after the record with passed in LSN.
|
OLogSequenceNumber |
OMemoryWriteAheadLog.logAtomicOperationEndRecord(long operationUnitId,
boolean rollback,
OLogSequenceNumber startLsn,
Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) |
OLogSequenceNumber |
OWriteAheadLog.logAtomicOperationEndRecord(long operationUnitId,
boolean rollback,
OLogSequenceNumber startLsn,
Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) |
OLogSequenceNumber |
OAbstractWriteAheadLog.logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) |
OLogSequenceNumber |
OWriteAheadLog.logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) |
void |
OMemoryWriteAheadLog.moveLsnAfter(OLogSequenceNumber lsn) |
void |
OWriteAheadLog.moveLsnAfter(OLogSequenceNumber lsn)
Next LSN generated by WAL will be bigger than passed in value.
|
List<WriteableWALRecord> |
OMemoryWriteAheadLog.next(OLogSequenceNumber lsn,
int limit) |
List<WriteableWALRecord> |
OWriteAheadLog.next(OLogSequenceNumber lsn,
int limit) |
List<WriteableWALRecord> |
OMemoryWriteAheadLog.read(OLogSequenceNumber lsn,
int limit) |
List<WriteableWALRecord> |
OWriteAheadLog.read(OLogSequenceNumber lsn,
int limit) |
byte[] |
OLogSegment.readRecord(OLogSequenceNumber lsn)
Reads WAL record from segment from position indicated by LSN.
|
void |
OMemoryWriteAheadLog.removeCutTillLimit(OLogSequenceNumber lsn) |
void |
OWriteAheadLog.removeCutTillLimit(OLogSequenceNumber lsn)
Removes LSN after which WAL log should be preserved.
|
void |
OWALRecord.setLsn(OLogSequenceNumber lsn) |
void |
OAbstractWALRecord.setLsn(OLogSequenceNumber lsn) |
void |
OFuzzyCheckpointStartRecord.setLsn(OLogSequenceNumber lsn) |
Constructor and Description |
---|
MetaDataRecord(OLogSequenceNumber previousCheckpoint) |
OAbstractCheckPointStartRecord(OLogSequenceNumber previousCheckpoint) |
OAbstractWALRecord(OLogSequenceNumber previousCheckpoint) |
OFullCheckpointStartRecord(OLogSequenceNumber previousCheckpoint) |
OFuzzyCheckpointStartRecord(OLogSequenceNumber previousCheckpoint,
OLogSequenceNumber flushedLsn) |
Modifier and Type | Method and Description |
---|---|
void |
CASDiskWriteAheadLog.addCutTillLimit(OLogSequenceNumber lsn) |
void |
CASDiskWriteAheadLog.addEventAt(OLogSequenceNumber lsn,
Runnable event) |
boolean |
CASDiskWriteAheadLog.cutTill(OLogSequenceNumber lsn) |
OLogSequenceNumber |
CASDiskWriteAheadLog.logAtomicOperationEndRecord(long operationUnitId,
boolean rollback,
OLogSequenceNumber startLsn,
Map<String,OAtomicOperationMetadata<?>> atomicOperationMetadata) |
OLogSequenceNumber |
CASDiskWriteAheadLog.logFuzzyCheckPointStart(OLogSequenceNumber flushedLsn) |
void |
CASDiskWriteAheadLog.moveLsnAfter(OLogSequenceNumber lsn) |
List<WriteableWALRecord> |
CASDiskWriteAheadLog.next(OLogSequenceNumber lsn,
int limit) |
List<WriteableWALRecord> |
CASDiskWriteAheadLog.read(OLogSequenceNumber lsn,
int limit) |
void |
CASDiskWriteAheadLog.removeCutTillLimit(OLogSequenceNumber lsn) |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
StartWALRecord.getLsn() |
OLogSequenceNumber |
MilestoneWALRecord.getLsn() |
Modifier and Type | Method and Description |
---|---|
void |
StartWALRecord.setLsn(OLogSequenceNumber lsn) |
void |
MilestoneWALRecord.setLsn(OLogSequenceNumber lsn) |
Modifier and Type | Method and Description |
---|---|
protected OLogSequenceNumber |
ODirectMemoryStorage.copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
long startSegment) |
Modifier and Type | Method and Description |
---|---|
OCacheEntry |
ODirectMemoryOnlyDiskCache.allocateNewPage(long fileId,
OWriteCache writeCache,
OLogSequenceNumber startLSN) |
OCacheEntry |
ODirectMemoryOnlyDiskCache.loadForWrite(long fileId,
long pageIndex,
boolean checkPinnedPages,
OWriteCache writeCache,
boolean verifyChecksums,
OLogSequenceNumber startLSN) |
void |
ODirectMemoryOnlyDiskCache.updateDirtyPagesTable(OCachePointer pointer,
OLogSequenceNumber startLSN) |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
ODistributedSyncConfiguration.getLastLSN(String server) |
OLogSequenceNumber |
ODistributedMomentum.getLSN(String iNode) |
Modifier and Type | Method and Description |
---|---|
void |
ODistributedSyncConfiguration.setLastLSN(String server,
OLogSequenceNumber lsn,
boolean updateLastOperationTimestamp) |
void |
ODistributedMomentum.setLSN(String iNode,
OLogSequenceNumber iLSN) |
void |
ODistributedDatabase.setLSN(String sourceNodeName,
OLogSequenceNumber taskLastLSN,
boolean writeLastOperation) |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
ODistributedDatabaseChunk.getLastWal() |
OLogSequenceNumber |
ONewDistributedTransactionManager.getLsn() |
Modifier and Type | Method and Description |
---|---|
void |
ODistributedDatabaseImpl.setLSN(String sourceNodeName,
OLogSequenceNumber taskLastLSN,
boolean updateLastOperationTimestamp) |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
OTransactionPhase1Task.getLastLSN() |
OLogSequenceNumber |
OTransactionPhase2Task.getLastLSN() |
OLogSequenceNumber |
OUpdateDatabaseStatusTask.OUpdateResult.getSequenceNumber() |
Modifier and Type | Method and Description |
---|---|
void |
OTransactionPhase1Task.setLastLSN(OLogSequenceNumber lastLSN) |
Constructor and Description |
---|
OSyncDatabaseTask(OLogSequenceNumber lastLSN,
long lastOperationTimestamp) |
OTransactionPhase2Task(ODistributedRequestId transactionId,
boolean success,
int[] involvedClusters,
OLogSequenceNumber lsn) |
OUpdateDatabaseStatusTask(String databaseName,
String status,
OLogSequenceNumber lsn) |
OUpdateResult(OLogSequenceNumber sequenceNumber) |
Modifier and Type | Field and Description |
---|---|
protected OLogSequenceNumber |
OAbstractReplicatedTask.lastLSN |
Modifier and Type | Method and Description |
---|---|
OLogSequenceNumber |
OAbstractReplicatedTask.getLastLSN() |
Constructor and Description |
---|
ODistributedDatabaseDeltaSyncException(OLogSequenceNumber requested) |
ODistributedDatabaseDeltaSyncException(OLogSequenceNumber requested,
String reason) |
Copyright © 2009–2020 OrientDB. All rights reserved.