Package org.apache.bookkeeper.bookie

Class DefaultEntryLogger.BufferedLogChannel

java.lang.Object

org.apache.bookkeeper.bookie.BufferedChannelBase

org.apache.bookkeeper.bookie.BufferedReadChannel

org.apache.bookkeeper.bookie.BufferedChannel

org.apache.bookkeeper.bookie.DefaultEntryLogger.BufferedLogChannel

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

DefaultEntryLogger

static class DefaultEntryLogger.BufferedLogChannel
extends BufferedChannel

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.bookkeeper.bookie.BufferedChannelBase

BufferedChannelBase.BufferedChannelClosedException

Field Summary

Fields inherited from class org.apache.bookkeeper.bookie.BufferedChannel

position, unpersistedBytes, unpersistedBytesBound, writeBuffer, writeBufferStartPosition, writeCapacity

Fields inherited from class org.apache.bookkeeper.bookie.BufferedReadChannel

cacheHitCount, invocationCount, readBuffer, readBufferStartPosition, readCapacity, sealed

Fields inherited from class org.apache.bookkeeper.bookie.BufferedChannelBase

fileChannel

Constructor Summary

Constructors

Constructor	Description
BufferedLogChannel(io.netty.buffer.ByteBufAllocator allocator, FileChannel fc, int writeCapacity, int readCapacity, long logId, File logFile, long unpersistedBytesBound)

Method Summary

Modifier and Type	Method	Description
(package private) void	appendLedgersMap()	Append the ledger map at the end of the entry log.
Long	getLedgerIdAssigned()
ConcurrentLongLongHashMap	getLedgersMap()
File	getLogFile()
long	getLogId()
void	registerWrittenEntry(long ledgerId, long entrySize)
void	setLedgerIdAssigned(Long ledgerId)
String	toString()

Methods inherited from class org.apache.bookkeeper.bookie.BufferedChannel

clear, close, flush, flushAndForceWrite, flushAndForceWriteIfRegularFlush, forceWrite, getFileChannelPosition, getNumOfBytesInWriteBuffer, getUnpersistedBytes, position, read, write

Methods inherited from class org.apache.bookkeeper.bookie.BufferedReadChannel

read, size

Methods inherited from class org.apache.bookkeeper.bookie.BufferedChannelBase

validateAndGetFileChannel

Methods inherited from class java.lang.Object

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

Constructor Details

BufferedLogChannel

public BufferedLogChannel(io.netty.buffer.ByteBufAllocator allocator,
 FileChannel fc,
 int writeCapacity,
 int readCapacity,
 long logId,
 File logFile,
 long unpersistedBytesBound)
                   throws IOException

Throws:

IOException

Method Details

getLogId

public long getLogId()

getLogFile

public File getLogFile()

registerWrittenEntry

public void registerWrittenEntry(long ledgerId,
 long entrySize)

getLedgersMap

public ConcurrentLongLongHashMap getLedgersMap()

getLedgerIdAssigned

public Long getLedgerIdAssigned()

setLedgerIdAssigned

public void setLedgerIdAssigned(Long ledgerId)

toString

public String toString()

Overrides:

toString in class Object

appendLedgersMap

void appendLedgersMap()
               throws IOException

Append the ledger map at the end of the entry log. Updates the entry log file header with the offset and size of the map.

Throws:

IOException