Package org.apache.bookkeeper.client

Class PendingReadOp.ParallelReadRequest

java.lang.Object

org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

org.apache.bookkeeper.client.PendingReadOp.SingleLedgerEntryRequest

org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

All Implemented Interfaces:

SpeculativeRequestExecutor

Enclosing class:

PendingReadOp

class PendingReadOp.ParallelReadRequest
extends PendingReadOp.SingleLedgerEntryRequest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	numPendings

Fields inherited from class org.apache.bookkeeper.client.PendingReadOp.SingleLedgerEntryRequest

entryImpl

Fields inherited from class org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

complete, eId, ensemble, firstError, numBookiesMissingEntry, rc, writeSet

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) void	logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) BookieId	maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)	Send to next replica speculatively, if required and possible.
(package private) void	read()	Execute the read request.

Methods inherited from class org.apache.bookkeeper.client.PendingReadOp.SingleLedgerEntryRequest

close, complete

Methods inherited from class org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

fail, getRc, isComplete, issueSpeculativeRequest, toString

Methods inherited from class java.lang.Object

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

Field Details

numPendings

int numPendings

Constructor Details

ParallelReadRequest

ParallelReadRequest(List<BookieId> ensemble,
 long lId,
 long eId)

Method Details

read

void read()

Description copied from class: ReadOpBase.LedgerEntryRequest

Execute the read request.

Specified by:

read in class ReadOpBase.LedgerEntryRequest

logErrorAndReattemptRead

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

Description copied from class: ReadOpBase.LedgerEntryRequest

Log error errMsg and reattempt read from host.

Overrides:

logErrorAndReattemptRead in class ReadOpBase.LedgerEntryRequest

Parameters:

bookieIndex - bookie index

host - host that just respond

errMsg - error msg to log

rc - read result code

maybeSendSpeculativeRead

BookieId maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)

Description copied from class: ReadOpBase.LedgerEntryRequest

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

Specified by:

maybeSendSpeculativeRead in class ReadOpBase.LedgerEntryRequest

Parameters:

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

Returns:

host we sent to if we sent. null otherwise.