com.hazelcast.spi.hotrestart.impl.gc.chunk

Class GrowingChunk

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk

com.hazelcast.spi.hotrestart.impl.gc.chunk.GrowingChunk

All Implemented Interfaces:

com.hazelcast.nio.Disposable

Direct Known Subclasses:

WriteThroughChunk

public abstract class GrowingChunk
extends 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.

Field Summary

Fields inherited from class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk

ACTIVE_FNAME_SUFFIX, FNAME_SUFFIX, garbage, liveRecordCount, records, seq, SURVIVOR_FNAME_SUFFIX, SYSPROP_TOMB_CHUNK_SIZE_LIMIT, SYSPROP_VAL_CHUNK_SIZE_LIMIT, TOMB_BASEDIR, TOMB_SIZE_LIMIT_DEFAULT, VAL_BASEDIR, VAL_SIZE_LIMIT_DEFAULT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GrowingChunk(long chunkSeq, RecordMap records)

Method Summary

Modifier and Type	Method and Description
void	addStep2(long recordSeq, long keyPrefix, KeyHandle kh, int size) Adds the record to this chunk's record map.
void	addStep2(long recordSeq, long keyPrefix, KeyHandle kh, int filePos, int size) Called only by Rebuilder, which encounters records out of file order.
protected abstract int	determineSizeLimit() Determines the limit on the size of this chunk by reading a system property.
boolean	full()
protected void	grow(int amount) Updates the chunk's size property by adding the supplied amount.
abstract void	insertOrUpdate(long recordSeq, long keyPrefix, KeyHandle kh, int filePos, int size) Inserts a new entry in the chunk's record map or updates the existing one under the same key handle.
protected void	insertOrUpdateTombstone(long recordSeq, long keyPrefix, KeyHandle kh, int filePos, int size) Implements insertOrUpdate for a tombstone record.
protected void	insertOrUpdateValue(long recordSeq, long keyPrefix, KeyHandle kh, int size) Implements insertOrUpdate for a value record.
long	size()

Methods inherited from class com.hazelcast.spi.hotrestart.impl.gc.chunk.Chunk

base, dispose, fnameSuffix, needsDismissing, needsDismissing, retire, retire, tombChunkSizeLimit, toString, valChunkSizeLimit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GrowingChunk

protected GrowingChunk(long chunkSeq,
                       RecordMap records)

Method Detail

addStep2

public final void addStep2(long recordSeq,
                           long keyPrefix,
                           KeyHandle kh,
                           int size)

Adds the record to this chunk's record map. Called by the collector thread.

addStep2

public final void addStep2(long recordSeq,
                           long keyPrefix,
                           KeyHandle kh,
                           int filePos,
                           int size)

Called only by Rebuilder, which encounters records out of file order. Therefore addStep2FilePos is unusable.

insertOrUpdate

public abstract void insertOrUpdate(long recordSeq,
                                    long keyPrefix,
                                    KeyHandle kh,
                                    int filePos,
                                    int size)

Inserts a new entry in the chunk's record map or updates the existing one under the same key handle.

size

public final long size()

Specified by:

size in class Chunk

Returns:

size in bytes of the chunk file

grow

protected final void grow(int amount)

Updates the chunk's size property by adding the supplied amount.

full

public final boolean full()

Returns:

true if this chunk's size has reached (or exceeded) its size limit.

insertOrUpdateValue

protected final void insertOrUpdateValue(long recordSeq,
                                         long keyPrefix,
                                         KeyHandle kh,
                                         int size)

Implements insertOrUpdate for a value record.

insertOrUpdateTombstone

protected final void insertOrUpdateTombstone(long recordSeq,
                                             long keyPrefix,
                                             KeyHandle kh,
                                             int filePos,
                                             int size)

Implements insertOrUpdate for a tombstone record.

determineSizeLimit

protected abstract int determineSizeLimit()

Determines the limit on the size of this chunk by reading a system property. The size limit is used to decide when to deactivate a chunk and create a new one.