Package org.apache.bookkeeper.client

Class PendingAddOp

java.lang.Object

org.apache.bookkeeper.client.PendingAddOp

All Implemented Interfaces:

BookkeeperInternalCallbacks.WriteCallback

class PendingAddOp
extends Object
implements BookkeeperInternalCallbacks.WriteCallback

This represents a pending add operation. When it has got success from all bookies, it sees if its at the head of the pending adds queue, and if yes, sends ack back to the application. If a bookie fails, a replacement is made and placed at the same position in the ensemble. The pending adds are then rereplicated.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) DistributionSchedule.AckSet	ackSet
(package private) Set<BookieId>	addEntrySuccessBookies
(package private) boolean	allowFailFast
(package private) boolean	callbackTriggered
(package private) AsyncCallback.AddCallbackWithLatency	cb
(package private) ClientContext	clientCtx
(package private) boolean	completed
(package private) Object	ctx
(package private) long	currentLedgerLength
(package private) List<BookieId>	ensemble
(package private) long	entryId
(package private) int	entryLength
(package private) boolean	hasRun
(package private) boolean	isRecoveryAdd
(package private) LedgerHandle	lh
(package private) io.netty.buffer.ByteBuf	payload
(package private) int	pendingWriteRequests
(package private) long	qwcLatency
(package private) long	requestTimeNanos
(package private) io.netty.util.ReferenceCounted	toSend
(package private) long	writeDelayedStartTime
(package private) EnumSet<WriteFlag>	writeFlags

Method Summary

Modifier and Type	Method	Description
(package private) PendingAddOp	allowFailFastOnUnwritableChannel()
(package private) static PendingAddOp	create(LedgerHandle lh, ClientContext clientCtx, List<BookieId> ensemble, io.netty.buffer.ByteBuf payload, EnumSet<WriteFlag> writeFlags, AsyncCallback.AddCallbackWithLatency cb, Object ctx)
(package private) PendingAddOp	enableRecoveryAdd()	Enable the recovery add flag for this operation.
boolean	equals(Object o)
(package private) long	getEntryId()
int	hashCode()
void	initiate()	Initiate the add operation.
(package private) boolean	maybeTimeout()
void	recyclePendAddOpObject()
(package private) void	sendAddSuccessCallbacks()
(package private) void	setEntryId(long entryId)
(package private) void	setLedgerLength(long ledgerLength)
(package private) void	submitCallback(int rc)
(package private) void	timeoutQuorumWait()
String	toString()
(package private) void	unsetSuccessAndSendWriteRequest(List<BookieId> ensemble, int bookieIndex)
void	writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

payload

io.netty.buffer.ByteBuf payload

toSend

io.netty.util.ReferenceCounted toSend

cb

AsyncCallback.AddCallbackWithLatency cb

ctx

Object ctx

entryId

long entryId

entryLength

int entryLength

ackSet

DistributionSchedule.AckSet ackSet

completed

boolean completed

lh

LedgerHandle lh

clientCtx

ClientContext clientCtx

isRecoveryAdd

boolean isRecoveryAdd

requestTimeNanos

volatile long requestTimeNanos

qwcLatency

long qwcLatency

addEntrySuccessBookies

Set<BookieId> addEntrySuccessBookies

writeDelayedStartTime

long writeDelayedStartTime

currentLedgerLength

long currentLedgerLength

pendingWriteRequests

int pendingWriteRequests

callbackTriggered

boolean callbackTriggered

hasRun

boolean hasRun

writeFlags

EnumSet<WriteFlag> writeFlags

allowFailFast

boolean allowFailFast

ensemble

List<BookieId> ensemble

Method Details

create

static PendingAddOp create(LedgerHandle lh,
 ClientContext clientCtx,
 List<BookieId> ensemble,
 io.netty.buffer.ByteBuf payload,
 EnumSet<WriteFlag> writeFlags,
 AsyncCallback.AddCallbackWithLatency cb,
 Object ctx)

enableRecoveryAdd

PendingAddOp enableRecoveryAdd()

Enable the recovery add flag for this operation.

See Also:

• LedgerHandle.asyncRecoveryAddEntry(byte[], int, int, org.apache.bookkeeper.client.AsyncCallback.AddCallback, java.lang.Object)

allowFailFastOnUnwritableChannel

PendingAddOp allowFailFastOnUnwritableChannel()

setEntryId

void setEntryId(long entryId)

setLedgerLength

void setLedgerLength(long ledgerLength)

getEntryId

long getEntryId()

maybeTimeout

boolean maybeTimeout()

timeoutQuorumWait

void timeoutQuorumWait()

unsetSuccessAndSendWriteRequest

void unsetSuccessAndSendWriteRequest(List<BookieId> ensemble,
 int bookieIndex)

initiate

public void initiate()

Initiate the add operation.

writeComplete

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

Specified by:

writeComplete in interface BookkeeperInternalCallbacks.WriteCallback

sendAddSuccessCallbacks

void sendAddSuccessCallbacks()

submitCallback

void submitCallback(int rc)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

recyclePendAddOpObject

public void recyclePendAddOpObject()