Package org.apache.bookkeeper.proto

Class BookieClientImpl.ChannelReadyForAddEntryCallback

java.lang.Object

org.apache.bookkeeper.proto.BookieClientImpl.ChannelReadyForAddEntryCallback

All Implemented Interfaces:

BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient>

Enclosing class:

BookieClientImpl

static class BookieClientImpl.ChannelReadyForAddEntryCallback
extends Object
implements BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient>

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
(package private) static BookieClientImpl.ChannelReadyForAddEntryCallback	create(BookieClientImpl bookieClient, io.netty.util.ReferenceCounted toSend, long ledgerId, long entryId, BookieId addr, Object ctx, BookkeeperInternalCallbacks.WriteCallback cb, int options, byte[] masterKey, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)
void	operationComplete(int rc, PerChannelBookieClient pcbc)
void	recycle()

Methods inherited from class java.lang.Object

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

Field Details

cb

BookkeeperInternalCallbacks.WriteCallback cb

Method Details

create

static BookieClientImpl.ChannelReadyForAddEntryCallback create(BookieClientImpl bookieClient,
 io.netty.util.ReferenceCounted toSend,
 long ledgerId,
 long entryId,
 BookieId addr,
 Object ctx,
 BookkeeperInternalCallbacks.WriteCallback cb,
 int options,
 byte[] masterKey,
 boolean allowFastFail,
 EnumSet<WriteFlag> writeFlags)

operationComplete

public void operationComplete(int rc,
 PerChannelBookieClient pcbc)

Specified by:

operationComplete in interface BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient>

recycle

public void recycle()