org.apache.bookkeeper.client

Class PendingReadOp.SequenceReadRequest

java.lang.Object

org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

All Implemented Interfaces:

java.lang.AutoCloseable, SpeculativeRequestExecutor

Enclosing class:

PendingReadOp

class PendingReadOp.SequenceReadRequest
extends PendingReadOp.LedgerEntryRequest

Field Summary

Fields

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

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
(package private) boolean	complete(int bookieIndex, org.apache.bookkeeper.net.BookieId host, io.netty.buffer.ByteBuf buffer) Complete the read request from host.
(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 heardFrom) Send to next replica speculatively, if required and possible.
(package private) void	read() Execute the read request.
(package private) org.apache.bookkeeper.net.BookieId	sendNextRead()

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

close, fail, getRc, isComplete, issueSpeculativeRequest, toString

Methods inherited from class java.lang.Object

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

Field Detail

NOT_FOUND

static final int NOT_FOUND

See Also:

Constant Field Values

nextReplicaIndexToReadFrom

int nextReplicaIndexToReadFrom

sentReplicas

final java.util.BitSet sentReplicas

erroredReplicas

final java.util.BitSet erroredReplicas

Constructor Detail

SequenceReadRequest

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

Method Detail

maybeSendSpeculativeRead

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

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:

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

Returns:

host we sent to if we sent. null otherwise.

read

void read()

Description copied from class: PendingReadOp.LedgerEntryRequest

Execute the read request.

Specified by:

read in class PendingReadOp.LedgerEntryRequest

sendNextRead

org.apache.bookkeeper.net.BookieId sendNextRead()

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

complete

boolean complete(int bookieIndex,
                 org.apache.bookkeeper.net.BookieId host,
                 io.netty.buffer.ByteBuf buffer)

Description copied from class: PendingReadOp.LedgerEntryRequest

Complete the read request from host.

Overrides:

complete in class PendingReadOp.LedgerEntryRequest

Parameters:

bookieIndex - bookie index

host - host that respond the read

buffer - the data buffer

Returns:

return true if we managed to complete the entry; otherwise return false if the read entry is not complete or it is already completed before