Package org.apache.cassandra.transport

Class Dispatcher.RequestProcessor

java.lang.Object

org.apache.cassandra.transport.Dispatcher.RequestProcessor

All Implemented Interfaces:

java.lang.Runnable, DebuggableTask, DebuggableTask.RunnableDebuggableTask

Enclosing class:

Dispatcher

public class Dispatcher.RequestProcessor
extends java.lang.Object
implements DebuggableTask.RunnableDebuggableTask

It is important to keep this class an instance of DebuggableTask, either runnable or callable since this is the only way we can keep it not wrapped into a callable on SEPExecutor submission path. And we need this functionality for tracking time purposes.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.concurrent.DebuggableTask

DebuggableTask.CallableDebuggableTask<T>, DebuggableTask.RunnableDebuggableTask, DebuggableTask.RunningDebuggableTask

Constructor Summary

Constructors

Constructor	Description
RequestProcessor(io.netty.channel.Channel channel, Message.Request request, org.apache.cassandra.transport.Dispatcher.FlushItemConverter forFlusher, ClientResourceLimits.Overload backpressure)

Method Summary

Modifier and Type	Method	Description
long	creationTimeNanos()
java.lang.String	description()
void	run()
long	startTimeNanos()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.concurrent.DebuggableTask

elapsedSinceCreation

Constructor Detail

RequestProcessor

public RequestProcessor(io.netty.channel.Channel channel,
                        Message.Request request,
                        org.apache.cassandra.transport.Dispatcher.FlushItemConverter forFlusher,
                        ClientResourceLimits.Overload backpressure)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

creationTimeNanos

public long creationTimeNanos()

Specified by:

creationTimeNanos in interface DebuggableTask

startTimeNanos

public long startTimeNanos()

Specified by:

startTimeNanos in interface DebuggableTask

description

public java.lang.String description()

Specified by:

description in interface DebuggableTask

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object