Package org.apache.bookkeeper.proto
Class ReadCompletion
- java.lang.Object
-
- org.apache.bookkeeper.proto.CompletionValue
-
- org.apache.bookkeeper.proto.ReadCompletion
-
class ReadCompletion extends CompletionValue
-
-
Field Summary
Fields Modifier and Type Field Description (package private) BookkeeperInternalCallbacks.ReadEntryCallback
cb
-
Fields inherited from class org.apache.bookkeeper.proto.CompletionValue
ctx, entryId, ledgerId, LOG, mdcContextMap, opLogger, perChannelBookieClient, startTime, timeoutOpLogger
-
-
Constructor Summary
Constructors Constructor Description ReadCompletion(CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
errorOut()
void
errorOut(int rc)
void
handleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
void
handleV3Response(BookkeeperProtocol.Response response)
void
setOutstanding()
-
Methods inherited from class org.apache.bookkeeper.proto.CompletionValue
convertStatus, errorOutAndRunCallback, logOpResult, logResponse, maybeTimeout, release, restoreMdcContext, timeout
-
-
-
-
Field Detail
-
cb
final BookkeeperInternalCallbacks.ReadEntryCallback cb
-
-
Constructor Detail
-
ReadCompletion
public ReadCompletion(CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
-
-
Method Detail
-
errorOut
public void errorOut()
- Specified by:
errorOut
in classCompletionValue
-
errorOut
public void errorOut(int rc)
- Specified by:
errorOut
in classCompletionValue
-
setOutstanding
public void setOutstanding()
- Overrides:
setOutstanding
in classCompletionValue
-
handleV2Response
public void handleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
- Overrides:
handleV2Response
in classCompletionValue
-
handleV3Response
public void handleV3Response(BookkeeperProtocol.Response response)
- Specified by:
handleV3Response
in classCompletionValue
-
-