Package org.apache.bookkeeper.proto

Class PacketProcessorBase<T extends BookieProtocol.Request>

java.lang.Object

org.apache.bookkeeper.proto.PacketProcessorBase<T>

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ReadEntryProcessor, WriteEntryProcessor

abstract class PacketProcessorBase<T extends BookieProtocol.Request>
extends Object
implements Runnable

A base class for bookeeper packet processors.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	enqueueNanos
(package private) T	request
(package private) BookieRequestHandler	requestHandler
(package private) BookieRequestProcessor	requestProcessor

Constructor Summary

Constructors

Constructor	Description
PacketProcessorBase()

Method Summary

Modifier and Type	Method	Description
protected void	init(T request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)
protected boolean	isVersionCompatible()
protected abstract void	processPacket()
protected void	reset()
void	run()
protected void	sendReadReqResponse(int rc, Object response, OpStatsLogger statsLogger, boolean throttle)
protected void	sendResponse(int rc, Object response, OpStatsLogger statsLogger)
protected void	sendResponseAndWait(int rc, Object response, OpStatsLogger statsLogger)	Write on the channel and wait until the write is completed.
protected void	sendWriteReqResponse(int rc, Object response, OpStatsLogger statsLogger)

Methods inherited from class java.lang.Object

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

Field Details

request

T extends BookieProtocol.Request request

requestHandler

BookieRequestHandler requestHandler

requestProcessor

BookieRequestProcessor requestProcessor

enqueueNanos

long enqueueNanos

Constructor Details

PacketProcessorBase

PacketProcessorBase()

Method Details

init

protected void init(T request,
 BookieRequestHandler requestHandler,
 BookieRequestProcessor requestProcessor)

reset

protected void reset()

isVersionCompatible

protected boolean isVersionCompatible()

sendWriteReqResponse

protected void sendWriteReqResponse(int rc,
 Object response,
 OpStatsLogger statsLogger)

sendReadReqResponse

protected void sendReadReqResponse(int rc,
 Object response,
 OpStatsLogger statsLogger,
 boolean throttle)

sendResponse

protected void sendResponse(int rc,
 Object response,
 OpStatsLogger statsLogger)

sendResponseAndWait

protected void sendResponseAndWait(int rc,
 Object response,
 OpStatsLogger statsLogger)

Write on the channel and wait until the write is completed.

That will make the thread to get blocked until we're able to write everything on the TCP stack, providing auto-throttling and avoiding using too much memory when handling read-requests.

run

public void run()

Specified by:

run in interface Runnable

processPacket

protected abstract void processPacket()