Package org.apache.bookkeeper.bookie

Class EntryLogManagerForSingleEntryLog

java.lang.Object

org.apache.bookkeeper.bookie.EntryLogManagerBase

org.apache.bookkeeper.bookie.EntryLogManagerForSingleEntryLog

All Implemented Interfaces:

EntryLogManager

class EntryLogManagerForSingleEntryLog
extends EntryLogManagerBase

Field Summary

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

entryLoggerAllocator, ledgerDirsManager, logSizeLimit, rotatedLogChannels

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
long	addEntry(long ledger, io.netty.buffer.ByteBuf entry, boolean rollLog)
void	checkpoint()
void	close()
boolean	commitEntryMemTableFlush()
(package private) void	createNewLog(long ledgerId)
DefaultEntryLogger.BufferedLogChannel	createNewLogForCompaction()
void	flushCurrentLogs()
(package private) void	flushRotatedLogs()	flushCurrentLogs method is called during checkpoint, so metadata of the file also should be force written.
void	forceClose()
DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedger(long ledgerId)
(package private) DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedgerForAddEntry(long ledgerId, int entrySize, boolean rollLog)
long	getCurrentLogId()
DefaultEntryLogger.BufferedLogChannel	getCurrentLogIfPresent(long entryLogId)
File	getDirForNextEntryLog(List<File> writableLedgerDirs)
void	prepareEntryMemTableFlush()
void	prepareSortedLedgerStorageCheckpoint(long numBytesFlushed)
void	setCurrentLogForLedgerAndAddToRotate(long ledgerId, DefaultEntryLogger.BufferedLogChannel logChannel)

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

createNewLog, flush, flushLogChannel, getRotatedLogChannels, reachEntryLogLimit, readEntryLogHardLimit, selectDirForNextEntryLog

Methods inherited from class java.lang.Object

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

Constructor Details

EntryLogManagerForSingleEntryLog

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

Method Details

addEntry

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

Specified by:

addEntry in interface EntryLogManager

Overrides:

addEntry in class EntryLogManagerBase

Throws:

IOException

getCurrentLogForLedgerForAddEntry

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

Specified by:

getCurrentLogForLedgerForAddEntry in class EntryLogManagerBase

Throws:

IOException

createNewLog

void createNewLog(long ledgerId)
           throws IOException

Overrides:

createNewLog in class EntryLogManagerBase

Throws:

IOException

setCurrentLogForLedgerAndAddToRotate

public void setCurrentLogForLedgerAndAddToRotate(long ledgerId,
 DefaultEntryLogger.BufferedLogChannel logChannel)

Specified by:

setCurrentLogForLedgerAndAddToRotate in class EntryLogManagerBase

getCurrentLogForLedger

public DefaultEntryLogger.BufferedLogChannel getCurrentLogForLedger(long ledgerId)

Specified by:

getCurrentLogForLedger in class EntryLogManagerBase

getCurrentLogIfPresent

public DefaultEntryLogger.BufferedLogChannel getCurrentLogIfPresent(long entryLogId)

getDirForNextEntryLog

public File getDirForNextEntryLog(List<File> writableLedgerDirs)

checkpoint

public void checkpoint()
                throws IOException

Throws:

IOException

getCurrentLogId

public long getCurrentLogId()

flushCurrentLogs

public void flushCurrentLogs()
                      throws IOException

Specified by:

flushCurrentLogs in class EntryLogManagerBase

Throws:

IOException

flushRotatedLogs

void flushRotatedLogs()
               throws IOException

flushCurrentLogs method is called during checkpoint, so metadata of the file also should be force written.

Specified by:

flushRotatedLogs in class EntryLogManagerBase

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

forceClose

public void forceClose()

prepareEntryMemTableFlush

public void prepareEntryMemTableFlush()

commitEntryMemTableFlush

public boolean commitEntryMemTableFlush()
                                 throws IOException

Throws:

IOException

prepareSortedLedgerStorageCheckpoint

public void prepareSortedLedgerStorageCheckpoint(long numBytesFlushed)
                                          throws IOException

Throws:

IOException

createNewLogForCompaction

public DefaultEntryLogger.BufferedLogChannel createNewLogForCompaction()
                                                                throws IOException

Throws:

IOException