Package org.apache.bookkeeper.proto
Class AddCompletion
java.lang.Object
org.apache.bookkeeper.proto.CompletionValue
org.apache.bookkeeper.proto.AddCompletion
- All Implemented Interfaces:
BookkeeperInternalCallbacks.WriteCallback
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final io.netty.util.Recycler.Handle<AddCompletion>(package private) CompletionKey(package private) BookkeeperInternalCallbacks.WriteCallbackFields inherited from class org.apache.bookkeeper.proto.CompletionValue
ctx, entryId, ledgerId, LOG, mdcContextMap, opLogger, perChannelBookieClient, startTime, timeoutOpLogger -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) static AddCompletionacquireAddCompletion(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient) voiderrorOut()voiderrorOut(int rc) voidhandleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response) voidhandleV3Response(BookkeeperProtocol.Response response) (package private) booleanvoidrelease()(package private) voidreset(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient) voidvoidwriteComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx) Methods inherited from class org.apache.bookkeeper.proto.CompletionValue
convertStatus, errorOutAndRunCallback, logOpResult, logResponse, restoreMdcContext, timeout
-
Field Details
-
handle
-
key
CompletionKey key -
originalCallback
BookkeeperInternalCallbacks.WriteCallback originalCallback
-
-
Constructor Details
-
AddCompletion
AddCompletion(io.netty.util.Recycler.Handle<AddCompletion> handle)
-
-
Method Details
-
acquireAddCompletion
static AddCompletion acquireAddCompletion(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient) -
reset
void reset(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient) -
release
public void release()- Overrides:
releasein classCompletionValue
-
writeComplete
- Specified by:
writeCompletein interfaceBookkeeperInternalCallbacks.WriteCallback
-
maybeTimeout
boolean maybeTimeout()- Overrides:
maybeTimeoutin classCompletionValue
-
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
-