org.apache.bookkeeper.client

Class PendingReadOp.ParallelReadRequest

java.lang.Object

org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

All Implemented Interfaces:

java.lang.AutoCloseable, SpeculativeRequestExecutor

Enclosing class:

PendingReadOp

class PendingReadOp.ParallelReadRequest
extends PendingReadOp.LedgerEntryRequest

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	numPendings

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

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

Constructor Summary

Constructors

Constructor and Description
ParallelReadRequest(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, long lId, long eId)

Method Summary

Modifier and Type	Method and Description
(package private) void	logErrorAndReattemptRead(int bookieIndex, org.apache.bookkeeper.net.BookieId host, java.lang.String errMsg, int rc) Log error errMsg and reattempt read from host.
(package private) org.apache.bookkeeper.net.BookieId	maybeSendSpeculativeRead(java.util.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.LedgerEntryRequest

close, complete, fail, getRc, isComplete, issueSpeculativeRequest, toString

Methods inherited from class java.lang.Object

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

Field Detail

numPendings

int numPendings

Constructor Detail

ParallelReadRequest

ParallelReadRequest(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
                    long lId,
                    long eId)

Method Detail

read

void read()

Description copied from class: PendingReadOp.LedgerEntryRequest

Execute the read request.

Specified by:

read in class PendingReadOp.LedgerEntryRequest

logErrorAndReattemptRead

void logErrorAndReattemptRead(int bookieIndex,
                              org.apache.bookkeeper.net.BookieId host,
                              java.lang.String errMsg,
                              int rc)

Description copied from class: PendingReadOp.LedgerEntryRequest

Log error errMsg and reattempt read from host.

Overrides:

logErrorAndReattemptRead in class PendingReadOp.LedgerEntryRequest

Parameters:

bookieIndex - bookie index

host - host that just respond

errMsg - error msg to log

rc - read result code

maybeSendSpeculativeRead

org.apache.bookkeeper.net.BookieId maybeSendSpeculativeRead(java.util.BitSet heardFromHostsBitSet)

Description copied from class: PendingReadOp.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 PendingReadOp.LedgerEntryRequest

Parameters:

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

Returns:

host we sent to if we sent. null otherwise.