Package org.apache.bookkeeper.proto

Class PerChannelBookieClient.CompletionValue

java.lang.Object

org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue

Direct Known Subclasses:

PerChannelBookieClient.AddCompletion, PerChannelBookieClient.BatchedReadCompletion, PerChannelBookieClient.ForceLedgerCompletion, PerChannelBookieClient.GetBookieInfoCompletion, PerChannelBookieClient.GetListOfEntriesOfLedgerCompletion, PerChannelBookieClient.ReadCompletion, PerChannelBookieClient.ReadLacCompletion, PerChannelBookieClient.StartTLSCompletion, PerChannelBookieClient.WriteLacCompletion

Enclosing class:

PerChannelBookieClient

abstract class PerChannelBookieClient.CompletionValue
extends java.lang.Object

Boiler-plate wrapper classes follow.

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.Object	ctx
protected long	entryId
protected long	ledgerId
protected long	startTime

Constructor Summary

Constructors

Constructor	Description
CompletionValue(java.lang.String operationName, java.lang.Object ctx, long ledgerId, long entryId, OpStatsLogger opLogger, OpStatsLogger timeoutOpLogger)

Method Summary

Modifier and Type	Method	Description
protected int	convertStatus(BookkeeperProtocol.StatusCode status, int defaultStatus)
abstract void	errorOut()
abstract void	errorOut(int rc)
protected void	errorOutAndRunCallback(java.lang.Runnable callback)
void	handleV2Response(long ledgerId, long entryId, BookkeeperProtocol.StatusCode status, BookieProtocol.Response response)
abstract void	handleV3Response(BookkeeperProtocol.Response response)
(package private) void	logOpResult(int rc)
protected void	logResponse(BookkeeperProtocol.StatusCode status, java.lang.Object... extraInfo)
(package private) boolean	maybeTimeout()
void	restoreMdcContext()
void	setOutstanding()
(package private) void	timeout()

Methods inherited from class java.lang.Object

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

Field Detail

ctx

protected java.lang.Object ctx

ledgerId

protected long ledgerId

entryId

protected long entryId

startTime

protected long startTime

Constructor Detail

CompletionValue

public CompletionValue(java.lang.String operationName,
                       java.lang.Object ctx,
                       long ledgerId,
                       long entryId,
                       OpStatsLogger opLogger,
                       OpStatsLogger timeoutOpLogger)

Method Detail

logOpResult

void logOpResult(int rc)

maybeTimeout

boolean maybeTimeout()

timeout

void timeout()

logResponse

protected void logResponse(BookkeeperProtocol.StatusCode status,
                           java.lang.Object... extraInfo)

convertStatus

protected int convertStatus(BookkeeperProtocol.StatusCode status,
                            int defaultStatus)

restoreMdcContext

public void restoreMdcContext()

errorOut

public abstract void errorOut()

errorOut

public abstract void errorOut(int rc)

setOutstanding

public void setOutstanding()

errorOutAndRunCallback

protected void errorOutAndRunCallback(java.lang.Runnable callback)

handleV2Response

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

handleV3Response

public abstract void handleV3Response(BookkeeperProtocol.Response response)