Package org.apache.bookkeeper.proto
Class ReadEntryProcessorV3
java.lang.Object
org.apache.bookkeeper.proto.PacketProcessorBaseV3
org.apache.bookkeeper.proto.ReadEntryProcessorV3
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
LongPollReadEntryProcessorV3
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final longprotected com.google.common.base.Stopwatchprotected final longprotected final BookkeeperProtocol.ReadRequestprotected final OpStatsLoggerprotected final OpStatsLoggerFields inherited from class org.apache.bookkeeper.proto.PacketProcessorBaseV3
enqueueNanos, request, requestHandler, requestProcessor -
Constructor Summary
ConstructorsConstructorDescriptionReadEntryProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool) -
Method Summary
Modifier and TypeMethodDescriptionprotected BookkeeperProtocol.ReadResponsebuildResponse(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, BookkeeperProtocol.StatusCode statusCode, com.google.common.base.Stopwatch startTimeSw) protected voidprotected Longprotected BookkeeperProtocol.ReadResponseprotected voidhandleReadResultForFenceRead(io.netty.buffer.ByteBuf entryBody, BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) Handle read result for fence read.protected BookkeeperProtocol.ReadResponsereadEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, boolean readLACPiggyBack, com.google.common.base.Stopwatch startTimeSw) Read a specific entry.protected BookkeeperProtocol.ReadResponsereadEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) Read a specific entry.protected voidregisterEvent(boolean failed, OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) protected voidregisterFailedEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) protected voidregisterSuccessfulEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) voidrun()protected voidsendResponse(BookkeeperProtocol.ReadResponse readResponse) toString()this toString method filters out masterKey from the output.Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBaseV3
getHeader, isVersionCompatible, sendResponse
-
Field Details
-
lastPhaseStartTime
protected com.google.common.base.Stopwatch lastPhaseStartTime -
readRequest
-
ledgerId
protected final long ledgerId -
entryId
protected final long entryId -
readStats
-
reqStats
-
-
Constructor Details
-
ReadEntryProcessorV3
public ReadEntryProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool)
-
-
Method Details
-
getPreviousLAC
-
handleReadResultForFenceRead
protected void handleReadResultForFenceRead(io.netty.buffer.ByteBuf entryBody, BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) Handle read result for fence read.- Parameters:
entryBody- read resultreadResponseBuilder- read response builderentryId- entry idstartTimeSw- timer for the read request
-
readEntry
protected BookkeeperProtocol.ReadResponse readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) throws IOException, BookieException Read a specific entry.- Parameters:
readResponseBuilder- read response builder.entryId- entry to readstartTimeSw- stop watch to measure the read operation.- Returns:
- read response or null if it is a fence read operation.
- Throws:
IOExceptionBookieException
-
readEntry
protected BookkeeperProtocol.ReadResponse readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, boolean readLACPiggyBack, com.google.common.base.Stopwatch startTimeSw) throws IOException, BookieException Read a specific entry.- Parameters:
readResponseBuilder- read response builder.entryId- entry to readstartTimeSw- stop watch to measure the read operation.- Returns:
- read response or null if it is a fence read operation.
- Throws:
IOExceptionBookieException
-
getReadResponse
-
run
public void run() -
executeOp
protected void executeOp() -
buildResponse
protected BookkeeperProtocol.ReadResponse buildResponse(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, BookkeeperProtocol.StatusCode statusCode, com.google.common.base.Stopwatch startTimeSw) -
sendResponse
-
registerSuccessfulEvent
protected void registerSuccessfulEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) -
registerFailedEvent
protected void registerFailedEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) -
registerEvent
protected void registerEvent(boolean failed, OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime) -
toString
this toString method filters out masterKey from the output. masterKey contains the password of the ledger.- Overrides:
toStringin classPacketProcessorBaseV3
-