org.apache.bookkeeper.client

Class ForceLedgerOp

java.lang.Object

org.apache.bookkeeper.client.ForceLedgerOp

All Implemented Interfaces:

java.lang.Runnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ForceLedgerCallback

class ForceLedgerOp
extends java.lang.Object
implements java.lang.Runnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ForceLedgerCallback

This represents a request to sync the ledger on every bookie.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) DistributionSchedule.AckSet	ackSet
(package private) org.apache.bookkeeper.proto.BookieClient	bookieClient
(package private) java.util.concurrent.CompletableFuture<java.lang.Void>	cb
(package private) boolean	completed
(package private) java.util.List<org.apache.bookkeeper.net.BookieId>	currentEnsemble
(package private) long	currentNonDurableLastAddConfirmed
(package private) boolean	errored
(package private) int	lastSeenError
(package private) LedgerHandle	lh

Constructor Summary

Constructors

Constructor and Description
ForceLedgerOp(LedgerHandle lh, org.apache.bookkeeper.proto.BookieClient bookieClient, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, java.util.concurrent.CompletableFuture<java.lang.Void> cb)

Method Summary

Modifier and Type	Method and Description
void	forceLedgerComplete(int rc, long ledgerId, org.apache.bookkeeper.net.BookieId addr, java.lang.Object ctx)
(package private) void	initiate()
void	run()
(package private) void	sendForceLedgerRequest(int bookieIndex)

Methods inherited from class java.lang.Object

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

Field Detail

cb

final java.util.concurrent.CompletableFuture<java.lang.Void> cb

ackSet

DistributionSchedule.AckSet ackSet

completed

boolean completed

errored

boolean errored

lastSeenError

int lastSeenError

currentEnsemble

final java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble

currentNonDurableLastAddConfirmed

long currentNonDurableLastAddConfirmed

lh

final LedgerHandle lh

bookieClient

final org.apache.bookkeeper.proto.BookieClient bookieClient

Constructor Detail

ForceLedgerOp

ForceLedgerOp(LedgerHandle lh,
              org.apache.bookkeeper.proto.BookieClient bookieClient,
              java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
              java.util.concurrent.CompletableFuture<java.lang.Void> cb)

Method Detail

sendForceLedgerRequest

void sendForceLedgerRequest(int bookieIndex)

run

public void run()

Specified by:

run in interface java.lang.Runnable

initiate

void initiate()

forceLedgerComplete

public void forceLedgerComplete(int rc,
                                long ledgerId,
                                org.apache.bookkeeper.net.BookieId addr,
                                java.lang.Object ctx)

Specified by:

forceLedgerComplete in interface org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ForceLedgerCallback