Package org.apache.bookkeeper.proto

Class BatchedReadEntryProcessor

java.lang.Object

org.apache.bookkeeper.proto.PacketProcessorBase<BookieProtocol.ReadRequest>

org.apache.bookkeeper.proto.ReadEntryProcessor

org.apache.bookkeeper.proto.BatchedReadEntryProcessor

All Implemented Interfaces:

Runnable

public class BatchedReadEntryProcessor
extends ReadEntryProcessor

Field Summary

Fields inherited from class org.apache.bookkeeper.proto.ReadEntryProcessor

fenceThreadPool, throttleReadResponses

Fields inherited from class org.apache.bookkeeper.proto.PacketProcessorBase

enqueueNanos, request, requestHandler, requestProcessor

Method Summary

Modifier and Type	Method	Description
protected BookieProtocol.Response	buildReadResponse(io.netty.util.ReferenceCounted data)
static BatchedReadEntryProcessor	create(BookieProtocol.BatchedReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, boolean throttleReadResponses, long maxBatchReadSize)
protected io.netty.util.ReferenceCounted	readData()
protected void	recycle()
String	toString()

Methods inherited from class org.apache.bookkeeper.proto.ReadEntryProcessor

create, processPacket

Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBase

init, isVersionCompatible, reset, run, sendReadReqResponse, sendResponse, sendResponseAndWait, sendWriteReqResponse

Methods inherited from class java.lang.Object

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

Method Details

create

public static BatchedReadEntryProcessor create(BookieProtocol.BatchedReadRequest request,
 BookieRequestHandler requestHandler,
 BookieRequestProcessor requestProcessor,
 ExecutorService fenceThreadPool,
 boolean throttleReadResponses,
 long maxBatchReadSize)

readData

protected io.netty.util.ReferenceCounted readData()
                                           throws Exception

Overrides:

readData in class ReadEntryProcessor

Throws:

Exception

buildReadResponse

protected BookieProtocol.Response buildReadResponse(io.netty.util.ReferenceCounted data)

Overrides:

buildReadResponse in class ReadEntryProcessor

toString

public String toString()

Overrides:

toString in class ReadEntryProcessor

recycle

protected void recycle()

Overrides:

recycle in class ReadEntryProcessor