Package org.apache.bookkeeper.client

Class BatchedReadOp.SequenceReadRequest

java.lang.Object

org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

org.apache.bookkeeper.client.BatchedReadOp.BatchedLedgerEntryRequest

org.apache.bookkeeper.client.BatchedReadOp.SequenceReadRequest

All Implemented Interfaces:

SpeculativeRequestExecutor

Enclosing class:

BatchedReadOp

class BatchedReadOp.SequenceReadRequest
extends BatchedReadOp.BatchedLedgerEntryRequest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BitSet	erroredReplicas
(package private) int	nextReplicaIndexToReadFrom
(package private) static final int	NOT_FOUND
(package private) final BitSet	sentReplicas

Fields inherited from class org.apache.bookkeeper.client.BatchedReadOp.BatchedLedgerEntryRequest

entries, lId, maxCount, maxSize

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

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

Constructor Summary

Constructors

Constructor	Description
SequenceReadRequest(List<BookieId> ensemble, long lId, long eId, int maxCount, long maxSize)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	complete(int bookieIndex, BookieId host, ByteBufList bufList)
(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 heardFrom)	Send to next replica speculatively, if required and possible.
(package private) void	read()	Execute the read request.
(package private) BookieId	sendNextRead()

Methods inherited from class org.apache.bookkeeper.client.BatchedReadOp.BatchedLedgerEntryRequest

toString

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

close, fail, getRc, isComplete, issueSpeculativeRequest

Methods inherited from class java.lang.Object

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

Field Details

NOT_FOUND

static final int NOT_FOUND

See Also:

• Constant Field Values

nextReplicaIndexToReadFrom

int nextReplicaIndexToReadFrom

sentReplicas

final BitSet sentReplicas

erroredReplicas

final BitSet erroredReplicas

Constructor Details

SequenceReadRequest

SequenceReadRequest(List<BookieId> ensemble,
 long lId,
 long eId,
 int maxCount,
 long maxSize)

Method Details

read

void read()

Description copied from class: ReadOpBase.LedgerEntryRequest

Execute the read request.

Specified by:

read in class ReadOpBase.LedgerEntryRequest

maybeSendSpeculativeRead

BookieId maybeSendSpeculativeRead(BitSet heardFrom)

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:

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

Returns:

host we sent to if we sent. null otherwise.

sendNextRead

BookieId sendNextRead()

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

complete

boolean complete(int bookieIndex,
 BookieId host,
 ByteBufList bufList)

Overrides:

complete in class BatchedReadOp.BatchedLedgerEntryRequest