Package org.apache.bookkeeper.client

Class ReadLastConfirmedAndEntryOp.ParallelReadRequest

java.lang.Object

org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

All Implemented Interfaces:

java.lang.AutoCloseable

Enclosing class:

ReadLastConfirmedAndEntryOp

class ReadLastConfirmedAndEntryOp.ParallelReadRequest
extends ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	numPendings

Fields inherited from class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

complete, ensemble, entryImpl, firstError, numMissedEntryReads, orderedEnsemble, rc, writeSet

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) void	logErrorAndReattemptRead(int bookieIndex, BookieId host, java.lang.String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) 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.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

close, complete, fail, getFirstError, getRc, isComplete, 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<BookieId> ensemble,
                    long lId,
                    long eId)

Method Detail

read

void read()

Description copied from class: ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Execute the read request.

Specified by:

read in class ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

logErrorAndReattemptRead

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

Description copied from class: ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Log error errMsg and reattempt read from host.

Overrides:

logErrorAndReattemptRead in class ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Parameters:

bookieIndex - bookie index

host - host that just respond

errMsg - error msg to log

rc - read result code

maybeSendSpeculativeRead

BookieId maybeSendSpeculativeRead(java.util.BitSet heardFromHostsBitSet)

Description copied from class: ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

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 ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Parameters:

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

Returns:

host we sent to if we sent. null otherwise.