Package org.apache.bookkeeper.proto
Class ReadEntryProcessor
- java.lang.Object
-
- org.apache.bookkeeper.util.SafeRunnable
-
- org.apache.bookkeeper.proto.PacketProcessorBase<BookieProtocol.ReadRequest>
-
- org.apache.bookkeeper.proto.ReadEntryProcessor
-
- All Implemented Interfaces:
java.lang.Runnable
,SafeRunnable
class ReadEntryProcessor extends PacketProcessorBase<BookieProtocol.ReadRequest>
-
-
Field Summary
-
Fields inherited from class org.apache.bookkeeper.proto.PacketProcessorBase
channel, enqueueNanos, request, requestProcessor
-
Fields inherited from interface org.apache.bookkeeper.common.util.SafeRunnable
LOGGER
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ReadEntryProcessor
create(BookieProtocol.ReadRequest request, io.netty.channel.Channel channel, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses)
protected void
processPacket()
java.lang.String
toString()
-
Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBase
init, isVersionCompatible, reset, safeRun, sendResponse, sendResponseAndWait
-
Methods inherited from class org.apache.bookkeeper.util.SafeRunnable
safeRun, safeRun
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.bookkeeper.common.util.SafeRunnable
run
-
-
-
-
Method Detail
-
create
public static ReadEntryProcessor create(BookieProtocol.ReadRequest request, io.netty.channel.Channel channel, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses)
-
processPacket
protected void processPacket()
- Specified by:
processPacket
in classPacketProcessorBase<BookieProtocol.ReadRequest>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-