void |
InterleavedLedgerStorage.checkpoint(CheckpointSource.Checkpoint checkpoint) |
|
void |
LedgerStorage.checkpoint(CheckpointSource.Checkpoint checkpoint) |
Ask the ledger storage to sync data until the given checkpoint.
|
void |
SortedLedgerStorage.checkpoint(CheckpointSource.Checkpoint checkpoint) |
|
void |
SyncThread.checkpoint(CheckpointSource.Checkpoint checkpoint) |
|
void |
CheckpointSource.checkpointComplete(CheckpointSource.Checkpoint checkpoint,
boolean compact) |
Tell checkpoint source that the checkpoint is completed.
|
void |
CheckpointSourceList.checkpointComplete(CheckpointSource.Checkpoint checkpoint,
boolean compact) |
|
void |
Journal.checkpointComplete(CheckpointSource.Checkpoint checkpoint,
boolean compact) |
Telling journal a checkpoint is finished.
|
(package private) int |
EntryMemTable.EntrySkipList.compareTo(CheckpointSource.Checkpoint cp) |
|
protected void |
SyncThread.doCheckpoint(CheckpointSource.Checkpoint checkpoint) |
|
long |
EntryMemTable.flush(SkipListFlusher flusher,
CheckpointSource.Checkpoint checkpoint) |
Flush memtable until checkpoint.
|
(package private) long |
EntryMemTable.flushSnapshot(SkipListFlusher flusher,
CheckpointSource.Checkpoint checkpoint) |
Flush snapshot and clear it iff its data is before checkpoint.
|
(package private) long |
EntryMemTableWithParallelFlusher.flushSnapshot(SkipListFlusher flusher,
CheckpointSource.Checkpoint checkpoint) |
Functionally this overridden flushSnapshot does the same as
EntryMemTable's flushSnapshot, but it uses flushExecutor
(OrderedExecutor) to process an entry through flusher.
|
void |
CacheCallback.onSizeLimitReached(CheckpointSource.Checkpoint cp) |
Process notification that cache size limit reached.
|
void |
SortedLedgerStorage.onSizeLimitReached(CheckpointSource.Checkpoint cp) |
|
(package private) CheckpointSource.Checkpoint |
EntryMemTable.snapshot(CheckpointSource.Checkpoint oldCp) |
Snapshot current EntryMemTable.
|
void |
Checkpointer.startCheckpoint(CheckpointSource.Checkpoint checkpoint) |
Start checkpointing for a given checkpoint location.
|
void |
SyncThread.startCheckpoint(CheckpointSource.Checkpoint checkpoint) |
|