Package org.iq80.leveldb.impl

Class MMapLogWriter

java.lang.Object

org.iq80.leveldb.impl.MMapLogWriter

All Implemented Interfaces:

LogWriter

public class MMapLogWriter
extends Object
implements LogWriter

Field Summary

Fields

Modifier and Type	Field	Description
private int	blockOffset	Current offset in the current block
private final AtomicBoolean	closed
private final File	file
private final FileChannel	fileChannel
private final long	fileNumber
private long	fileOffset
private MappedByteBuffer	mappedByteBuffer
private static final int	PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
MMapLogWriter(File file, long fileNumber)

Method Summary

Modifier and Type	Method	Description
void	addRecord(Slice record, boolean force)
void	close()
void	delete()
private void	destroyMappedByteBuffer()
private void	ensureCapacity(int bytes)
File	getFile()
long	getFileNumber()
boolean	isClosed()
private static Slice	newLogRecordHeader(LogChunkType type, Slice slice)
private void	unmap()
private void	writeChunk(LogChunkType type, Slice slice)

Methods inherited from class java.lang.Object

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

Field Details

PAGE_SIZE

private static final int PAGE_SIZE

See Also:

• Constant Field Values

file

private final File file

fileNumber

private final long fileNumber

fileChannel

private final FileChannel fileChannel

closed

private final AtomicBoolean closed

mappedByteBuffer

private MappedByteBuffer mappedByteBuffer

fileOffset

private long fileOffset

blockOffset

private int blockOffset

Current offset in the current block

Constructor Details

MMapLogWriter

public MMapLogWriter(File file,
 long fileNumber)
              throws IOException

Throws:

IOException

Method Details

isClosed

public boolean isClosed()

Specified by:

isClosed in interface LogWriter

close

public void close()
           throws IOException

Specified by:

close in interface LogWriter

Throws:

IOException

delete

public void delete()
            throws IOException

Specified by:

delete in interface LogWriter

Throws:

IOException

destroyMappedByteBuffer

private void destroyMappedByteBuffer()

getFile

public File getFile()

Specified by:

getFile in interface LogWriter

getFileNumber

public long getFileNumber()

Specified by:

getFileNumber in interface LogWriter

addRecord

public void addRecord(Slice record,
 boolean force)
               throws IOException

Specified by:

addRecord in interface LogWriter

Throws:

IOException

writeChunk

private void writeChunk(LogChunkType type,
 Slice slice)
                 throws IOException

Throws:

IOException

ensureCapacity

private void ensureCapacity(int bytes)
                     throws IOException

Throws:

IOException

unmap

private void unmap()

newLogRecordHeader

private static Slice newLogRecordHeader(LogChunkType type,
 Slice slice)