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

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 class PacketProcessorBase<BookieProtocol.ReadRequest>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object