Package org.apache.bookkeeper.bookie

Class EntryLogManagerBase

java.lang.Object

org.apache.bookkeeper.bookie.EntryLogManagerBase

All Implemented Interfaces:

EntryLogManager

Direct Known Subclasses:

EntryLogManagerForEntryLogPerLedger, EntryLogManagerForSingleEntryLog

abstract class EntryLogManagerBase
extends Object
implements EntryLogManager

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final EntryLoggerAllocator	entryLoggerAllocator
(package private) final LedgerDirsManager	ledgerDirsManager
(package private) final long	logSizeLimit	The maximum size of a entry logger file.
(package private) List<DefaultEntryLogger.BufferedLogChannel>	rotatedLogChannels

Constructor Summary

Constructors

Constructor	Description
EntryLogManagerBase(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, EntryLoggerAllocator entryLoggerAllocator, List<DefaultEntryLogger.EntryLogListener> listeners)

Method Summary

Modifier and Type	Method	Description
long	addEntry(long ledger, io.netty.buffer.ByteBuf entry, boolean rollLog)
(package private) void	createNewLog(long ledgerId)
(package private) void	createNewLog(long ledgerId, String reason)
void	flush()
(package private) abstract void	flushCurrentLogs()
(package private) void	flushLogChannel(DefaultEntryLogger.BufferedLogChannel logChannel, boolean forceMetadata)
(package private) abstract void	flushRotatedLogs()
(package private) abstract DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedger(long ledgerId)
(package private) abstract DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedgerForAddEntry(long ledgerId, int entrySize, boolean rollLog)
(package private) List<DefaultEntryLogger.BufferedLogChannel>	getRotatedLogChannels()
(package private) boolean	reachEntryLogLimit(DefaultEntryLogger.BufferedLogChannel logChannel, long size)
(package private) boolean	readEntryLogHardLimit(DefaultEntryLogger.BufferedLogChannel logChannel, long size)
(package private) File	selectDirForNextEntryLog()
(package private) abstract void	setCurrentLogForLedgerAndAddToRotate(long ledgerId, DefaultEntryLogger.BufferedLogChannel logChannel)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.bookie.EntryLogManager

checkpoint, close, commitEntryMemTableFlush, createNewLogForCompaction, forceClose, getCurrentLogIfPresent, getDirForNextEntryLog, prepareEntryMemTableFlush, prepareSortedLedgerStorageCheckpoint

Field Details

rotatedLogChannels

volatile List<DefaultEntryLogger.BufferedLogChannel> rotatedLogChannels

entryLoggerAllocator

final EntryLoggerAllocator entryLoggerAllocator

ledgerDirsManager

final LedgerDirsManager ledgerDirsManager

logSizeLimit

final long logSizeLimit

The maximum size of a entry logger file.

Constructor Details

EntryLogManagerBase

EntryLogManagerBase(ServerConfiguration conf,
 LedgerDirsManager ledgerDirsManager,
 EntryLoggerAllocator entryLoggerAllocator,
 List<DefaultEntryLogger.EntryLogListener> listeners)

Method Details

addEntry

public long addEntry(long ledger,
 io.netty.buffer.ByteBuf entry,
 boolean rollLog)
              throws IOException

Specified by:

addEntry in interface EntryLogManager

Throws:

IOException

reachEntryLogLimit

boolean reachEntryLogLimit(DefaultEntryLogger.BufferedLogChannel logChannel,
 long size)

readEntryLogHardLimit

boolean readEntryLogHardLimit(DefaultEntryLogger.BufferedLogChannel logChannel,
 long size)

getCurrentLogForLedger

abstract DefaultEntryLogger.BufferedLogChannel getCurrentLogForLedger(long ledgerId)
                                                               throws IOException

Throws:

IOException

getCurrentLogForLedgerForAddEntry

abstract DefaultEntryLogger.BufferedLogChannel getCurrentLogForLedgerForAddEntry(long ledgerId,
 int entrySize,
 boolean rollLog)
                                                                          throws IOException

Throws:

IOException

setCurrentLogForLedgerAndAddToRotate

abstract void setCurrentLogForLedgerAndAddToRotate(long ledgerId,
 DefaultEntryLogger.BufferedLogChannel logChannel)
                                            throws IOException

Throws:

IOException

flushCurrentLogs

abstract void flushCurrentLogs()
                        throws IOException

Throws:

IOException

flushRotatedLogs

abstract void flushRotatedLogs()
                        throws IOException

Throws:

IOException

getRotatedLogChannels

List<DefaultEntryLogger.BufferedLogChannel> getRotatedLogChannels()

flush

public void flush()
           throws IOException

Specified by:

flush in interface EntryLogManager

Throws:

IOException

flushLogChannel

void flushLogChannel(DefaultEntryLogger.BufferedLogChannel logChannel,
 boolean forceMetadata)
              throws IOException

Throws:

IOException

createNewLog

void createNewLog(long ledgerId)
           throws IOException

Throws:

IOException

createNewLog

void createNewLog(long ledgerId,
 String reason)
           throws IOException

Throws:

IOException

selectDirForNextEntryLog

File selectDirForNextEntryLog()
                       throws LedgerDirsManager.NoWritableLedgerDirException

Throws:

LedgerDirsManager.NoWritableLedgerDirException