Skip navigation links
A B C D E F G H I K L M N O P Q R S T U V W Y 

A

accept(RestartItem) - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
Called when encountering a record which is not interred by a prefix tombstone.
accept(KeyHandle, byte[]) - Method in interface com.hazelcast.spi.hotrestart.RamStore
Called during Hot Restart.
acceptCleared(RestartItem) - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
Called when encountering a record which is interred by a prefix tombstone.
ACTIVE_FNAME_SUFFIX - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Suffix added to the chunk file while it is active.
ActiveChunk - Interface in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a currently active chunk.
ActiveValChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents the currently active value chunk.
ActiveValChunk(long, RecordMap, ChunkFileOut, GcHelper) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveValChunk
 
add(Record, KeyHandle, RecordDataHolder) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.SurvivorValChunk
Adds a record both to the survivor chunk file and to the chunk's record map.
add(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOffHeap
 
add(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOnHeap
 
add(KeyHandle) - Method in interface com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle
Adds a key handle to the set.
additionalInt() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
additionalInt() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
additionalInt() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
addPrefixTombstones(long[]) - Method in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
Adds prefix tombstones for the given key prefixes.
address() - Method in class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 
address() - Method in interface com.hazelcast.spi.hotrestart.KeyHandleOffHeap
 
addStep1(long, long, byte[], byte[]) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
Writes a record to the chunk file and updates the size property on this object.
addStep1(long, long, byte[], byte[]) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveValChunk
 
addStep1(long, long, byte[], byte[]) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
addStep1(TombFileAccessor, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
Does the same work as WriteThroughTombChunk.addStep1(long, long, byte[], byte[]), but using a TombFileAccessor to get the data.
addStep2(long, long, KeyHandle, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Adds the record to this chunk's record map.
addStep2(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Called only by Rebuilder, which encounters records out of file order.
advance() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap.Cursor
Attempts to advance the cursor to the next position.
advance() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SortedBySeqRecordCursorOnHeap
 
advance() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap.Cursor
Attempts to advance the cursor to the next position.
advance() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
Advances to the next record in the chunk file.
advance() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor
Attempts to advance to the next record.
advance() - Method in interface com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle.KhCursor
Attempts to advance the cursor to the next position.
advance() - Method in interface com.hazelcast.spi.hotrestart.impl.SortedBySeqRecordCursor
Attempts to advance the cursor to the next position.
allocate(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.mem.MmapMalloc
 
asKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SortedBySeqRecordCursorOnHeap
 
asKeyHandle() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap.Cursor
Returns the key handle associated with the tracker at the current cursor position.
asKeyHandle() - Method in interface com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle.KhCursor
Returns the key handle at the current cursor position.
asKeyHandle() - Method in interface com.hazelcast.spi.hotrestart.impl.SortedBySeqRecordCursor
Returns the key handle associated with the record at the current cursor position.
asRecord() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap.Cursor
Returns the record at the current cursor position.
asRecord() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SortedBySeqRecordCursorOnHeap
 
asRecord() - Method in interface com.hazelcast.spi.hotrestart.impl.SortedBySeqRecordCursor
Returns the record at the current cursor position.
asTracker() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap.Cursor
 

B

backup(File) - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Copies the contents of this hot restart store to the target directory.
backup(File) - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
backup(File) - Method in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
Copies the prefix tombstone file to the target directory.
BackupExecutor - Class in com.hazelcast.spi.hotrestart.impl.gc
Executor in charge of running backup tasks.
BackupExecutor() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
 
BackupTask - Class in com.hazelcast.spi.hotrestart.impl.gc
Class in charge of copying stable hot restart chunks.
base() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
base() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
 
base() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
benefitToCost(long, long) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
Calculates the Benefit-Cost factor.
BITS_PER_HEX_DIGIT - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
A hex digit represents this many bits.
BUCKET_DIR_MASK - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Bitmask used for the operation "modulo MAX_BUCKET_DIRS"
BUCKET_DIRNAME_DIGITS - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
The number of hex digits in the name of a bucket dir
BUFFER_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.HotRestarter
Buffer size used for file I/O.
BY_BENEFIT_COST_DESC - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableChunk
 
bytes() - Method in interface com.hazelcast.spi.hotrestart.HotRestartKey
 
bytes() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOffHeap
 
bytes() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 

C

cachedBenefitToCost() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableChunk
 
catchupAsNeeded() - Method in class com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup
catchupNow() - Method in class com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup
Caches up with the mutator thread.
changeSuffix(String, long, String, String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Changes the filename suffix of a chunk file.
Chunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a chunk file.
Chunk(long, RecordMap) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
Chunk(GrowingChunk) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
Chunk(long, RecordMap, int, long) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
CHUNK_FNAME_LENGTH - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Chunk filename is a zero-padded long in hex notation.
CHUNK_SNAPSHOT_FNAME - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
chunkFile(String, long, String, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Returns a File instance representing the chunk file described by the parameters.
ChunkFileCursor - Class in com.hazelcast.spi.hotrestart.impl.io
A cursor over a chunk file's contents.
ChunkFileCursor(int, File) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
ChunkFileCursor.Tomb - Class in com.hazelcast.spi.hotrestart.impl.io
Specialization of ChunkFileCursor to tombstone chunk.
ChunkFileOut - Class in com.hazelcast.spi.hotrestart.impl.io
Encapsulates chunk file writing code.
ChunkFileOut(File, MutatorCatchup) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
 
ChunkFileRecord - Interface in com.hazelcast.spi.hotrestart.impl.io
Represents a record read from a chunk file.
ChunkFilesetCursor - Class in com.hazelcast.spi.hotrestart.impl.io
A cursor over all the records in a list of chunk files.
ChunkFilesetCursor.Tomb - Class in com.hazelcast.spi.hotrestart.impl.io
Specialization of ChunkFileSetCursor to tombstone chunks
ChunkFilesetCursor.Val - Class in com.hazelcast.spi.hotrestart.impl.io
Specialization of ChunkFileSetCursor to value chunks
ChunkManager - Class in com.hazelcast.spi.hotrestart.impl.gc
Manages GC-related metadata and contains the entry points into the GC procedures.
chunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
 
chunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
 
chunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
chunkSeq() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
chunkSeq - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
clear(boolean, long...) - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Removes all mappings for the supplied list of key prefixes.
clear(boolean, long...) - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
clear() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
clearedItem(ChunkFileRecord) - Static method in class com.hazelcast.spi.hotrestart.impl.RestartItem
Constructs an item that corresponds to a cleared record (interred by a prefix tombstone).
clearedPrefixesFoundAtRestart - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
A key prefix could exist in a chunk file, yet during Hot Restart no record with that key prefix might be added to a record map due to a prefix tombstone (Rebuilder.acceptCleared(RestartItem) doesn't add the record to the record map).
close() - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Closes this Hot Restart store and releases any system resources it had acquired.
close() - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
close() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
 
close() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughChunk
 
close() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
close() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Flushes any remaining data to the file, executes fsync on it as indicated by the ChunkFileOut.needsFsyncBeforeClosing flag, and closes the file.
close() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor
 
close() - Method in class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
Disposes the underlying MappedByteBuffer.
COLLECTOR_QUEUE_CAPACITY - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Capacity of the work queue which is used by the mutator thread to submit tasks to the GC thread.
com.hazelcast.spi.hotrestart - package com.hazelcast.spi.hotrestart
SPI for the Hot Restart store.
com.hazelcast.spi.hotrestart.impl - package com.hazelcast.spi.hotrestart.impl
Implementation code for the Hot Restart store SPI.
com.hazelcast.spi.hotrestart.impl.di - package com.hazelcast.spi.hotrestart.impl.di
 
com.hazelcast.spi.hotrestart.impl.gc - package com.hazelcast.spi.hotrestart.impl.gc
Implementation of garbage collection for the Hot Restart store.
com.hazelcast.spi.hotrestart.impl.gc.chunk - package com.hazelcast.spi.hotrestart.impl.gc.chunk
 
com.hazelcast.spi.hotrestart.impl.gc.mem - package com.hazelcast.spi.hotrestart.impl.gc.mem
 
com.hazelcast.spi.hotrestart.impl.gc.record - package com.hazelcast.spi.hotrestart.impl.gc.record
 
com.hazelcast.spi.hotrestart.impl.gc.tracker - package com.hazelcast.spi.hotrestart.impl.gc.tracker
 
com.hazelcast.spi.hotrestart.impl.io - package com.hazelcast.spi.hotrestart.impl.io
 
ConcurrentHotRestartStore - Class in com.hazelcast.spi.hotrestart.impl
Concurrent implementation of HotRestartStore which delegates work to a single-threaded HotRestartPersistenceEngine over a many-to-one concurrent queue.
copy(File, File) - Method in class com.hazelcast.spi.hotrestart.impl.io.DefaultCopyStrategy
 
copy(File, File) - Method in interface com.hazelcast.spi.hotrestart.impl.io.FileCopyStrategy
Copy the file from source to target.
copy(File, File) - Method in class com.hazelcast.spi.hotrestart.impl.io.HardLinkCopyStrategy
 
copyEntry(KeyHandle, int, RecordDataSink) - Method in interface com.hazelcast.spi.hotrestart.RamStore
Copies the key/value bytes into the corresponding byte buffers provided by the supplied RecordDataSink.
cost() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
 
currentRecord() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor
 
cursor() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOffHeap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOnHeap
 
cursor() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
cursor() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 
cursor() - Method in interface com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle
 

D

deadOrAliveSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
deadSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Asserts that the record is dead and returns its sequence number.
decrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Decrements this record's garbage count.
decrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
decrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
DEFAULT_CATCHUP_INTERVAL_LOG2 - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup
Base-2 log of the number of calls to MutatorCatchup.catchupAsNeeded() before deciding to catch up.
DefaultCopyStrategy - Class in com.hazelcast.spi.hotrestart.impl.io
Default file copy strategy which copies the contents of the source.
DefaultCopyStrategy() - Constructor for class com.hazelcast.spi.hotrestart.impl.io.DefaultCopyStrategy
 
deleteChunkFile(StableChunk) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Deletes the stable chunk file associated with the given instance of StableChunk.
deleteChunkFile(long, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Deletes chunk file with the given seq.
deleteChunkFiles(long[], boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Deletes chunk files with the given chunkSeqs.
dep(Object) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Registers an object by its actual type.
dep(Class<? super T>, T) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Registers an object by type.
dep(String, T) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Registers an object by name.
dep(Class<?>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Instantiates a type and registers the instance under that type.
dep(Class<? super T>, Class<T>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Instantiates a type and registers the instance under the specified type.
dep(String, Class<?>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Instantiates a type and registers the instance under the specified name.
determineSizeLimit() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveValChunk
 
determineSizeLimit() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Determines the limit on the size of this chunk by reading a system property.
determineSizeLimit() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.SurvivorValChunk
 
determineSizeLimit() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
diagnoseLateCatchup(String, long, GcLogger) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup
 
DiContainer - Class in com.hazelcast.spi.hotrestart.impl.di
A container which simplifies the process of "wiring" a set of collaborator objects (providing each object with references to all its collaborators), as well as basic lifecycle management (initialization and disposal).
DiContainer() - Constructor for class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Creates an empty container.
DiContainer(DiContainer) - Constructor for class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Creates an empty container which has a parent container.
DiException - Exception in com.hazelcast.spi.hotrestart.impl.di
Thrown by the DiContainer
DiException(String) - Constructor for exception com.hazelcast.spi.hotrestart.impl.di.DiException
 
DiException(String, Throwable) - Constructor for exception com.hazelcast.spi.hotrestart.impl.di.DiException
 
dismissGarbage(Chunk) - Method in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
Propagates the effects of all prefix tombstones to the given chunk.
disposable() - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Adds the object registered by the preceding dep(...) call to the list of objects to dispose when this container is disposed.
disposable(Disposable) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Adds an object to the list of objects to dispose when this container is disposed.
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Calls dispose() on all objects submitted for disposal.
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.ChunkManager
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OffHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OnHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.mem.MmapMalloc
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOffHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOnHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SortedBySeqRecordCursorOnHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
dispose() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 
disposeFilePosToKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
Disposes the file position-to-key handle map.
done() - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
Called when done reading.
DRAIN_IDLER - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 

E

END - Static variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
equals(Object) - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
equals(Object) - Method in class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 

F

FAILURE_FILE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.BackupTask
Name of the file which indicates that there was a failure during backup
file - Variable in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
 
FileCopyStrategy - Interface in com.hazelcast.spi.hotrestart.impl.io
Defines a specific strategy for copying files.
filePos() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor.Tomb
 
filePos() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
filePos - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
filePosition() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Asserts that this is a tombstone record and returns its offset in the underlying chunk file.
fine(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
fine(String, Object, Object, Object, Object, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finest(String, Object, Object, Object, Object, Object, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finestVerbose(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
finestVerbose(String, Object) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
flagForFsyncOnClose(boolean) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
As soon as a record which "needs fsync" is added to the chunk, it must not be closed without fsync-ing it first.
flagForFsyncOnClose(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughChunk
 
flagForFsyncOnClose(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Sets whether to execute an fsync operation on the chunk file before closing it.
flip() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
FNAME_SUFFIX - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Chunk filename suffix.
fnameSuffix() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
free(long, long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.mem.MmapMalloc
 
fsync() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
Performs the fsync operation on the open chunk file.
fsync() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughChunk
 
fsync() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
 
FSYNC_INTERVAL_BYTES - Static variable in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
 
full() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
 

G

garbage - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
The amount of garbage in this chunk in bytes.
garbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
garbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
 
GcExecutor - Class in com.hazelcast.spi.hotrestart.impl.gc
Contains top-level control code for the GC thread.
GcHelper - Class in com.hazelcast.spi.hotrestart.impl.gc
Contains common constants, global counters, static utility methods, and system resource-oriented methods used throughout the Hot Restart module.
GcHelper.OffHeap - Class in com.hazelcast.spi.hotrestart.impl.gc
The GC helper specialization for off-heap Hot Restart store
GcHelper.OnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc
The GC helper specialization for on-heap Hot Restart store
GcLogger - Class in com.hazelcast.spi.hotrestart.impl.gc
Adds lazy-evaluating methods to Hazelcast logger.
GcMainLoop - Class in com.hazelcast.spi.hotrestart.impl.gc
Runnable that runs the main loop of the GC thread.
GCSTATS_ENABLED - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
get(Class<T>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Looks up a registered object by type.
get(String) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Looks up a registered object by name.
get(String, Class<T>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Looks up a registered object by name and casts it into the supplied type.
get(KeyHandle) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
Returns the record mapped by the supplied KeyHandle, if any; otherwise returns null.
get(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
get(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
get(KeyHandle) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
Returns the tracker mapped by the supplied KeyHandle, if any; otherwise returns null.
get(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
get(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 
getBackupState() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupTask
Returns the current state of the backup task
getBackupTaskMaxChunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Returns the maximum chunk seq that the last submitted task will or has backed up
getBackupTaskState() - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Returns the state of the hot restart backup task
getBackupTaskState() - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
getBackupTaskState() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Returns the current state of the last backup task
getDi() - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
Gives access to the internal DI container, exclusively for testing purposes.
getKeyBuffer(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
getKeyBuffer(int) - Method in interface com.hazelcast.spi.hotrestart.RecordDataSink
Provides a ByteBuffer into which the key data should be put.
getLiveKeyHandle(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
 
getMaxChunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupTask
 
getValueBuffer(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
getValueBuffer(int) - Method in interface com.hazelcast.spi.hotrestart.RecordDataSink
Provides a ByteBuffer into which the value data should be put.
grow(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Updates the chunk's size property by adding the supplied amount.
GrowingChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a chunk which is still growing, either because the underlying file is just being written to or because an existing file is being reloaded during restart.
GrowingChunk(long, RecordMap) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
 

H

handle() - Method in interface com.hazelcast.spi.hotrestart.HotRestartKey
 
handle() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOffHeap
 
handle() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
HardLinkCopyStrategy - Class in com.hazelcast.spi.hotrestart.impl.io
File copy strategy which uses hard links from JDK7 (see https://docs.oracle.com/javase/7/docs/api/java/nio/file/Files.html#createLink(java.nio.file.Path,%20java.nio.file.Path)).
HardLinkCopyStrategy() - Constructor for class com.hazelcast.spi.hotrestart.impl.io.HardLinkCopyStrategy
Constructs the strategy or throws an exception if the relevant classes or methods are not available : java.nio.file.Files#createLink(java.nio.file.Path, java.nio.file.Path) java.io.File#toPath()
hashCode() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
hashCode() - Method in class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 
homeDir() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
hotRestart(boolean, int, ConcurrentConveyor<RestartItem>[], ConcurrentConveyor<RestartItem>, ConcurrentConveyor<RestartItem>[]) - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Performs hot restart: reads the data from persistent storage and pushes it to its associated RamStoreRegistry.
hotRestart(boolean, int, ConcurrentConveyor<RestartItem>[], ConcurrentConveyor<RestartItem>, ConcurrentConveyor<RestartItem>[]) - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
HotRestarter - Class in com.hazelcast.spi.hotrestart.impl
Reads the persistent state and: refills the RAM stores rebuilds the Hot Restart Store's metadata
HotRestartException - Exception in com.hazelcast.spi.hotrestart
Exception type exposed to the client of the Hot Restart SPI.
HotRestartException() - Constructor for exception com.hazelcast.spi.hotrestart.HotRestartException
 
HotRestartException(String) - Constructor for exception com.hazelcast.spi.hotrestart.HotRestartException
 
HotRestartException(String, Throwable) - Constructor for exception com.hazelcast.spi.hotrestart.HotRestartException
 
HotRestartException(Throwable) - Constructor for exception com.hazelcast.spi.hotrestart.HotRestartException
 
HotRestartKey - Interface in com.hazelcast.spi.hotrestart
Identifies a record in the Hot Restart store.
HotRestartModule - Class in com.hazelcast.spi.hotrestart.impl
Contains Hot Restart Store factory methods.
HotRestartPersistenceEngine - Class in com.hazelcast.spi.hotrestart.impl
Single-threaded persistence engine behind the ConcurrentHotRestartStore.
HotRestartStore - Interface in com.hazelcast.spi.hotrestart
Persistent store of key-value mappings specifically tailored to support the Hot Restart feature.
HotRestartStoreConfig - Class in com.hazelcast.spi.hotrestart.impl
Internal configuration class for the Hot Restart store.
HotRestartStoreConfig() - Constructor for class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 

I

IN_PROGRESS_FILE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.BackupTask
Name of the file which indicates that there is a backup in progress
incrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Increments this record's garbage count.
incrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
incrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
incrementGarbageCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
Increments the global garbage count for this tracker.
info(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
initChunkSeq(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Initializes the chunk sequence counter to the given value.
initFilePosToKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
Initializes the file position-to-key handle map used during TombGC to look up a tombstone at a given file position, in order to determine its liveness status.
INITIAL_BUFSIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
Initial size of the key/value byte buffers
initialize(Object) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Calls all Initialize-annotated methods on the supplied object.
Initialize - Annotation Type in com.hazelcast.spi.hotrestart.impl.di
Annotates a method that the DI container will invoke after all the objects in the container had their dependencies injected.
Inject - Annotation Type in com.hazelcast.spi.hotrestart.impl.di
Annotates a field, method, or constructor that the DI container will assign/invoke.
inProgress() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Returns if the backup task is in progress.
insertOrUpdate(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveValChunk
 
insertOrUpdate(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Inserts a new entry in the chunk's record map or updates the existing one under the same key handle.
insertOrUpdate(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.SurvivorValChunk
 
insertOrUpdate(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
insertOrUpdateTombstone(long, long, KeyHandle, int, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Implements insertOrUpdate for a tombstone record.
insertOrUpdateValue(long, long, KeyHandle, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
Implements insertOrUpdate for a value record.
instantiate(Class<T>) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Instantiates the given type by calling its @Inject-annotated constructor and satisfying the constructor's dependencies.
interruptBackupTask() - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Interrupts the backup task if one is currently running.
interruptBackupTask() - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
interruptBackupTask(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Interrupts the backup task if one is currently running.
invoke(Object, String) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
 
isActiveChunkFile(File) - Static method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor
 
isAlive() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
isAlive() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
 
isBackupTaskDone() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Returns true if the backup task is done (successfully or with failure) or if there is no submitted backup task
isClearedItem() - Method in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
isSpecialItem() - Method in class com.hazelcast.spi.hotrestart.impl.RestartItem
Says whether this is a special item, either: describing a cleared record (interred by a prefix tombstone), requesting to remove null-keys from the RamStore, or the "submitter gone" item, which the submitter thread sends as the very last item.
isTombstone() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
isTombstone() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
 

K

key() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
key() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
key - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
keyBuffer - Variable in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
keyHandle - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
KeyHandle - Interface in com.hazelcast.spi.hotrestart
A "lightweight" key which uniquely identifies a record in the Hot Restart store's metadata structures using the minimal amount of data.
KeyHandleOffHeap - Interface in com.hazelcast.spi.hotrestart
KeyHandle for an off-heap record.
keyHandleSenders - Variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 
KeyOffHeap - Class in com.hazelcast.spi.hotrestart.impl
Implementation of HotRestartKey for off-heap hot restart store.
KeyOffHeap(long, byte[], long, long) - Constructor for class com.hazelcast.spi.hotrestart.impl.KeyOffHeap
 
KeyOnHeap - Class in com.hazelcast.spi.hotrestart.impl
Implementation usable both as HotRestartKey and KeyHandle for an on-heap hot restart store.
KeyOnHeap(long, byte[]) - Constructor for class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
keyPrefix(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
keyPrefix(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
keyPrefix(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
keyPrefix() - Method in class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
 
keyReceivers - Variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 

L

liveRecordCount - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
liveSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Asserts that the record is alive and returns its sequence number.
liveTombstones - Variable in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
The global count of live tombstones in the store.
liveValues - Variable in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
The global count of live values in the store.
loadAndCopyTombstone(int, ChunkFileOut) - Method in class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
Loads the header data of the tombstone at pos into the cursor object and copies the tombstone into the supplied ChunkFileOut.
LOG_CATEGORY - Static variable in interface com.hazelcast.spi.hotrestart.HotRestartStore
The name of the log category used by the Hot Restart module
LOG_OF_BUFFER_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.HotRestarter
Base-2 logarithm of buffer size.
logger() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 

M

malloc() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
MAX_BUCKET_DIRS - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
To optimize file access times, chunk files are distributed across bucket directories.
MAX_PARK_MICROS - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
Max park microseconds while awaiting new items in the queue.
maxChunkSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
 
maxRecordSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
Returns the maximum observed record seq in the collector prefix tombstone list, regardless of prefix
metricsRegistry() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
MIN_QUEUE_CAPACITY - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 
MmapMalloc - Class in com.hazelcast.spi.hotrestart.impl.gc.mem
Allocator based on memory-mapped files.
MmapMalloc(File, boolean) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.mem.MmapMalloc
 
moveToChunk(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
Makes this tracker point to a new chunk seq as the location of the live record.
MUTATOR_QUEUE_CAPACITY - Static variable in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
Capacity of the many-to-one queue used by partition threads to submit to HotRestart persistence thread
MutatorCatchup - Class in com.hazelcast.spi.hotrestart.impl.gc
Instance of this class is passed around to allow catching up with the mutator thread at any point along the GC cycle codepath.
MutatorCatchup.CatchupRunnable - Interface in com.hazelcast.spi.hotrestart.impl.gc
Allows a task to be run with access to the MutatorCatchup.

N

name() - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Returns the store's name, which matches the name of its home directory.
name() - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
Name - Annotation Type in com.hazelcast.spi.hotrestart.impl.di
 
needsDismissing() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
needsDismissing(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Sets whether the "dismiss prefix garbage" operation is needed for this chunk.
needsDismissing(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
 
needsDismissing(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
negateSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Negates the value of the rawSeq property.
negateSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
negateSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
NEW_FILE_SUFFIX - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
 
newActiveTombChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Creates a new active tombstone chunk file and returns an instance of WriteThroughTombChunk that wraps it.
newActiveValChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Creates a new active value chunk file and returns an instance of ActiveValChunk that wraps it.
newLiveRecord(long, boolean, TrackerMap, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
Signals that a new live record with this tracker's key handle for has entered the system.
newOffHeapHotRestartStore(HotRestartStoreConfig, HazelcastProperties) - Static method in class com.hazelcast.spi.hotrestart.impl.HotRestartModule
Constructs, configures, and returns an off-heap Hot Restart Store.
newOnHeapHotRestartStore(HotRestartStoreConfig, HazelcastProperties) - Static method in class com.hazelcast.spi.hotrestart.impl.HotRestartModule
Constructs, configures, and returns an on-heap Hot Restart Store.
newRecordMap(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OffHeap
 
newRecordMap(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OnHeap
 
newRecordMapOffHeap(MemoryManager, MemoryManager) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
newSetOfKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Creates and returns an instance of SetOfKeyHandle.
newSetOfKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OffHeap
 
newSetOfKeyHandle() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OnHeap
 
newSurvivorValChunk(MutatorCatchup) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Creates a new survivor value chunk file and returns an instance of SurvivorValChunk that wraps it.
newTombstoneMap() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OffHeap
 
newTombstoneMapOffHeap(MemoryManager) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
newTrackerMap() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Creates and returns an instance of TrackerMap.
newTrackerMap() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OffHeap
 
newTrackerMap() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper.OnHeap
 
nextRecordSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Increments the record sequence counter and returns the new value.

O

out - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughChunk
 

P

payloadSize() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
positionInUnitsOfBufsize(long) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Expresses the given file position in the unit of HotRestarter.BUFFER_SIZE.
preAccept(long, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
To be called for each encountered record and followed with a call to either Rebuilder.accept(RestartItem) or Rebuilder.acceptCleared(RestartItem).
prefix() - Method in interface com.hazelcast.spi.hotrestart.HotRestartKey
 
prefix() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
prefix() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
prefix() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOffHeap
 
prefix() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
prefix - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
PREFIX_TOMBSTONES_FILENAME - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Name of the file that contains prefix tombstones
PrefixTombstoneManager - Class in com.hazelcast.spi.hotrestart.impl.gc
Manages "prefix tombstones" which inter all entries under a given key prefix.
prefixToThreadId(long) - Method in interface com.hazelcast.spi.hotrestart.RamStoreRegistry
Returns the ID of the partition thread responsible for the given key prefix.
prepareForNewTask() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
If there is no currently running task, makes a reservation so that following invocations of BackupExecutor.getBackupTaskState() return BackupTaskState.NOT_STARTED.
PROPERTY_GCSTATS_ENABLED - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
PROPERTY_VERBOSE_FINEST_LOGGING - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
put(HotRestartKey, byte[], boolean) - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Establishes a persistent mapping from the supplied key to the supplied value.
put(HotRestartKey, byte[], boolean) - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
putIfAbsent(long, KeyHandle, long, int, boolean, int) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
If there is no current mapping for kh, establishes a mapping from kh to a record defined by (seq, size, isTombstone, additionalInt) and returns null.
putIfAbsent(long, KeyHandle, long, int, boolean, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
putIfAbsent(long, KeyHandle, long, int, boolean, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
putIfAbsent(KeyHandle, long, boolean) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
If there is no current mapping for kh, establishes a mapping from kh to a tracker defined by (chunkSeq, isTombstone) and returns null.
putIfAbsent(KeyHandle, long, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
putIfAbsent(KeyHandle, long, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 

Q

QUEUE_CAPACITY_BUDGET - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 

R

ramStore - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
RamStore - Interface in com.hazelcast.spi.hotrestart
Specifies operations that the Hot Restart store will request from the RAM store.
ramStoreForPrefix(long) - Method in interface com.hazelcast.spi.hotrestart.RamStoreRegistry
Returns the RAM store in charge of the supplied key prefix.
ramStoreRegistry() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
RamStoreRegistry - Interface in com.hazelcast.spi.hotrestart
RAM store registry for the data managed by a Hot Restart store.
RamStoreRestartLoop - Class in com.hazelcast.spi.hotrestart.impl
Contains the main loop executed by the threads that call into the RamStore during the Hot Restart process.
RamStoreRestartLoop(int, int, RamStoreRegistry, ILogger) - Constructor for class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 
rawSeqValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
rawSeqValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
rawSeqValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
rawSizeValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
rawSizeValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
rawSizeValue() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
reallocate(long, long, long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.mem.MmapMalloc
 
Rebuilder - Class in com.hazelcast.spi.hotrestart.impl.gc
Rebuilds the GC-related metadata during the Hot Restart procedure.
Record - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Holds the metadata on the newest record in a chunk associated with a given key and also some metadata on any dead records within the same chunk associated with the same key.
Record() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
RecordDataHolder - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Implementation of RecordDataSink.
RecordDataHolder() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
RecordDataSink - Interface in com.hazelcast.spi.hotrestart
A mutable sink for the data of a single record in the Hot Restart Store.
RecordMap - Interface in com.hazelcast.spi.hotrestart.impl.gc.record
Special-purpose map from KeyHandle to Record, used to hold GC-related metadata about one chunk.
RecordMap.Cursor - Interface in com.hazelcast.spi.hotrestart.impl.gc.record
Cursor over record map's contents.
RecordMapOffHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Record map backed by off-heap storage.
RecordMapOnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Map with on-heap keys and records.
RecordMapOnHeap() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
RecordOffHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Specialization of Record as a Flyweight object around a pointer to a native-memory record structure.
RecordOffHeap() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
RecordOnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Specialization of Record as a plain Java object.
RecordOnHeap(long, int, boolean, int) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
records - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
recordSeq() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
 
recordSeq() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
recordSeq() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
recordSeq() - Method in class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
 
recordSeq - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
recordSize() - Method in class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
 
reduceGarbageCount(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
Reduces the global garbage count for this tracker by the specified amount.
remove(HotRestartKey, boolean) - Method in interface com.hazelcast.spi.hotrestart.HotRestartStore
Removes the persistent mapping for the supplied key.
remove(HotRestartKey, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.ConcurrentHotRestartStore
 
remove(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOffHeap
 
remove(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOnHeap
 
remove(KeyHandle) - Method in interface com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle
Removes a key handle from the set.
removeIfDead(KeyHandle, Tracker) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
Removes the entry for tr if tr represents a dead record.
removeIfDead(KeyHandle, Tracker) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
 
removeLiveTombstone(KeyHandle) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
Removes the entry for kh assuming that it maps to a tracker representing a live tombstone.
removeLiveTombstone(KeyHandle) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
 
removeNullEntries(SetOfKeyHandle) - Method in interface com.hazelcast.spi.hotrestart.RamStore
Called during Hot Restart.
restart(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestarter
 
restartingRamStoreForPrefix(long) - Method in interface com.hazelcast.spi.hotrestart.RamStoreRegistry
Returns the RAM store in charge of the supplied key prefix.
RestartItem - Class in com.hazelcast.spi.hotrestart.impl
Item in the concurret queues during restarting.
RestartItem.WithSetOfKeyHandle - Class in com.hazelcast.spi.hotrestart.impl
Used both for the "remove null keys" item and for the "submitter gone" item.
retire(KeyHandle, Record, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Retires a record in this chunk (makes it dead).
retire(KeyHandle, Record) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
retire(KeyHandle, Record, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
 
retire(boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Retires this record (makes it dead).
retire(TrackerMap) - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
Signals that the live record that this tracker points to was retired.
run(BackupTask) - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupExecutor
Runs the backup task.
run() - Method in class com.hazelcast.spi.hotrestart.impl.gc.BackupTask
Runs the backup task.
run() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcMainLoop
 
run(MutatorCatchup) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup.CatchupRunnable
 
run(int) - Method in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 
runWhileGcPaused(MutatorCatchup.CatchupRunnable) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Runs the task while holding a mutex lock which is also held during GC activity.

S

seq - Variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Unique sequence number of this chunk.
seq(File) - Static method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor
 
sequenceId() - Method in class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 
sequenceId() - Method in interface com.hazelcast.spi.hotrestart.KeyHandleOffHeap
 
setAdditionalInt(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Sets the raw "additional int" property on this record.
setAdditionalInt(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
setAdditionalInt(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
setFilePosition(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Asserts that this is a tombstone record and sets its offset in the underlying chunk file to the supplied value.
setGarbageCount(int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Sets this record's garbage count to the given value.
setHomeDir(File) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
setLoggingService(LoggingService) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
setMalloc(MemoryAllocator) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
setMaxSeq(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
 
setMetricsRegistry(MetricsRegistry) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
SetOfKeyHandle - Interface in com.hazelcast.spi.hotrestart.impl
Set of key handles.
SetOfKeyHandle.KhCursor - Interface in com.hazelcast.spi.hotrestart.impl
 
SetOfKeyHandleOffHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
Off-heap implementation of SetOfKeyHandle.
SetOfKeyHandleOffHeap(MemoryManager) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOffHeap
 
SetOfKeyHandleOnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
On-heap implementation of SetOfKeyHandle.
SetOfKeyHandleOnHeap() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.record.SetOfKeyHandleOnHeap
 
setPrefixTombstones(Long2LongHashMap) - Method in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
Initializes this object with the existing prefix tombstones reloaded from a file.
setRamStoreRegistry(RamStoreRegistry) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
setRawSeqSize(long, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Sets the raw "seq" and "size" values on this record.
setRawSeqSize(long, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
setRawSeqSize(long, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOnHeap
 
setStoreName(String) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
severe(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
severe(String, Throwable) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
shutdown() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Asks the GC thread to stop and awaits its completion.
shutdownRequested() - Method in class com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup
 
SimpleHandleOffHeap - Class in com.hazelcast.spi.hotrestart.impl
Simple implementation of KeyHandleOffHeap.
SimpleHandleOffHeap(long, long) - Constructor for class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 
size() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableChunk
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
size(byte[], byte[]) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Calculates the size in bytes a record would have in a chunk file if it contained the provided key and value blobs.
size() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
size() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 
size() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor
 
size() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
size - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
Snapshotter - Class in com.hazelcast.spi.hotrestart.impl.gc
Takes a snapshot of the Hot Restart Store state and saves it to the file named "chunk-snapshot.bin" in the Hot Restart Store's home directory.
sokh - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem.WithSetOfKeyHandle
 
sortedBySeqCursor(int, RecordMap[], MutatorCatchup) - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
Creates a sorted-by-seq cursor over all live records in the provided record maps.
sortedBySeqCursor(int, RecordMap[], MutatorCatchup) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
sortedBySeqCursor(int, RecordMap[], MutatorCatchup) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
SortedBySeqRecordCursor - Interface in com.hazelcast.spi.hotrestart.impl
Cursor over records sorted by their recordSeq.
SortedBySeqRecordCursorOnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.record
On-heap implementation of SortedBySeqRecordCursor.
SOURCE_CHUNK_FLAG_MASK - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
SPIN_COUNT - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
How many times to busy-spin while awaiting new items in the queue.
StableChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a fully constructed chunk whose on-disk contents are stable (immutable).
stableChunkFile(StableChunk, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcHelper
Returns a File instance representing the file associated with the given stable chunk.
StableTombChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Stable tombstone chunk.
StableTombChunk(long, RecordMap, int, long, long) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
 
StableValChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a chunk whose on-disk contents are stable (immutable).
StableValChunk(ActiveValChunk) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
 
StableValChunk(long, RecordMap, int, long, long, boolean) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
 
StableValChunk(long, RecordMap, LongSet, int, long, long, boolean) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
 
start() - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Starts the GC thread.
start(ILogger, ChunkManager, String) - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartPersistenceEngine
 
startValuePhase(Map<Long, SetOfKeyHandle>) - Method in class com.hazelcast.spi.hotrestart.impl.gc.Rebuilder
The Hot Restart procedure starts with the tombstone chunk reading phase and this method is called when transitioning into the value chunk reading phase.
storeName() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
submitBackup(File) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
 
submitRecord(HotRestartKey, long, int, boolean) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Submits a "record added" event to the GC thread's work queue.
submitReplaceActiveChunk(ActiveChunk, ActiveChunk) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcExecutor
Submits a "active chunk replaced" event to the GC thread's work queue.
SURVIVOR_FLAG_MASK - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
SURVIVOR_FNAME_SUFFIX - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Suffix added to a chunk file while it is being written to during a GC cycle.
SurvivorValChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Survivor chunk used by the ValEvacuator.
SurvivorValChunk(long, RecordMap, ChunkFileOut, GcHelper) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.SurvivorValChunk
 
SWEEPING_TIMESLICE_MS - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager
 
SYSPROP_TOMB_CHUNK_SIZE_LIMIT - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
System property that specifies the limit on the tombstone chunk file size
SYSPROP_VAL_CHUNK_SIZE_LIMIT - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
System property that specifies the limit on the value chunk file size

T

toKeyHandle() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap.Cursor
 
toKeyHandle() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMap.Cursor
 
toKeyHandle(byte[]) - Method in interface com.hazelcast.spi.hotrestart.RamStore
Called during Hot Restart.
Tomb(File) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor.Tomb
 
Tomb(List<File>) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor.Tomb
 
TOMB_BASEDIR - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Name of the base directory for tombstone records.
TOMB_HEADER_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Size of the tombstone record header in a chunk file: seq, prefix, key size
TOMB_SIZE_LIMIT_DEFAULT - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Default tombstone chunk file size limit in bytes.
tombChunkSizeLimit() - Static method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Fetches the configured size limit in bytes for the tombstone chunk from the system property "hazelcast.hotrestart.tomb.chunk.size.limit".
TombFileAccessor - Class in com.hazelcast.spi.hotrestart.impl.io
Read-only accessor of data inside a tombstone chunk file.
TombFileAccessor(File) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.TombFileAccessor
 
TOMBSTONE_FLAG_MASK - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.Snapshotter
 
TOMBSTONE_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
toRawSizeValue(int, boolean) - Static method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Encodes the given size and isTombstone parameters into a single int value of the raw "size" property.
toStable() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap
Special-purpose method supporting an off-heap memory optimization where during GC the growing chunk's record map is stored using an auxiliary memory allocator that allocates from a different pool than the main one, thus reducing the peak memory demand on the main allocator.
toStable() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap
 
toStable() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOnHeap
 
toStableChunk() - Method in interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk
Converts this active chunk into a stable chunk.
toStableChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveValChunk
 
toStableChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.SurvivorValChunk
 
toStableChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughChunk
 
toStableChunk() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
toString() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
 
toString() - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
 
toString() - Method in class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
 
toString() - Method in class com.hazelcast.spi.hotrestart.impl.KeyOnHeap
 
toString() - Method in class com.hazelcast.spi.hotrestart.impl.SimpleHandleOffHeap
 
trackedKeyCount() - Method in class com.hazelcast.spi.hotrestart.impl.gc.ChunkManager
 
Tracker - Class in com.hazelcast.spi.hotrestart.impl.gc.tracker
Tracks the GC state for a single key handle in the Hot Restart store: which chunk holds the live record, whether it's a tombstone, and the global garbage count for the key handle.
Tracker() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.tracker.Tracker
 
TrackerMap - Interface in com.hazelcast.spi.hotrestart.impl.gc.tracker
Special-purpose map from KeyHandle to Tracker, used to hold global GC-related metadata about all records in the Hot Restart Store.
TrackerMap.Cursor - Interface in com.hazelcast.spi.hotrestart.impl.gc.tracker
Cursor over tracker map's entries.
TrackerMapBase - Class in com.hazelcast.spi.hotrestart.impl.gc.tracker
Abstract base class common to both tracker map implementations.
TrackerMapBase() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapBase
 
TrackerMapOffHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.tracker
Off-heap implementation of record tracker map.
TrackerMapOffHeap(MemoryManager, MemoryAllocator) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOffHeap
 
TrackerMapOnHeap - Class in com.hazelcast.spi.hotrestart.impl.gc.tracker
On-heap implementation of record tracker map.
TrackerMapOnHeap() - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.tracker.TrackerMapOnHeap
 

U

update(long, int) - Method in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Updates the sequence number and size properties of this record to the supplied values.
updateBenefitToCost() - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableTombChunk
Updates the cached value of the Benefit-Cost factor.
updateBenefitToCost(long) - Method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.StableValChunk
Updates the cached value of the benefit/cost factor.

V

Val(List<File>) - Constructor for class com.hazelcast.spi.hotrestart.impl.io.ChunkFilesetCursor.Val
 
VAL_BASEDIR - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Name of the base directory for value records.
VAL_HEADER_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.record.Record
Size of the value record header in a chunk file: seq, prefix, key size, value size
VAL_SIZE_LIMIT_DEFAULT - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Default value chunk file size limit in bytes.
valChunkSizeLimit() - Static method in class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk
Fetches the configured size limit in bytes for the value chunk from the system property "hazelcast.hotrestart.val.chunk.size.limit".
validateAndCreateHomeDir() - Method in class com.hazelcast.spi.hotrestart.impl.HotRestartStoreConfig
 
value() - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileCursor.Tomb
 
value() - Method in interface com.hazelcast.spi.hotrestart.impl.io.ChunkFileRecord
 
value - Variable in class com.hazelcast.spi.hotrestart.impl.RestartItem
 
VALUE_RECORD_SIZE - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordOffHeap
 
valueBuffer - Variable in class com.hazelcast.spi.hotrestart.impl.gc.record.RecordDataHolder
 
valueReceivers - Variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
 
VERBOSE_FINEST_LOGGING - Static variable in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 

W

warning(String) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
warning(String, Throwable) - Method in class com.hazelcast.spi.hotrestart.impl.gc.GcLogger
 
wire(T) - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Late-wires the provided target object without registering it with the container.
wireAndInitializeAll() - Method in class com.hazelcast.spi.hotrestart.impl.di.DiContainer
Late-wires all the objects registered with the container, then calls all Initialize-annotated methods on each object.
WithSetOfKeyHandle(long, SetOfKeyHandle) - Constructor for class com.hazelcast.spi.hotrestart.impl.RestartItem.WithSetOfKeyHandle
 
WriteThroughChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Represents a chunk associated with an open file.
WriteThroughTombChunk - Class in com.hazelcast.spi.hotrestart.impl.gc.chunk
Write-through chunk specialized to contain tombstone records.
WriteThroughTombChunk(long, String, RecordMap, ChunkFileOut, GcHelper) - Constructor for class com.hazelcast.spi.hotrestart.impl.gc.chunk.WriteThroughTombChunk
 
writeTombstone(long, long, byte[]) - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Writes a tombstone record to the chunk file.
writeTombstone(long, long, ByteBuffer, int) - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Writes a tombstone record to the chunk file.
writeValueRecord(long, long, byte[], byte[]) - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Writes a value record to the chunk file.
writeValueRecord(Record, long, ByteBuffer, ByteBuffer) - Method in class com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut
Writes a value record to the chunk file.

Y

YIELD_COUNT - Static variable in class com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop
How many times to yield while awaiting new items in the queue.
A B C D E F G H I K L M N O P Q R S T U V W Y 
Skip navigation links

Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.