Package org.apache.bookkeeper.proto

Class WriteEntryProcessor

java.lang.Object

org.apache.bookkeeper.proto.PacketProcessorBase<BookieProtocol.ParsedAddRequest>

org.apache.bookkeeper.proto.WriteEntryProcessor

All Implemented Interfaces:

Runnable, BookkeeperInternalCallbacks.WriteCallback

class WriteEntryProcessor
extends PacketProcessorBase<BookieProtocol.ParsedAddRequest>
implements BookkeeperInternalCallbacks.WriteCallback

Processes add entry requests.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	startTimeNanos

Fields inherited from class org.apache.bookkeeper.proto.PacketProcessorBase

enqueueNanos, request, requestHandler, requestProcessor

Method Summary

Modifier and Type	Method	Description
static WriteEntryProcessor	create(BookieProtocol.ParsedAddRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)
protected void	processPacket()
(package private) void	recycle()
protected void	reset()
String	toString()
void	writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)

Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBase

init, isVersionCompatible, run, sendReadReqResponse, sendResponse, sendResponseAndWait, sendWriteReqResponse

Methods inherited from class java.lang.Object

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

Field Details

startTimeNanos

long startTimeNanos

Method Details

reset

protected void reset()

Overrides:

reset in class PacketProcessorBase<BookieProtocol.ParsedAddRequest>

create

public static WriteEntryProcessor create(BookieProtocol.ParsedAddRequest request,
 BookieRequestHandler requestHandler,
 BookieRequestProcessor requestProcessor)

processPacket

protected void processPacket()

Specified by:

processPacket in class PacketProcessorBase<BookieProtocol.ParsedAddRequest>

writeComplete

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

Specified by:

writeComplete in interface BookkeeperInternalCallbacks.WriteCallback

toString

public String toString()

Overrides:

toString in class Object

recycle

void recycle()