Package org.apache.bookkeeper.proto

Class ReadEntryProcessor

java.lang.Object

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

org.apache.bookkeeper.proto.ReadEntryProcessor

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

BatchedReadEntryProcessor

class ReadEntryProcessor
extends PacketProcessorBase<BookieProtocol.ReadRequest>

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutorService	fenceThreadPool
protected boolean	throttleReadResponses

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

enqueueNanos, request, requestHandler, requestProcessor

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReadEntryProcessor()

Method Summary

Modifier and Type	Method	Description
protected BookieProtocol.Response	buildReadResponse(io.netty.util.ReferenceCounted data)
static ReadEntryProcessor	create(BookieProtocol.ReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, boolean throttleReadResponses)
protected void	processPacket()
protected io.netty.util.ReferenceCounted	readData()
(package private) void	recycle()
String	toString()

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

Field Details

fenceThreadPool

protected ExecutorService fenceThreadPool

throttleReadResponses

protected boolean throttleReadResponses

Constructor Details

ReadEntryProcessor

protected ReadEntryProcessor()

Method Details

create

public static ReadEntryProcessor create(BookieProtocol.ReadRequest request,
 BookieRequestHandler requestHandler,
 BookieRequestProcessor requestProcessor,
 ExecutorService fenceThreadPool,
 boolean throttleReadResponses)

processPacket

protected void processPacket()

Specified by:

processPacket in class PacketProcessorBase<BookieProtocol.ReadRequest>

readData

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

Throws:

Exception

buildReadResponse

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

toString

public String toString()

Overrides:

toString in class Object

recycle

void recycle()