Package org.apache.bookkeeper.proto
Class PerChannelBookieClient.ReadCompletion
- java.lang.Object
-
- org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue
-
- org.apache.bookkeeper.proto.PerChannelBookieClient.ReadCompletion
-
- Enclosing class:
- PerChannelBookieClient
class PerChannelBookieClient.ReadCompletion extends PerChannelBookieClient.CompletionValue
-
-
Field Summary
Fields Modifier and Type Field Description (package private) BookkeeperInternalCallbacks.ReadEntryCallback
cb
-
Fields inherited from class org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue
ctx, entryId, ledgerId, startTime
-
-
Constructor Summary
Constructors Constructor Description ReadCompletion(PerChannelBookieClient.CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId)
-
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, org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
void
handleV3Response(org.apache.bookkeeper.proto.BookkeeperProtocol.Response response)
void
setOutstanding()
-
Methods inherited from class org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue
convertStatus, errorOutAndRunCallback, logOpResult, logResponse, maybeTimeout, restoreMdcContext, timeout
-
-
-
-
Field Detail
-
cb
final BookkeeperInternalCallbacks.ReadEntryCallback cb
-
-
Constructor Detail
-
ReadCompletion
public ReadCompletion(PerChannelBookieClient.CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId)
-
-
Method Detail
-
errorOut
public void errorOut()
- Specified by:
errorOut
in classPerChannelBookieClient.CompletionValue
-
errorOut
public void errorOut(int rc)
- Specified by:
errorOut
in classPerChannelBookieClient.CompletionValue
-
setOutstanding
public void setOutstanding()
- Overrides:
setOutstanding
in classPerChannelBookieClient.CompletionValue
-
handleV2Response
public void handleV2Response(long ledgerId, long entryId, org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
- Overrides:
handleV2Response
in classPerChannelBookieClient.CompletionValue
-
handleV3Response
public void handleV3Response(org.apache.bookkeeper.proto.BookkeeperProtocol.Response response)
- Specified by:
handleV3Response
in classPerChannelBookieClient.CompletionValue
-
-