class PendingAddOp extends Object implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteCallback, io.netty.util.TimerTask
Modifier and Type | Field and Description |
---|---|
(package private) DistributionSchedule.AckSet |
ackSet |
(package private) OpStatsLogger |
addOpLogger |
(package private) boolean |
callbackTriggered |
(package private) AsyncCallback.AddCallback |
cb |
(package private) boolean |
completed |
(package private) Object |
ctx |
(package private) long |
entryId |
(package private) int |
entryLength |
(package private) boolean |
isRecoveryAdd |
(package private) LedgerHandle |
lh |
(package private) long |
requestTimeNanos |
(package private) io.netty.util.Timeout |
timeout |
(package private) int |
timeoutSec |
(package private) io.netty.buffer.ByteBuf |
toSend |
(package private) Set<Integer> |
writeSet |
Constructor and Description |
---|
PendingAddOp(LedgerHandle lh,
AsyncCallback.AddCallback cb,
Object ctx) |
Modifier and Type | Method and Description |
---|---|
(package private) PendingAddOp |
enableRecoveryAdd()
Enable the recovery add flag for this operation.
|
boolean |
equals(Object o) |
(package private) long |
getEntryId() |
int |
hashCode() |
(package private) void |
initiate(io.netty.buffer.ByteBuf toSend,
int entryLength) |
void |
run(io.netty.util.Timeout timeout) |
(package private) void |
sendAddSuccessCallbacks() |
(package private) void |
sendWriteRequest(int bookieIndex) |
(package private) void |
setEntryId(long entryId) |
(package private) void |
submitCallback(int rc) |
(package private) void |
timeoutQuorumWait() |
String |
toString() |
(package private) void |
unsetSuccessAndSendWriteRequest(int bookieIndex) |
void |
writeComplete(int rc,
long ledgerId,
long entryId,
org.apache.bookkeeper.net.BookieSocketAddress addr,
Object ctx) |
io.netty.buffer.ByteBuf toSend
Object ctx
long entryId
int entryLength
DistributionSchedule.AckSet ackSet
boolean completed
LedgerHandle lh
boolean isRecoveryAdd
long requestTimeNanos
final int timeoutSec
io.netty.util.Timeout timeout
OpStatsLogger addOpLogger
boolean callbackTriggered
PendingAddOp(LedgerHandle lh, AsyncCallback.AddCallback cb, Object ctx)
PendingAddOp enableRecoveryAdd()
void setEntryId(long entryId)
long getEntryId()
void sendWriteRequest(int bookieIndex)
public void run(io.netty.util.Timeout timeout)
run
in interface io.netty.util.TimerTask
void timeoutQuorumWait()
void unsetSuccessAndSendWriteRequest(int bookieIndex)
void initiate(io.netty.buffer.ByteBuf toSend, int entryLength)
public void writeComplete(int rc, long ledgerId, long entryId, org.apache.bookkeeper.net.BookieSocketAddress addr, Object ctx)
writeComplete
in interface org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteCallback
void sendAddSuccessCallbacks()
void submitCallback(int rc)
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.