Package org.apache.bookkeeper.bookie

Class LedgerCacheImpl

java.lang.Object

org.apache.bookkeeper.bookie.LedgerCacheImpl

All Implemented Interfaces:

Closeable, AutoCloseable, LedgerCache

public class LedgerCacheImpl
extends Object
implements LedgerCache

Implementation of LedgerCache interface. This class serves two purposes.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.bookie.LedgerCache

LedgerCache.LedgerIndexMetadata, LedgerCache.NoIndexForLedgerException, LedgerCache.PageEntries, LedgerCache.PageEntriesIterable

Constructor Summary

Constructors

Constructor	Description
LedgerCacheImpl(ServerConfiguration conf, SnapshotMap<Long,Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager)
LedgerCacheImpl(ServerConfiguration conf, SnapshotMap<Long,Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
void	cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	close()
void	deleteLedger(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.
void	flushLedger(boolean doAll)
PrimitiveIterator.OfLong	getEntriesIterator(long ledgerId)
long	getEntryOffset(long ledger, long entry)
io.netty.buffer.ByteBuf	getExplicitLac(long ledgerId)
(package private) IndexInMemPageMgr	getIndexPageManager()
(package private) IndexPersistenceMgr	getIndexPersistenceManager()
Long	getLastAddConfirmed(long ledgerId)
long	getLastEntry(long ledgerId)
int	getPageSize()
boolean	isFenced(long ledgerId)
boolean	ledgerExists(long ledgerId)
LedgerCache.PageEntriesIterable	listEntries(long ledgerId)
void	putEntryOffset(long ledger, long entry, long offset)
LedgerCache.LedgerIndexMetadata	readLedgerIndexMetadata(long ledgerId)
byte[]	readMasterKey(long ledgerId)
void	setExplicitLac(long ledgerId, io.netty.buffer.ByteBuf lac)
boolean	setFenced(long ledgerId)
void	setMasterKey(long ledgerId, byte[] masterKey)
long	updateLastAddConfirmed(long ledgerId, long lac)
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

Constructor Details

LedgerCacheImpl

public LedgerCacheImpl(ServerConfiguration conf,
 SnapshotMap<Long,Boolean> activeLedgers,
 LedgerDirsManager ledgerDirsManager)
                throws IOException

Throws:

IOException

LedgerCacheImpl

public LedgerCacheImpl(ServerConfiguration conf,
 SnapshotMap<Long,Boolean> activeLedgers,
 LedgerDirsManager ledgerDirsManager,
 StatsLogger statsLogger)
                throws IOException

Throws:

IOException

Method Details

getIndexPersistenceManager

IndexPersistenceMgr getIndexPersistenceManager()

getIndexPageManager

IndexInMemPageMgr getIndexPageManager()

getPageSize

public int getPageSize()

Returns:

page size used in ledger cache

getLastAddConfirmed

public Long getLastAddConfirmed(long ledgerId)
                         throws IOException

Specified by:

getLastAddConfirmed in interface LedgerCache

Throws:

IOException

updateLastAddConfirmed

public long updateLastAddConfirmed(long ledgerId,
 long lac)
                            throws IOException

Specified by:

updateLastAddConfirmed in interface LedgerCache

Throws:

IOException

waitForLastAddConfirmedUpdate

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

Specified by:

waitForLastAddConfirmedUpdate in interface LedgerCache

Throws:

IOException

cancelWaitForLastAddConfirmedUpdate

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

Specified by:

cancelWaitForLastAddConfirmedUpdate in interface LedgerCache

Throws:

IOException

putEntryOffset

public void putEntryOffset(long ledger,
 long entry,
 long offset)
                    throws IOException

Specified by:

putEntryOffset in interface LedgerCache

Throws:

IOException

getEntryOffset

public long getEntryOffset(long ledger,
 long entry)
                    throws IOException

Specified by:

getEntryOffset in interface LedgerCache

Throws:

IOException

flushLedger

public void flushLedger(boolean doAll)
                 throws IOException

Specified by:

flushLedger in interface LedgerCache

Throws:

IOException

getLastEntry

public long getLastEntry(long ledgerId)
                  throws IOException

Specified by:

getLastEntry in interface LedgerCache

Throws:

IOException

deleteLedger

public void deleteLedger(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.

Specified by:

deleteLedger in interface LedgerCache

Throws:

IOException

readMasterKey

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

Specified by:

readMasterKey in interface LedgerCache

Throws:

IOException

BookieException

setFenced

public boolean setFenced(long ledgerId)
                  throws IOException

Specified by:

setFenced in interface LedgerCache

Throws:

IOException

isFenced

public boolean isFenced(long ledgerId)
                 throws IOException

Specified by:

isFenced in interface LedgerCache

Throws:

IOException

setExplicitLac

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

Specified by:

setExplicitLac in interface LedgerCache

Throws:

IOException

getExplicitLac

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

Specified by:

getExplicitLac in interface LedgerCache

setMasterKey

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

Specified by:

setMasterKey in interface LedgerCache

Throws:

IOException

ledgerExists

public boolean ledgerExists(long ledgerId)
                     throws IOException

Specified by:

ledgerExists in interface LedgerCache

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

listEntries

public LedgerCache.PageEntriesIterable listEntries(long ledgerId)
                                            throws IOException

Specified by:

listEntries in interface LedgerCache

Throws:

IOException

readLedgerIndexMetadata

public LedgerCache.LedgerIndexMetadata readLedgerIndexMetadata(long ledgerId)
                                                        throws IOException

Specified by:

readLedgerIndexMetadata in interface LedgerCache

Throws:

IOException

getEntriesIterator

public PrimitiveIterator.OfLong getEntriesIterator(long ledgerId)
                                            throws IOException

Specified by:

getEntriesIterator in interface LedgerCache

Throws:

IOException