Package org.apache.bookkeeper.client

Class PendingReadOp.SingleLedgerEntryRequest

java.lang.Object

org.apache.bookkeeper.client.ReadOpBase.LedgerEntryRequest

org.apache.bookkeeper.client.PendingReadOp.SingleLedgerEntryRequest

All Implemented Interfaces:

SpeculativeRequestExecutor

Direct Known Subclasses:

PendingReadOp.ParallelReadRequest, PendingReadOp.SequenceReadRequest

Enclosing class:

PendingReadOp

abstract class PendingReadOp.SingleLedgerEntryRequest
extends ReadOpBase.LedgerEntryRequest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final LedgerEntryImpl	entryImpl

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

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

Constructor Summary

Constructors

Constructor	Description
SingleLedgerEntryRequest(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)	Complete the read request from host.

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

fail, getRc, isComplete, issueSpeculativeRequest, logErrorAndReattemptRead, maybeSendSpeculativeRead, read, toString

Methods inherited from class java.lang.Object

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

Field Details

entryImpl

final LedgerEntryImpl entryImpl

Constructor Details

SingleLedgerEntryRequest

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

Method Details

close

public void close()

Overrides:

close in class ReadOpBase.LedgerEntryRequest

complete

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

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