Package org.apache.bookkeeper.bookie

Class IndexPersistenceMgr

java.lang.Object

org.apache.bookkeeper.bookie.IndexPersistenceMgr

public class IndexPersistenceMgr
extends Object

A IndexPersistenceMgr is responsible for managing the persistence state for the index in a bookie.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final SnapshotMap<Long,Boolean>	activeLedgers
(package private) final int	entriesPerPage
(package private) final FileInfoBackingCache	fileInfoBackingCache
(package private) final LedgerDirsManager	ledgerDirsManager
(package private) final int	openFileLimit
(package private) final int	pageSize
(package private) final com.google.common.cache.Cache<Long,FileInfoBackingCache.CachedFileInfo>	readFileInfoCache
(package private) static final String	RLOC
(package private) final com.google.common.cache.Cache<Long,FileInfoBackingCache.CachedFileInfo>	writeFileInfoCache

Constructor Summary

Constructors

Constructor	Description
IndexPersistenceMgr(int pageSize, int entriesPerPage, ServerConfiguration conf, SnapshotMap<Long,Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
(package private) void	cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	close()
(package private) void	flushLedgerEntries(long l, List<LedgerEntryPage> entries)
(package private) void	flushLedgerHeader(long ledger)
io.netty.buffer.ByteBuf	getExplicitLac(long ledgerId)
(package private) FileInfoBackingCache.CachedFileInfo	getFileInfo(Long ledger, byte[] masterKey)	Get the FileInfo and increase reference count.
(package private) Long	getLastAddConfirmed(long ledgerId)
static final String	getLedgerName(long ledgerId)
(package private) int	getOpenFileLimit()
(package private) long	getPersistEntryBeyondInMem(long ledgerId, long lastEntryInMem)
(package private) boolean	isFenced(long ledgerId)
(package private) boolean	ledgerExists(long ledgerId)
LedgerCache.LedgerIndexMetadata	readLedgerIndexMetadata(long ledgerId)	Read ledger meta.
(package private) byte[]	readMasterKey(long ledgerId)
(package private) void	removeLedger(Long ledgerId)	This method is called whenever a ledger is deleted by the BookKeeper Client and we want to remove all relevant data for it stored in the LedgerCache.
(package private) void	setExplicitLac(long ledgerId, io.netty.buffer.ByteBuf lac)
(package private) boolean	setFenced(long ledgerId)
(package private) void	setMasterKey(long ledgerId, byte[] masterKey)
(package private) long	updateLastAddConfirmed(long ledgerId, long lac)
(package private) boolean	updatePage(LedgerEntryPage lep)	Update the ledger entry page.
(package private) boolean	waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)

Methods inherited from class java.lang.Object

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

Field Details

RLOC

static final String RLOC

See Also:

• Constant Field Values

writeFileInfoCache

final com.google.common.cache.Cache<Long,FileInfoBackingCache.CachedFileInfo> writeFileInfoCache

readFileInfoCache

final com.google.common.cache.Cache<Long,FileInfoBackingCache.CachedFileInfo> readFileInfoCache

fileInfoBackingCache

final FileInfoBackingCache fileInfoBackingCache

openFileLimit

final int openFileLimit

pageSize

final int pageSize

entriesPerPage

final int entriesPerPage

activeLedgers

final SnapshotMap<Long,Boolean> activeLedgers

ledgerDirsManager

final LedgerDirsManager ledgerDirsManager

Constructor Details

IndexPersistenceMgr

public IndexPersistenceMgr(int pageSize,
 int entriesPerPage,
 ServerConfiguration conf,
 SnapshotMap<Long,Boolean> activeLedgers,
 LedgerDirsManager ledgerDirsManager,
 StatsLogger statsLogger)
                    throws IOException

Throws:

IOException

Method Details

getLedgerName

public static final String getLedgerName(long ledgerId)

getFileInfo

FileInfoBackingCache.CachedFileInfo getFileInfo(Long ledger,
 byte[] masterKey)
                                         throws IOException

Get the FileInfo and increase reference count. When we get FileInfo from cache, we need to make sure it is synchronized with eviction, otherwise there might be a race condition as we get the FileInfo from cache, that FileInfo is then evicted and closed before we could even increase the reference counter.

Throws:

IOException

removeLedger

void removeLedger(Long ledgerId)
           throws IOException

This method is called whenever a ledger is deleted by the BookKeeper Client and we want to remove all relevant data for it stored in the LedgerCache.

Throws:

IOException

ledgerExists

boolean ledgerExists(long ledgerId)
              throws IOException

Throws:

IOException

close

void close()
    throws IOException

Throws:

IOException

getLastAddConfirmed

Long getLastAddConfirmed(long ledgerId)
                  throws IOException

Throws:

IOException

waitForLastAddConfirmedUpdate

boolean waitForLastAddConfirmedUpdate(long ledgerId,
 long previousLAC,
 Watcher<LastAddConfirmedUpdateNotification> watcher)
                               throws IOException

Throws:

IOException

cancelWaitForLastAddConfirmedUpdate

void cancelWaitForLastAddConfirmedUpdate(long ledgerId,
 Watcher<LastAddConfirmedUpdateNotification> watcher)
                                  throws IOException

Throws:

IOException

updateLastAddConfirmed

long updateLastAddConfirmed(long ledgerId,
 long lac)
                     throws IOException

Throws:

IOException

readMasterKey

byte[] readMasterKey(long ledgerId)
              throws IOException,
BookieException

Throws:

IOException

BookieException

setMasterKey

void setMasterKey(long ledgerId,
 byte[] masterKey)
           throws IOException

Throws:

IOException

setFenced

boolean setFenced(long ledgerId)
           throws IOException

Throws:

IOException

isFenced

boolean isFenced(long ledgerId)
          throws IOException

Throws:

IOException

setExplicitLac

void setExplicitLac(long ledgerId,
 io.netty.buffer.ByteBuf lac)
             throws IOException

Throws:

IOException

getExplicitLac

public io.netty.buffer.ByteBuf getExplicitLac(long ledgerId)

getOpenFileLimit

int getOpenFileLimit()

flushLedgerHeader

void flushLedgerHeader(long ledger)
                throws IOException

Throws:

IOException

flushLedgerEntries

void flushLedgerEntries(long l,
 List<LedgerEntryPage> entries)
                 throws IOException

Throws:

IOException

updatePage

boolean updatePage(LedgerEntryPage lep)
            throws IOException

Update the ledger entry page.

Parameters:

lep - ledger entry page

Returns:

true if it is a new page, otherwise false.

Throws:

IOException

getPersistEntryBeyondInMem

long getPersistEntryBeyondInMem(long ledgerId,
 long lastEntryInMem)
                         throws IOException

Throws:

IOException

readLedgerIndexMetadata

public LedgerCache.LedgerIndexMetadata readLedgerIndexMetadata(long ledgerId)
                                                        throws IOException

Read ledger meta.

Parameters:

ledgerId - Ledger Id

Throws:

IOException