org.openspaces.memcached.protocol

Class MemcachedCommandHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.openspaces.memcached.protocol.MemcachedCommandHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

@ChannelHandler.Sharable
public final class MemcachedCommandHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

The actual command handler, which is responsible for processing the CommandMessage instances that are inbound from the protocol decoders.

One instance is shared among the entire pipeline, since this handler is stateless, apart from some globals for the entire daemon.

The command handler produces ResponseMessages which are destined for the response encoder.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
AtomicInteger	curr_conns
int	idle_limit
protected static org.apache.commons.logging.Log	logger
AtomicInteger	total_conns
boolean	verbose
String	version The following state variables are universal for the entire daemon.

Constructor Summary

Constructors

Constructor and Description
MemcachedCommandHandler(SpaceCache cache, String memcachedVersion, boolean verbosity, int idle) Construct the server session handler

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx) On open we manage some statistics, and add this connection to the channel group.
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx) On close we manage some statistics, and remove this connection from the channel group.
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) The actual meat of the matter.
protected void	handleAdd(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleAppend(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleCas(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleDecr(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleDelete(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleFlush(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleGets(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleIncr(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleNoOp(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handlePrepend(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleQuit(io.netty.channel.Channel channel)
protected void	handleReplace(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleSet(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleStats(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command, int cmdKeysSize)
protected void	handleVerbosity(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)
protected void	handleVersion(io.netty.channel.ChannelHandlerContext ctx, CommandMessage command)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Detail

logger

protected static final org.apache.commons.logging.Log logger

curr_conns

public final AtomicInteger curr_conns

total_conns

public final AtomicInteger total_conns

version

public final String version

The following state variables are universal for the entire daemon. These are used for statistics gathering. In order for these values to work properly, the handler _must_ be declared with a ChannelPipelineCoverage of "all".

idle_limit

public final int idle_limit

verbose

public final boolean verbose

Constructor Detail

MemcachedCommandHandler

public MemcachedCommandHandler(SpaceCache cache,
                               String memcachedVersion,
                               boolean verbosity,
                               int idle)

Construct the server session handler

Parameters:

cache - the cache to use

memcachedVersion - the version string to return to clients

verbosity - verbosity level for debugging

idle - how long sessions can be idle for

Method Detail

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

On open we manage some statistics, and add this connection to the channel group.

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
                     throws Exception

On close we manage some statistics, and remove this connection from the channel group.

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

The actual meat of the matter. Turn CommandMessages into executions against the physical cache, and then pass on the downstream messages.

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

handleNoOp

protected void handleNoOp(io.netty.channel.ChannelHandlerContext ctx,
                          CommandMessage command)

handleFlush

protected void handleFlush(io.netty.channel.ChannelHandlerContext ctx,
                           CommandMessage command)

handleVerbosity

protected void handleVerbosity(io.netty.channel.ChannelHandlerContext ctx,
                               CommandMessage command)

handleQuit

protected void handleQuit(io.netty.channel.Channel channel)

handleVersion

protected void handleVersion(io.netty.channel.ChannelHandlerContext ctx,
                             CommandMessage command)

handleStats

protected void handleStats(io.netty.channel.ChannelHandlerContext ctx,
                           CommandMessage command,
                           int cmdKeysSize)

handleDelete

protected void handleDelete(io.netty.channel.ChannelHandlerContext ctx,
                            CommandMessage command)

handleDecr

protected void handleDecr(io.netty.channel.ChannelHandlerContext ctx,
                          CommandMessage command)

handleIncr

protected void handleIncr(io.netty.channel.ChannelHandlerContext ctx,
                          CommandMessage command)

handlePrepend

protected void handlePrepend(io.netty.channel.ChannelHandlerContext ctx,
                             CommandMessage command)

handleAppend

protected void handleAppend(io.netty.channel.ChannelHandlerContext ctx,
                            CommandMessage command)

handleReplace

protected void handleReplace(io.netty.channel.ChannelHandlerContext ctx,
                             CommandMessage command)

handleAdd

protected void handleAdd(io.netty.channel.ChannelHandlerContext ctx,
                         CommandMessage command)

handleCas

protected void handleCas(io.netty.channel.ChannelHandlerContext ctx,
                         CommandMessage command)

handleSet

protected void handleSet(io.netty.channel.ChannelHandlerContext ctx,
                         CommandMessage command)

handleGets

protected void handleGets(io.netty.channel.ChannelHandlerContext ctx,
                          CommandMessage command)