Package org.apache.bookkeeper.client

Class ReadOpBase.LedgerEntryRequest

java.lang.Object

org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

All Implemented Interfaces:

SpeculativeRequestExecutor

Direct Known Subclasses:

BatchedReadOp.BatchedLedgerEntryRequest, PendingReadOp.SingleLedgerEntryRequest

Enclosing class:

ReadOpBase

abstract class ReadOpBase.LedgerEntryRequest
extends Object
implements SpeculativeRequestExecutor

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicBoolean	complete
(package private) final long	eId
(package private) final List<BookieId>	ensemble
(package private) int	firstError
(package private) int	numBookiesMissingEntry
(package private) int	rc
(package private) final DistributionSchedule.WriteSet	writeSet

Constructor Summary

Constructors

Constructor	Description
LedgerEntryRequest(List<BookieId> ensemble, long eId)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) boolean	fail(int rc)	Fail the request with given result code rc.
(package private) int	getRc()	Get result code of this entry.
(package private) boolean	isComplete()	Whether the read request completed.
com.google.common.util.concurrent.ListenableFuture<Boolean>	issueSpeculativeRequest()	Issues a speculative request and indicates if more speculative requests should be issued.
(package private) void	logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) abstract BookieId	maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)	Send to next replica speculatively, if required and possible.
(package private) abstract void	read()	Execute the read request.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

complete

final AtomicBoolean complete

rc

int rc

firstError

int firstError

numBookiesMissingEntry

int numBookiesMissingEntry

eId

final long eId

ensemble

final List<BookieId> ensemble

writeSet

final DistributionSchedule.WriteSet writeSet

Constructor Details

LedgerEntryRequest

LedgerEntryRequest(List<BookieId> ensemble,
 long eId)

Method Details

close

public void close()

read

abstract void read()

Execute the read request.

fail

boolean fail(int rc)

Fail the request with given result code rc.

Parameters:

rc - result code to fail the request.

Returns:

true if we managed to fail the entry; otherwise return false if it already failed or completed.

logErrorAndReattemptRead

void logErrorAndReattemptRead(int bookieIndex,
 BookieId host,
 String errMsg,
 int rc)

Log error errMsg and reattempt read from host.

Parameters:

bookieIndex - bookie index

host - host that just respond

errMsg - error msg to log

rc - read result code

maybeSendSpeculativeRead

abstract BookieId maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)

Send to next replica speculatively, if required and possible. This returns the host we may have sent to for unit testing.

Parameters:

heardFromHostsBitSet - the set of hosts that we already received responses.

Returns:

host we sent to if we sent. null otherwise.

isComplete

boolean isComplete()

Whether the read request completed.

Returns:

true if the read request is completed.

getRc

int getRc()

Get result code of this entry.

Returns:

result code.

toString

public String toString()

Overrides:

toString in class Object

issueSpeculativeRequest

public com.google.common.util.concurrent.ListenableFuture<Boolean> issueSpeculativeRequest()

Issues a speculative request and indicates if more speculative requests should be issued.

Specified by:

issueSpeculativeRequest in interface SpeculativeRequestExecutor

Returns:

whether more speculative requests should be issued