Package org.apache.bookkeeper.bookie

Class EntryLogManagerForEntryLogPerLedger

java.lang.Object

org.apache.bookkeeper.bookie.EntryLogManagerBase

org.apache.bookkeeper.bookie.EntryLogManagerForEntryLogPerLedger

All Implemented Interfaces:

EntryLogManager

class EntryLogManagerForEntryLogPerLedger
extends EntryLogManagerBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	EntryLogManagerForEntryLogPerLedger.BufferedLogChannelWithDirInfo
(package private) class	EntryLogManagerForEntryLogPerLedger.EntryLogAndLockTuple
(package private) class	EntryLogManagerForEntryLogPerLedger.EntryLogsPerLedgerCounter

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final EntryLogManagerForEntryLogPerLedger.EntryLogsPerLedgerCounter	entryLogsPerLedgerCounter

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

entryLoggerAllocator, ledgerDirsManager, logSizeLimit, rotatedLogChannels

Constructor Summary

Constructors

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

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()	flushCurrentLogs method is called during checkpoint, so metadata of the file also should be force written.
(package private) void	doEntryLogMapCleanup()
(package private) void	flushCurrentLogs()
void	flushRotatedLogs()	if disk of the logChannel is full or if the entrylog limit is reached of if the logchannel is not initialized, then createNewLog.
void	forceClose()
(package private) ConcurrentMap<Long,EntryLogManagerForEntryLogPerLedger.EntryLogAndLockTuple>	getCacheAsMap()
Set<EntryLogManagerForEntryLogPerLedger.BufferedLogChannelWithDirInfo>	getCopyOfCurrentLogs()
DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedger(long ledgerId)
(package private) DefaultEntryLogger.BufferedLogChannel	getCurrentLogForLedgerForAddEntry(long ledgerId, int entrySize, boolean rollLog)
DefaultEntryLogger.BufferedLogChannel	getCurrentLogIfPresent(long entryLogId)
EntryLogManagerForEntryLogPerLedger.BufferedLogChannelWithDirInfo	getCurrentLogWithDirInfoForLedger(long ledgerId)
File	getDirForNextEntryLog(List<File> writableLedgerDirs)
(package private) Lock	getLock(long ledgerId)
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

Field Details

entryLogsPerLedgerCounter

final EntryLogManagerForEntryLogPerLedger.EntryLogsPerLedgerCounter entryLogsPerLedgerCounter

Constructor Details

EntryLogManagerForEntryLogPerLedger

EntryLogManagerForEntryLogPerLedger(ServerConfiguration conf,
 LedgerDirsManager ledgerDirsManager,
 EntryLoggerAllocator entryLoggerAllocator,
 List<DefaultEntryLogger.EntryLogListener> listeners,
 DefaultEntryLogger.RecentEntryLogsStatus recentlyCreatedEntryLogsStatus,
 StatsLogger statsLogger)
                             throws IOException

Throws:

IOException

Method Details

getLock

Lock getLock(long ledgerId)
      throws IOException

Throws:

IOException

setCurrentLogForLedgerAndAddToRotate

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

Specified by:

setCurrentLogForLedgerAndAddToRotate in class EntryLogManagerBase

Throws:

IOException

getCurrentLogForLedger

public DefaultEntryLogger.BufferedLogChannel getCurrentLogForLedger(long ledgerId)
                                                             throws IOException

Specified by:

getCurrentLogForLedger in class EntryLogManagerBase

Throws:

IOException

getCurrentLogWithDirInfoForLedger

public EntryLogManagerForEntryLogPerLedger.BufferedLogChannelWithDirInfo getCurrentLogWithDirInfoForLedger(long ledgerId)
                                                                                                    throws IOException

Throws:

IOException

getCopyOfCurrentLogs

public Set<EntryLogManagerForEntryLogPerLedger.BufferedLogChannelWithDirInfo> getCopyOfCurrentLogs()

getCurrentLogIfPresent

public DefaultEntryLogger.BufferedLogChannel getCurrentLogIfPresent(long entryLogId)

checkpoint

public void checkpoint()
                throws IOException

Throws:

IOException

prepareSortedLedgerStorageCheckpoint

public void prepareSortedLedgerStorageCheckpoint(long numBytesFlushed)
                                          throws IOException

Throws:

IOException

prepareEntryMemTableFlush

public void prepareEntryMemTableFlush()

commitEntryMemTableFlush

public boolean commitEntryMemTableFlush()
                                 throws IOException

Throws:

IOException

doEntryLogMapCleanup

void doEntryLogMapCleanup()

getCacheAsMap

ConcurrentMap<Long,EntryLogManagerForEntryLogPerLedger.EntryLogAndLockTuple> getCacheAsMap()

getDirForNextEntryLog

public File getDirForNextEntryLog(List<File> writableLedgerDirs)

close

public void close()
           throws IOException

Throws:

IOException

forceClose

public void forceClose()

flushCurrentLogs

void flushCurrentLogs()
               throws IOException

Specified by:

flushCurrentLogs in class EntryLogManagerBase

Throws:

IOException

createNewLogForCompaction

public DefaultEntryLogger.BufferedLogChannel createNewLogForCompaction()
                                                                throws IOException

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

Throws:

IOException

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

createNewLog

void createNewLog(long ledgerId)
           throws IOException

Overrides:

createNewLog 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

flushRotatedLogs

public void flushRotatedLogs()
                      throws IOException

if disk of the logChannel is full or if the entrylog limit is reached of if the logchannel is not initialized, then createNewLog. If allDisks are full then proceed with the current logChannel, since Bookie must have turned to readonly mode and the addEntry traffic would be from GC and it is ok to proceed in this case.

Specified by:

flushRotatedLogs in class EntryLogManagerBase

Throws:

IOException