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
-
Field Summary
FieldsFields inherited from class org.apache.bookkeeper.proto.PacketProcessorBase
enqueueNanos, request, requestHandler, requestProcessor -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected BookieProtocol.ResponsebuildReadResponse(io.netty.util.ReferenceCounted data) static ReadEntryProcessorcreate(BookieProtocol.ReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, boolean throttleReadResponses) protected voidprotected io.netty.util.ReferenceCountedreadData()(package private) voidrecycle()toString()Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBase
init, isVersionCompatible, reset, run, sendReadReqResponse, sendResponse, sendResponseAndWait, sendWriteReqResponse
-
Field Details
-
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:
processPacketin classPacketProcessorBase<BookieProtocol.ReadRequest>
-
readData
- Throws:
Exception
-
buildReadResponse
-
toString
-
recycle
void recycle()
-