Package org.apache.bookkeeper.proto

Class PacketProcessorBaseV3

java.lang.Object

org.apache.bookkeeper.proto.PacketProcessorBaseV3

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ForceLedgerProcessorV3, GetBookieInfoProcessorV3, GetListOfEntriesOfLedgerProcessorV3, ReadEntryProcessorV3, ReadLacProcessorV3, WriteEntryProcessorV3, WriteLacProcessorV3

public abstract class PacketProcessorBaseV3
extends Object
implements Runnable

A base class for bookkeeper protocol v3 packet processors.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final long	enqueueNanos
(package private) final BookkeeperProtocol.Request	request
(package private) final BookieRequestHandler	requestHandler
(package private) final BookieRequestProcessor	requestProcessor

Constructor Summary

Constructors

Constructor	Description
PacketProcessorBaseV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)

Method Summary

Modifier and Type	Method	Description
protected BookkeeperProtocol.BKPacketHeader	getHeader()	Build a header with protocol version 3 and the operation type same as what was in the request.
protected boolean	isVersionCompatible()
protected void	sendResponse(BookkeeperProtocol.StatusCode code, Object response, OpStatsLogger statsLogger)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Details

request

final BookkeeperProtocol.Request request

requestHandler

final BookieRequestHandler requestHandler

requestProcessor

final BookieRequestProcessor requestProcessor

enqueueNanos

final long enqueueNanos

Constructor Details

PacketProcessorBaseV3

public PacketProcessorBaseV3(BookkeeperProtocol.Request request,
 BookieRequestHandler requestHandler,
 BookieRequestProcessor requestProcessor)

Method Details

sendResponse

protected void sendResponse(BookkeeperProtocol.StatusCode code,
 Object response,
 OpStatsLogger statsLogger)

isVersionCompatible

protected boolean isVersionCompatible()

getHeader

protected BookkeeperProtocol.BKPacketHeader getHeader()

Build a header with protocol version 3 and the operation type same as what was in the request.

Returns:

toString

public String toString()

Overrides:

toString in class Object