Package org.apache.bookkeeper.bookie

Class LedgerDescriptorImpl

java.lang.Object

org.apache.bookkeeper.bookie.LedgerDescriptor

org.apache.bookkeeper.bookie.LedgerDescriptorImpl

Direct Known Subclasses:

LedgerDescriptorReadOnlyImpl

public class LedgerDescriptorImpl
extends LedgerDescriptor

Implements a ledger inside a bookie. In particular, it implements operations to write entries to a ledger and read entries from a ledger.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final LedgerStorage	ledgerStorage
(package private) final byte[]	masterKey

Constructor Summary

Constructors

Constructor	Description
LedgerDescriptorImpl(byte[] masterKey, long ledgerId, LedgerStorage ledgerStorage)

Method Summary

Modifier and Type	Method	Description
(package private) long	addEntry(io.netty.buffer.ByteBuf entry)
(package private) void	cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	checkAccess(byte[] masterKey)
(package private) CompletableFuture<Boolean>	fenceAndLogInJournal(Journal journal)	When we fence a ledger, we need to first set ledger to fenced state in memory and then log the fence entry in Journal so that we can rebuild the state.
(package private) io.netty.buffer.ByteBuf	getExplicitLac()
(package private) long	getLastAddConfirmed()
long	getLedgerId()
(package private) PrimitiveIterator.OfLong	getListOfEntriesOfLedger(long ledgerId)
(package private) boolean	isFenced()
(package private) io.netty.buffer.ByteBuf	readEntry(long entryId)
(package private) void	setExplicitLac(io.netty.buffer.ByteBuf lac)
(package private) boolean	setFenced()
(package private) boolean	waitForLastAddConfirmedUpdate(long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)

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

create, createLedgerFenceEntry, createReadOnly

Methods inherited from class java.lang.Object

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

Field Details

ledgerStorage

final LedgerStorage ledgerStorage

masterKey

final byte[] masterKey

Constructor Details

LedgerDescriptorImpl

LedgerDescriptorImpl(byte[] masterKey,
 long ledgerId,
 LedgerStorage ledgerStorage)

Method Details

checkAccess

void checkAccess(byte[] masterKey)
          throws BookieException,
IOException

Specified by:

checkAccess in class LedgerDescriptor

Throws:

BookieException

IOException

getLedgerId

public long getLedgerId()

Specified by:

getLedgerId in class LedgerDescriptor

setFenced

boolean setFenced()
           throws IOException

Specified by:

setFenced in class LedgerDescriptor

Throws:

IOException

isFenced

boolean isFenced()
          throws IOException,
BookieException

Specified by:

isFenced in class LedgerDescriptor

Throws:

IOException

BookieException

setExplicitLac

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

Specified by:

setExplicitLac in class LedgerDescriptor

Throws:

IOException

getExplicitLac

io.netty.buffer.ByteBuf getExplicitLac()
                                throws IOException,
BookieException

Specified by:

getExplicitLac in class LedgerDescriptor

Throws:

IOException

BookieException

fenceAndLogInJournal

CompletableFuture<Boolean> fenceAndLogInJournal(Journal journal)
                                         throws IOException

Description copied from class: LedgerDescriptor

When we fence a ledger, we need to first set ledger to fenced state in memory and then log the fence entry in Journal so that we can rebuild the state.

We should satisfy the future only after we complete logging fence entry in Journal

Specified by:

fenceAndLogInJournal in class LedgerDescriptor

Returns:

Throws:

IOException

addEntry

long addEntry(io.netty.buffer.ByteBuf entry)
       throws IOException,
BookieException

Specified by:

addEntry in class LedgerDescriptor

Throws:

IOException

BookieException

readEntry

io.netty.buffer.ByteBuf readEntry(long entryId)
                           throws IOException,
BookieException

Specified by:

readEntry in class LedgerDescriptor

Throws:

IOException

BookieException

getLastAddConfirmed

long getLastAddConfirmed()
                  throws IOException,
BookieException

Specified by:

getLastAddConfirmed in class LedgerDescriptor

Throws:

IOException

BookieException

waitForLastAddConfirmedUpdate

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

Specified by:

waitForLastAddConfirmedUpdate in class LedgerDescriptor

Throws:

IOException

cancelWaitForLastAddConfirmedUpdate

void cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
                                  throws IOException

Specified by:

cancelWaitForLastAddConfirmedUpdate in class LedgerDescriptor

Throws:

IOException

getListOfEntriesOfLedger

PrimitiveIterator.OfLong getListOfEntriesOfLedger(long ledgerId)
                                           throws IOException

Specified by:

getListOfEntriesOfLedger in class LedgerDescriptor

Throws:

IOException