Package org.apache.bookkeeper.proto

Class CompletionValue

java.lang.Object

org.apache.bookkeeper.proto.CompletionValue

Direct Known Subclasses:

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

abstract class CompletionValue
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Object	ctx
protected long	entryId
protected long	ledgerId
(package private) static final org.slf4j.Logger	LOG
protected Map<String,String>	mdcContextMap
protected OpStatsLogger	opLogger
protected PerChannelBookieClient	perChannelBookieClient
protected long	startTime
protected OpStatsLogger	timeoutOpLogger

Constructor Summary

Constructors

Constructor	Description
CompletionValue(String operationName, Object ctx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)

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(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, Object... extraInfo)
(package private) boolean	maybeTimeout()
void	release()
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 Details

ctx

protected Object ctx

ledgerId

protected long ledgerId

entryId

protected long entryId

startTime

protected long startTime

opLogger

protected OpStatsLogger opLogger

timeoutOpLogger

protected OpStatsLogger timeoutOpLogger

mdcContextMap

protected Map<String,String> mdcContextMap

perChannelBookieClient

protected PerChannelBookieClient perChannelBookieClient

LOG

static final org.slf4j.Logger LOG

Constructor Details

CompletionValue

public CompletionValue(String operationName,
 Object ctx,
 long ledgerId,
 long entryId,
 PerChannelBookieClient perChannelBookieClient)

Method Details

logOpResult

void logOpResult(int rc)

maybeTimeout

boolean maybeTimeout()

timeout

void timeout()

logResponse

protected void logResponse(BookkeeperProtocol.StatusCode status,
 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(Runnable callback)

handleV2Response

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

handleV3Response

public abstract void handleV3Response(BookkeeperProtocol.Response response)

release

public void release()