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

class AddCompletion
extends CompletionValue
implements BookkeeperInternalCallbacks.WriteCallback

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final io.netty.util.Recycler.Handle<AddCompletion>	handle
(package private) CompletionKey	key
(package private) BookkeeperInternalCallbacks.WriteCallback	originalCallback

Fields inherited from class org.apache.bookkeeper.proto.CompletionValue

ctx, entryId, ledgerId, LOG, mdcContextMap, opLogger, perChannelBookieClient, startTime, timeoutOpLogger

Constructor Summary

Constructors

Constructor	Description
AddCompletion(io.netty.util.Recycler.Handle<AddCompletion> handle)

Method Summary

Modifier and Type	Method	Description
(package private) static AddCompletion	acquireAddCompletion(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
void	errorOut()
void	errorOut(int rc)
void	handleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
void	handleV3Response(BookkeeperProtocol.Response response)
(package private) boolean	maybeTimeout()
void	release()
(package private) void	reset(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
void	setOutstanding()
void	writeComplete(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

handle

final io.netty.util.Recycler.Handle<AddCompletion> 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:

release in class CompletionValue

writeComplete

public void writeComplete(int rc,
 long ledgerId,
 long entryId,
 BookieId addr,
 Object ctx)

Specified by:

writeComplete in interface BookkeeperInternalCallbacks.WriteCallback

maybeTimeout

boolean maybeTimeout()

Overrides:

maybeTimeout in class CompletionValue

errorOut

public void errorOut()

Specified by:

errorOut in class CompletionValue

errorOut

public void errorOut(int rc)

Specified by:

errorOut in class CompletionValue

setOutstanding

public void setOutstanding()

Overrides:

setOutstanding in class CompletionValue

handleV2Response

public void handleV2Response(long ledgerId,
 long entryId,
 BookkeeperProtocol.StatusCode status,
 BookieProtocol.Response response)

Overrides:

handleV2Response in class CompletionValue

handleV3Response

public void handleV3Response(BookkeeperProtocol.Response response)

Specified by:

handleV3Response in class CompletionValue