Package org.apache.bookkeeper.bookie

Class EntryLoggerAllocator

java.lang.Object

org.apache.bookkeeper.bookie.EntryLoggerAllocator

class EntryLoggerAllocator
extends Object

An allocator pre-allocates entry log files.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ExecutorService	allocatorExecutor
(package private) final io.netty.buffer.ByteBuf	logfileHeader
(package private) Future<DefaultEntryLogger.BufferedLogChannel>	preallocation

Constructor Summary

Constructors

Constructor	Description
EntryLoggerAllocator(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, DefaultEntryLogger.RecentEntryLogsStatus recentlyCreatedEntryLogsStatus, long logId, io.netty.buffer.ByteBufAllocator byteBufAllocator)

Method Summary

Modifier and Type	Method	Description
(package private) void	clearCompactingLogId()
(package private) DefaultEntryLogger.BufferedLogChannel	createNewLog(File dirForNextEntryLog)
(package private) DefaultEntryLogger.BufferedLogChannel	createNewLogForCompaction(File dirForNextEntryLog)
(package private) long	getPreallocatedLogId()
(package private) Future<DefaultEntryLogger.BufferedLogChannel>	getPreallocationFuture()	get the preallocation for tests.
boolean	isSealed(long logId)
(package private) void	setLastLogId(File dir, long logId)	writes the given id to the "lastId" file in the given directory.
(package private) void	setWritingCompactingLogId(long logId)
(package private) void	setWritingLogId(long logId)
(package private) void	stop()	Stop the allocator.

Methods inherited from class java.lang.Object

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

Field Details

preallocation

Future<DefaultEntryLogger.BufferedLogChannel> preallocation

allocatorExecutor

ExecutorService allocatorExecutor

logfileHeader

final io.netty.buffer.ByteBuf logfileHeader

Constructor Details

EntryLoggerAllocator

EntryLoggerAllocator(ServerConfiguration conf,
 LedgerDirsManager ledgerDirsManager,
 DefaultEntryLogger.RecentEntryLogsStatus recentlyCreatedEntryLogsStatus,
 long logId,
 io.netty.buffer.ByteBufAllocator byteBufAllocator)

Method Details

getPreallocatedLogId

long getPreallocatedLogId()

isSealed

public boolean isSealed(long logId)

createNewLog

DefaultEntryLogger.BufferedLogChannel createNewLog(File dirForNextEntryLog)
                                            throws IOException

Throws:

IOException

createNewLogForCompaction

DefaultEntryLogger.BufferedLogChannel createNewLogForCompaction(File dirForNextEntryLog)
                                                         throws IOException

Throws:

IOException

setWritingLogId

void setWritingLogId(long logId)

setWritingCompactingLogId

void setWritingCompactingLogId(long logId)

clearCompactingLogId

void clearCompactingLogId()

setLastLogId

void setLastLogId(File dir,
 long logId)
           throws IOException

writes the given id to the "lastId" file in the given directory.

Throws:

IOException

stop

void stop()

Stop the allocator.

getPreallocationFuture

Future<DefaultEntryLogger.BufferedLogChannel> getPreallocationFuture()

get the preallocation for tests.