com.hazelcast.spi.hotrestart.impl.io

Class ChunkFileOut

java.lang.Object

com.hazelcast.spi.hotrestart.impl.io.ChunkFileOut

All Implemented Interfaces:

Closeable, AutoCloseable

public class ChunkFileOut
extends Object
implements Closeable

Encapsulates chunk file writing code.

Field Summary

Fields

Modifier and Type	Field and Description
File	file
static int	FSYNC_INTERVAL_BYTES

Constructor Summary

Constructors

Constructor and Description
ChunkFileOut(File file, MutatorCatchup mc)

Method Summary

Modifier and Type	Method and Description
void	close() Flushes any remaining data to the file, executes fsync on it as indicated by the needsFsyncBeforeClosing flag, and closes the file.
void	flagForFsyncOnClose(boolean fsyncOnClose) Sets whether to execute an fsync operation on the chunk file before closing it.
void	fsync()
void	writeTombstone(long seq, long prefix, byte[] key) Writes a tombstone record to the chunk file.
void	writeTombstone(long seq, long prefix, ByteBuffer keyBuf, int keySize) Writes a tombstone record to the chunk file.
void	writeValueRecord(long seq, long prefix, byte[] key, byte[] value) Writes a value record to the chunk file.
void	writeValueRecord(Record r, long keyPrefix, ByteBuffer keyBuf, ByteBuffer valBuf) Writes a value record to the chunk file.

Methods inherited from class java.lang.Object

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

Field Detail

FSYNC_INTERVAL_BYTES

public static final int FSYNC_INTERVAL_BYTES

See Also:

Constant Field Values

file

public final File file

Constructor Detail

ChunkFileOut

public ChunkFileOut(File file,
                    MutatorCatchup mc)
             throws FileNotFoundException

Throws:

FileNotFoundException

Method Detail

writeValueRecord

public void writeValueRecord(long seq,
                             long prefix,
                             byte[] key,
                             byte[] value)

Writes a value record to the chunk file.

Parameters:

seq - record seq

prefix - key prefix

key - key blob

value - value blob

writeValueRecord

public void writeValueRecord(Record r,
                             long keyPrefix,
                             ByteBuffer keyBuf,
                             ByteBuffer valBuf)

Writes a value record to the chunk file.

Parameters:

r - Record instance corresponding to the record to be written

keyPrefix - key prefix

keyBuf - byte buffer with key blob

valBuf - byte buffer with value blob

writeTombstone

public void writeTombstone(long seq,
                           long prefix,
                           byte[] key)

Writes a tombstone record to the chunk file.

Parameters:

seq - record seq

prefix - key prefix

key - key blob

writeTombstone

public void writeTombstone(long seq,
                           long prefix,
                           ByteBuffer keyBuf,
                           int keySize)

Writes a tombstone record to the chunk file.

Parameters:

seq - record seq

prefix - key prefix

keyBuf - byte buffer containing, among other data, the key blob and positioned at it

keySize - size of the key

flagForFsyncOnClose

public void flagForFsyncOnClose(boolean fsyncOnClose)

Sets whether to execute an fsync operation on the chunk file before closing it.

fsync

public void fsync()

close

public void close()

Flushes any remaining data to the file, executes fsync on it as indicated by the needsFsyncBeforeClosing flag, and closes the file.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable