Package org.apache.bookkeeper.proto
Class PacketProcessorBaseV3
java.lang.Object
org.apache.bookkeeper.proto.PacketProcessorBaseV3
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
ForceLedgerProcessorV3,GetBookieInfoProcessorV3,GetListOfEntriesOfLedgerProcessorV3,ReadEntryProcessorV3,ReadLacProcessorV3,WriteEntryProcessorV3,WriteLacProcessorV3
A base class for bookkeeper protocol v3 packet processors.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final long(package private) final BookkeeperProtocol.Request(package private) final BookieRequestHandler(package private) final BookieRequestProcessor -
Constructor Summary
ConstructorsConstructorDescriptionPacketProcessorBaseV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) -
Method Summary
Modifier and TypeMethodDescriptionprotected BookkeeperProtocol.BKPacketHeaderBuild a header with protocol version 3 and the operation type same as what was in the request.protected booleanprotected voidsendResponse(BookkeeperProtocol.StatusCode code, Object response, OpStatsLogger statsLogger) toString()
-
Field Details
-
request
-
requestHandler
-
requestProcessor
-
enqueueNanos
final long enqueueNanos
-
-
Constructor Details
-
PacketProcessorBaseV3
public PacketProcessorBaseV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)
-
-
Method Details
-
sendResponse
protected void sendResponse(BookkeeperProtocol.StatusCode code, Object response, OpStatsLogger statsLogger) -
isVersionCompatible
protected boolean isVersionCompatible() -
getHeader
Build a header with protocol version 3 and the operation type same as what was in the request.- Returns:
-
toString
-