Package org.apache.bookkeeper.proto

Class PerChannelBookieClient.ReadCompletion

java.lang.Object

org.apache.bookkeeper.proto.PerChannelBookieClient.CompletionValue

org.apache.bookkeeper.proto.PerChannelBookieClient.ReadCompletion

Enclosing class:

PerChannelBookieClient

class PerChannelBookieClient.ReadCompletion
extends PerChannelBookieClient.CompletionValue

Field Summary

Fields

Modifier and Type	Field	Description
(package private) BookkeeperInternalCallbacks.ReadEntryCallback	cb

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

ctx, entryId, ledgerId, startTime

Constructor Summary

Constructors

Constructor	Description
ReadCompletion(PerChannelBookieClient.CompletionKey key, BookkeeperInternalCallbacks.ReadEntryCallback originalCallback, java.lang.Object originalCtx, long ledgerId, long entryId)

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)
void	setOutstanding()

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

convertStatus, errorOutAndRunCallback, logOpResult, logResponse, maybeTimeout, restoreMdcContext, timeout

Methods inherited from class java.lang.Object

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

Field Detail

cb

final BookkeeperInternalCallbacks.ReadEntryCallback cb

Constructor Detail

ReadCompletion

public ReadCompletion(PerChannelBookieClient.CompletionKey key,
                      BookkeeperInternalCallbacks.ReadEntryCallback originalCallback,
                      java.lang.Object originalCtx,
                      long ledgerId,
                      long entryId)

Method Detail

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