FileChannelLogWriter

java.lang.Object

org.iq80.leveldb.impl.FileChannelLogWriter

All Implemented Interfaces:: LogWriter

public class FileChannelLogWriter 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
Constructor Summary

Constructors

Constructor

Description

FileChannelLogWriter(File file, long fileNumber)
Method Summary

Modifier and Type

Method

Description

void

addRecord(Slice record, boolean force)

void

close()

void

delete()

File

getFile()

long

getFileNumber()

boolean

isClosed()

private Slice

newLogRecordHeader(LogChunkType type, Slice slice, int length)

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
- file
  
  private final File file
- fileNumber
  
  private final long fileNumber
- fileChannel
  
  private final FileChannel fileChannel
- closed
  
  private final AtomicBoolean closed
- blockOffset
  
  private int blockOffset
  
  Current offset in the current block
Constructor Details
- FileChannelLogWriter
  
  public FileChannelLogWriter(File file, long fileNumber) throws FileNotFoundException
  
  Throws:
  
  FileNotFoundException
Method Details
- isClosed
  
  public boolean isClosed()
  
  Specified by:
  
  isClosed in interface LogWriter
- close
  
  public void close()
  
  Specified by:
  
  close in interface LogWriter
- delete
  
  public void delete()
  
  Specified by:
  
  delete in interface LogWriter
- 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
- newLogRecordHeader
  
  private Slice newLogRecordHeader(LogChunkType type, Slice slice, int length)