Package org.infinispan.server.resp

Class RespRequestHandler

java.lang.Object

org.infinispan.server.resp.RespRequestHandler

Direct Known Subclasses:

CacheRespRequestHandler

public abstract class RespRequestHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final io.netty.util.AttributeKey<ByteBufPool>	BYTE_BUF_POOL_ATTRIBUTE_KEY
protected final CompletionStage<RespRequestHandler>	myStage
protected final RespServer	respServer
protected ResponseWriter	writer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RespRequestHandler(RespServer server)

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<RespRequestHandler>	actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx, RespCommand type, List<byte[]> arguments)	Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.
protected void	commandNotFound()
void	handleChannelDisconnect(io.netty.channel.ChannelHandlerContext ctx)
final CompletionStage<RespRequestHandler>	handleRequest(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, List<byte[]> arguments)
protected void	initializeIfNecessary(io.netty.channel.ChannelHandlerContext ctx)
CompletionStage<RespRequestHandler>	myStage()
RespServer	respServer()
<E> CompletionStage<RespRequestHandler>	stageToReturn(CompletionStage<E> stage, io.netty.channel.ChannelHandlerContext ctx, BiConsumer<? super E,ResponseWriter> biConsumer)
<E> CompletionStage<RespRequestHandler>	stageToReturn(CompletionStage<E> stage, io.netty.channel.ChannelHandlerContext ctx, Function<E,RespRequestHandler> handlerWhenComplete)
CompletionStage<RespRequestHandler>	stageToReturn(CompletionStage<RespRequestHandler> stage, io.netty.channel.ChannelHandlerContext ctx)
ResponseWriter	writer()	Acquire the invalid input: 'in the current context. All responses must be written via this writer. @return A {@link ResponseWriter}.'

Methods inherited from class java.lang.Object

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

Field Details

myStage

protected final CompletionStage<RespRequestHandler> myStage

respServer

protected final RespServer respServer

writer

protected ResponseWriter writer

BYTE_BUF_POOL_ATTRIBUTE_KEY

public static final io.netty.util.AttributeKey<ByteBufPool> BYTE_BUF_POOL_ATTRIBUTE_KEY

Constructor Details

RespRequestHandler

protected RespRequestHandler(RespServer server)

Method Details

initializeIfNecessary

protected void initializeIfNecessary(io.netty.channel.ChannelHandlerContext ctx)

respServer

public RespServer respServer()

myStage

public CompletionStage<RespRequestHandler> myStage()

writer

public ResponseWriter writer()

Acquire the invalid input: 'in the current context. All responses must be written via this writer. @return A {@link ResponseWriter}.'

handleRequest

public final CompletionStage<RespRequestHandler> handleRequest(io.netty.channel.ChannelHandlerContext ctx,
 RespCommand command,
 List<byte[]> arguments)

commandNotFound

protected void commandNotFound()

actualHandleRequest

protected CompletionStage<RespRequestHandler> actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx,
 RespCommand type,
 List<byte[]> arguments)

Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.

Implementations should never use the ByteBufAllocator in the context. Instead, they should use writer to retrieve a ResponseWriter This ByteBuffer should only have bytes written to it adding up to the size requested. The ByteBuffer itself should never be written to the context or channel and flush should also never be invoked. Failure to do so may cause mis-ordering or responses as requests support pipelining and a ByteBuf may not be sent down stream until later in the pipeline.

Parameters:

ctx - Netty context pipeline for this request

type - The command type

arguments - The remaining arguments to the command

Returns:

stage that when complete returns the new handler to instate. This stage must be completed on the event loop

handleChannelDisconnect

public void handleChannelDisconnect(io.netty.channel.ChannelHandlerContext ctx)

stageToReturn

public <E> CompletionStage<RespRequestHandler> stageToReturn(CompletionStage<E> stage,
 io.netty.channel.ChannelHandlerContext ctx,
 BiConsumer<? super E,ResponseWriter> biConsumer)

stageToReturn

public <E> CompletionStage<RespRequestHandler> stageToReturn(CompletionStage<E> stage,
 io.netty.channel.ChannelHandlerContext ctx,
 Function<E,RespRequestHandler> handlerWhenComplete)

stageToReturn

public CompletionStage<RespRequestHandler> stageToReturn(CompletionStage<RespRequestHandler> stage,
 io.netty.channel.ChannelHandlerContext ctx)