Package org.apache.bookkeeper.client

Class ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

java.lang.Object

org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

ReadLastConfirmedAndEntryOp.ParallelReadRequest, ReadLastConfirmedAndEntryOp.SequenceReadRequest

Enclosing class:

ReadLastConfirmedAndEntryOp

abstract class ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicBoolean	complete
(package private) final List<BookieId>	ensemble
(package private) final LedgerEntryImpl	entryImpl
(package private) int	firstError
(package private) int	numMissedEntryReads
(package private) final DistributionSchedule.WriteSet	orderedEnsemble
(package private) int	rc
(package private) final DistributionSchedule.WriteSet	writeSet

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) boolean	complete(int bookieIndex, BookieId host, io.netty.buffer.ByteBuf buffer, long entryId)	Complete the read request from host.
(package private) boolean	fail(int rc)	Fail the request with given result code rc.
(package private) int	getFirstError()
(package private) int	getRc()	Get result code of this entry.
(package private) boolean	isComplete()	Whether the read request completed.
(package private) void	logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) abstract BookieId	maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)	Send to next replica speculatively, if required and possible.
(package private) abstract void	read()	Execute the read request.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

complete

final AtomicBoolean complete

rc

int rc

firstError

int firstError

numMissedEntryReads

int numMissedEntryReads

ensemble

final List<BookieId> ensemble

writeSet

final DistributionSchedule.WriteSet writeSet

orderedEnsemble

final DistributionSchedule.WriteSet orderedEnsemble

entryImpl

final LedgerEntryImpl entryImpl

Constructor Details

ReadLACAndEntryRequest

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

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

getFirstError

int getFirstError()

read

abstract void read()

Execute the read request.

complete

boolean complete(int bookieIndex,
 BookieId host,
 io.netty.buffer.ByteBuf buffer,
 long entryId)

Complete the read request from host.

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

fail

boolean fail(int rc)

Fail the request with given result code rc.

Parameters:

rc - result code to fail the request.

Returns:

true if we managed to fail the entry; otherwise return false if it already failed or completed.

logErrorAndReattemptRead

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

Log error errMsg and reattempt read from host.

Parameters:

bookieIndex - bookie index

host - host that just respond

errMsg - error msg to log

rc - read result code

maybeSendSpeculativeRead

abstract BookieId maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)

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

Parameters:

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

Returns:

host we sent to if we sent. null otherwise.

isComplete

boolean isComplete()

Whether the read request completed.

Returns:

true if the read request is completed.

getRc

int getRc()

Get result code of this entry.

Returns:

result code.

toString

public String toString()

Overrides:

toString in class Object