Package org.apache.bookkeeper.client

Class LedgerRecoveryOp

java.lang.Object

org.apache.bookkeeper.client.LedgerRecoveryOp

All Implemented Interfaces:

AsyncCallback.AddCallback, AsyncCallback.AddCallbackWithLatency, BookkeeperInternalCallbacks.ReadEntryListener

class LedgerRecoveryOp
extends Object
implements BookkeeperInternalCallbacks.ReadEntryListener, AsyncCallback.AddCallback

This class encapsulated the ledger recovery operation. It first does a read with entry-id of -1 (BookieProtocol.LAST_ADD_CONFIRMED) to all bookies. Then starting from the last confirmed entry (from hints in the ledger entries), it reads forward until it is not able to find a particular entry.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	LedgerRecoveryOp.RecoveryReadOp

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final ClientContext	clientCtx
(package private) long	endEntryToRead
(package private) BookkeeperInternalCallbacks.ReadEntryListener	entryListener
(package private) final LedgerHandle	lh
(package private) static final org.slf4j.Logger	LOG
(package private) LedgerMetadata	metadataForRecovery
(package private) final CompletableFuture<LedgerHandle>	promise
(package private) final AtomicLong	readCount
(package private) boolean	readDone
(package private) long	startEntryToRead
(package private) final AtomicLong	writeCount

Constructor Summary

Constructors

Constructor	Description
LedgerRecoveryOp(LedgerHandle lh, ClientContext clientCtx)

Method Summary

Modifier and Type	Method	Description
void	addComplete(int rc, LedgerHandle lh, long entryId, Object ctx)	Callback to implement if latency information is not desired.
CompletableFuture<LedgerHandle>	initiate()
void	onEntryComplete(int rc, LedgerHandle lh, LedgerEntry entry, Object ctx)	On given entry completed.
(package private) LedgerRecoveryOp	setEntryListener(BookkeeperInternalCallbacks.ReadEntryListener entryListener)	Set an entry listener to listen on individual recovery reads during recovery procedure.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.client.AsyncCallback.AddCallback

addCompleteWithLatency

Field Details

LOG

static final org.slf4j.Logger LOG

lh

final LedgerHandle lh

clientCtx

final ClientContext clientCtx

promise

final CompletableFuture<LedgerHandle> promise

readCount

final AtomicLong readCount

writeCount

final AtomicLong writeCount

readDone

volatile boolean readDone

startEntryToRead

volatile long startEntryToRead

endEntryToRead

volatile long endEntryToRead

metadataForRecovery

LedgerMetadata metadataForRecovery

entryListener

BookkeeperInternalCallbacks.ReadEntryListener entryListener

Constructor Details

LedgerRecoveryOp

public LedgerRecoveryOp(LedgerHandle lh,
 ClientContext clientCtx)

Method Details

setEntryListener

LedgerRecoveryOp setEntryListener(BookkeeperInternalCallbacks.ReadEntryListener entryListener)

Set an entry listener to listen on individual recovery reads during recovery procedure.

Parameters:

entryListener - entry listener

Returns:

ledger recovery operation

initiate

public CompletableFuture<LedgerHandle> initiate()

onEntryComplete

public void onEntryComplete(int rc,
 LedgerHandle lh,
 LedgerEntry entry,
 Object ctx)

Description copied from interface: BookkeeperInternalCallbacks.ReadEntryListener

On given entry completed.

Specified by:

onEntryComplete in interface BookkeeperInternalCallbacks.ReadEntryListener

Parameters:

rc - result code of reading this entry.

lh - ledger handle.

entry - ledger entry.

ctx - callback context.

addComplete

public void addComplete(int rc,
 LedgerHandle lh,
 long entryId,
 Object ctx)

Description copied from interface: AsyncCallback.AddCallback

Callback to implement if latency information is not desired.

Specified by:

addComplete in interface AsyncCallback.AddCallback

Parameters:

rc - return code

lh - ledger handle

entryId - entry identifier

ctx - context object