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

Class WriteThroughTombChunk

java.lang.Object

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

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

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

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

All Implemented Interfaces:

com.hazelcast.nio.Disposable, ActiveChunk

public class WriteThroughTombChunk
extends WriteThroughChunk
implements ActiveChunk

Write-through chunk specialized to contain tombstone records.

Field Summary

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

out

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

Constructor and Description
WriteThroughTombChunk(long seq, String suffix, RecordMap records, ChunkFileOut out, GcHelper gcHelper)

Method Summary

Modifier and Type	Method and Description
boolean	addStep1(long recordSeq, long keyPrefix, byte[] keyBytes, byte[] ignored) Writes a record to the chunk file and updates the size property on this object.
boolean	addStep1(TombFileAccessor tfa, int filePos) Does the same work as addStep1(long, long, byte[], byte[]), but using a TombFileAccessor to get the data.
String	base()
protected int	determineSizeLimit() Determines the limit on the size of this chunk by reading a system property.
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.
void	needsDismissing(boolean needsDismissing) Sets whether the "dismiss prefix garbage" operation is needed for this chunk.
StableTombChunk	toStableChunk() Converts this active chunk into a stable chunk.

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

close, flagForFsyncOnClose, fsync

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

addStep2, addStep2, full, grow, insertOrUpdateTombstone, insertOrUpdateValue, size

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.spi.hotrestart.impl.gc.chunk.ActiveChunk

close, flagForFsyncOnClose, fsync, size

Methods inherited from interface com.hazelcast.nio.Disposable

dispose

Constructor Detail

WriteThroughTombChunk

public WriteThroughTombChunk(long seq,
                             String suffix,
                             RecordMap records,
                             ChunkFileOut out,
                             GcHelper gcHelper)

Method Detail

addStep1

public boolean addStep1(long recordSeq,
                        long keyPrefix,
                        byte[] keyBytes,
                        byte[] ignored)

Description copied from interface: ActiveChunk

Writes a record to the chunk file and updates the size property on this object. May be called on the mutator thread.

Specified by:

addStep1 in interface ActiveChunk

Returns:

true if the chunk is now full.

addStep1

public boolean addStep1(TombFileAccessor tfa,
                        int filePos)

Does the same work as addStep1(long, long, byte[], byte[]), but using a TombFileAccessor to get the data.

Parameters:

tfa - tombstone file accessor connected to the source tombstone chunk

filePos - position of the tombstone in the source chunk

Returns:

whether this chunk is now full

insertOrUpdate

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

Description copied from class: GrowingChunk

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

Specified by:

insertOrUpdate in class GrowingChunk

determineSizeLimit

protected int determineSizeLimit()

Description copied from class: GrowingChunk

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.

Specified by:

determineSizeLimit in class GrowingChunk

needsDismissing

public void needsDismissing(boolean needsDismissing)

Description copied from class: Chunk

Sets whether the "dismiss prefix garbage" operation is needed for this chunk.

Overrides:

needsDismissing in class Chunk

base

public String base()

Overrides:

base in class Chunk

Returns:

name of the base directory of this chunk (within the owning Hot Restart store's home dir)

toStableChunk

public StableTombChunk toStableChunk()

Description copied from interface: ActiveChunk

Converts this active chunk into a stable chunk.

Specified by:

toStableChunk in interface ActiveChunk

Specified by:

toStableChunk in class WriteThroughChunk