Package org.apache.bookkeeper.proto
Class ReadCompletion
java.lang.Object
org.apache.bookkeeper.proto.CompletionValue
org.apache.bookkeeper.proto.ReadCompletion
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final BookkeeperInternalCallbacks.ReadEntryCallbackFields inherited from class org.apache.bookkeeper.proto.CompletionValue
ctx, entryId, ledgerId, LOG, mdcContextMap, opLogger, perChannelBookieClient, startTime, timeoutOpLogger -
Constructor Summary
ConstructorsConstructorDescriptionReadCompletion(CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient) -
Method Summary
Modifier and TypeMethodDescriptionvoiderrorOut()voiderrorOut(int rc) voidhandleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response) voidhandleV3Response(BookkeeperProtocol.Response response) voidMethods inherited from class org.apache.bookkeeper.proto.CompletionValue
convertStatus, errorOutAndRunCallback, logOpResult, logResponse, maybeTimeout, release, restoreMdcContext, timeout
-
Field Details
-
cb
-
-
Constructor Details
-
ReadCompletion
public ReadCompletion(CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
-
-
Method Details
-
errorOut
public void errorOut()- Specified by:
errorOutin classCompletionValue
-
errorOut
public void errorOut(int rc) - Specified by:
errorOutin classCompletionValue
-
setOutstanding
public void setOutstanding()- Overrides:
setOutstandingin classCompletionValue
-
handleV2Response
public void handleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response) - Overrides:
handleV2Responsein classCompletionValue
-
handleV3Response
- Specified by:
handleV3Responsein classCompletionValue
-