Package org.apache.bookkeeper.proto

Class PerChannelBookieClient.AddCompletion

java.lang.Object

org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue

org.apache.bookkeeper.proto.PerChannelBookieClient.AddCompletion

All Implemented Interfaces:

BookkeeperInternalCallbacks.WriteCallback

Enclosing class:

PerChannelBookieClient

class PerChannelBookieClient.AddCompletion
extends PerChannelBookieClient.CompletionValue
implements BookkeeperInternalCallbacks.WriteCallback

Field Summary

Fields

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

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

ctx, entryId, ledgerId, startTime

Constructor Summary

Constructors

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

Method Summary

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)
(package private) boolean	maybeTimeout()
(package private) void	reset(PerChannelBookieClient.CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId)
void	setOutstanding()
void	writeComplete(int rc, long ledgerId, long entryId, BookieId addr, java.lang.Object ctx)

Methods inherited from class org.apache.bookkeeper.proto.PerChannelBookieClient.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 Detail

handle

final io.netty.util.Recycler.Handle<PerChannelBookieClient.AddCompletion> handle

key

PerChannelBookieClient.CompletionKey key

originalCallback

BookkeeperInternalCallbacks.WriteCallback originalCallback

Constructor Detail

AddCompletion

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

Method Detail

reset

void reset(PerChannelBookieClient.CompletionKey key,
           BookkeeperInternalCallbacks.WriteCallback originalCallback,
           java.lang.Object originalCtx,
           long ledgerId,
           long entryId)

writeComplete

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

Specified by:

writeComplete in interface BookkeeperInternalCallbacks.WriteCallback

maybeTimeout

boolean maybeTimeout()

Overrides:

maybeTimeout in class PerChannelBookieClient.CompletionValue

errorOut

public void errorOut()

Specified by:

errorOut in class PerChannelBookieClient.CompletionValue

errorOut

public void errorOut(int rc)

Specified by:

errorOut in class PerChannelBookieClient.CompletionValue

setOutstanding

public void setOutstanding()

Overrides:

setOutstanding in class PerChannelBookieClient.CompletionValue

handleV2Response

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

Overrides:

handleV2Response in class PerChannelBookieClient.CompletionValue

handleV3Response

public void handleV3Response(BookkeeperProtocol.Response response)

Specified by:

handleV3Response in class PerChannelBookieClient.CompletionValue