Package org.infinispan.server.memcached.text

Class TextOpDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.ByteToMessageDecoder

org.infinispan.server.memcached.MemcachedBaseDecoder

org.infinispan.server.memcached.text.TextOpDecoder

All Implemented Interfaces:

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

Direct Known Subclasses:

TextOpDecoderImpl

public abstract class TextOpDecoder
extends MemcachedBaseDecoder

Since:

15.0

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder

io.netty.handler.codec.ByteToMessageDecoder.Cumulator

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
protected TokenReader	reader

Fields inherited from class org.infinispan.server.memcached.MemcachedBaseDecoder

accessLogging, ANONYMOUS, cache, ctx, current, log, principalName, requestStart, server, statistics, statsEnabled, subject, timeService, versionGenerator

Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TextOpDecoder(MemcachedServer server, Subject subject)

Method Summary

Modifier and Type	Method	Description
protected MemcachedResponse	add(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
protected MemcachedResponse	cas(TextHeader header, byte[] key, byte[] value, int flags, int expiration, long cas, boolean quiet)
protected MemcachedResponse	concat(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet, boolean append)
protected MemcachedResponse	delete(TextHeader header, byte[] key, boolean quiet)
protected MemcachedResponse	failedResponse(Header header, Throwable t)
protected MemcachedResponse	flush_all(TextHeader header, List<byte[]> varargs)
protected MemcachedResponse	gat(TextHeader header, int expiration, List<byte[]> keys, boolean withVersions)
protected MemcachedResponse	get(TextHeader header, List<byte[]> keys, boolean withVersions)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
protected void	handlerRemoved0(io.netty.channel.ChannelHandlerContext ctx)
protected MemcachedResponse	incr(TextHeader header, byte[] key, byte[] delta, boolean quiet, boolean isIncrement)
protected MemcachedResponse	ma(TextHeader header, byte[] key, List<byte[]> args)
protected MemcachedResponse	md(TextHeader header, byte[] key, List<byte[]> args)
protected MemcachedResponse	me(TextHeader header, byte[] key, List<byte[]> args)
protected MemcachedResponse	mg(TextHeader header, byte[] key, List<byte[]> args)
protected MemcachedResponse	mn(TextHeader header)
protected MemcachedResponse	ms(TextHeader header, byte[] key, byte[] value, List<byte[]> args)
protected void	quit(TextHeader header)
protected MemcachedResponse	replace(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
protected MemcachedResponse	send(Header header, CompletionStage<?> response)
protected MemcachedResponse	send(Header header, CompletionStage<?> response, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)
protected MemcachedResponse	set(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
protected MemcachedResponse	stats(TextHeader header, List<byte[]> names)
protected MemcachedResponse	touch(TextHeader header, byte[] key, int expiration, boolean quiet)
protected MemcachedResponse	version(TextHeader header)

Methods inherited from class org.infinispan.server.memcached.MemcachedBaseDecoder

exceptionCaught, metadata, registerExceptionHandler, resumeRead, statsMap, toMillis, touchMetadata

Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder

actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decode, decodeLast, discardSomeReadBytes, handlerRemoved, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Field Details

reader

protected TokenReader reader

Constructor Details

TextOpDecoder

protected TextOpDecoder(MemcachedServer server,
 Subject subject)

Method Details

get

protected MemcachedResponse get(TextHeader header,
 List<byte[]> keys,
 boolean withVersions)

set

protected MemcachedResponse set(TextHeader header,
 byte[] key,
 byte[] value,
 int flags,
 int expiration,
 boolean quiet)

delete

protected MemcachedResponse delete(TextHeader header,
 byte[] key,
 boolean quiet)

concat

protected MemcachedResponse concat(TextHeader header,
 byte[] key,
 byte[] value,
 int flags,
 int expiration,
 boolean quiet,
 boolean append)

replace

protected MemcachedResponse replace(TextHeader header,
 byte[] key,
 byte[] value,
 int flags,
 int expiration,
 boolean quiet)

add

protected MemcachedResponse add(TextHeader header,
 byte[] key,
 byte[] value,
 int flags,
 int expiration,
 boolean quiet)

cas

protected MemcachedResponse cas(TextHeader header,
 byte[] key,
 byte[] value,
 int flags,
 int expiration,
 long cas,
 boolean quiet)

touch

protected MemcachedResponse touch(TextHeader header,
 byte[] key,
 int expiration,
 boolean quiet)

gat

protected MemcachedResponse gat(TextHeader header,
 int expiration,
 List<byte[]> keys,
 boolean withVersions)

md

protected MemcachedResponse md(TextHeader header,
 byte[] key,
 List<byte[]> args)

ma

protected MemcachedResponse ma(TextHeader header,
 byte[] key,
 List<byte[]> args)

me

protected MemcachedResponse me(TextHeader header,
 byte[] key,
 List<byte[]> args)

mn

protected MemcachedResponse mn(TextHeader header)

ms

protected MemcachedResponse ms(TextHeader header,
 byte[] key,
 byte[] value,
 List<byte[]> args)

mg

protected MemcachedResponse mg(TextHeader header,
 byte[] key,
 List<byte[]> args)

flush_all

protected MemcachedResponse flush_all(TextHeader header,
 List<byte[]> varargs)

version

protected MemcachedResponse version(TextHeader header)

quit

protected void quit(TextHeader header)

incr

protected MemcachedResponse incr(TextHeader header,
 byte[] key,
 byte[] delta,
 boolean quiet,
 boolean isIncrement)

stats

protected MemcachedResponse stats(TextHeader header,
 List<byte[]> names)

handlerAdded

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

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class MemcachedBaseDecoder

Throws:

Exception

handlerRemoved0

protected void handlerRemoved0(io.netty.channel.ChannelHandlerContext ctx)
                        throws Exception

Overrides:

handlerRemoved0 in class io.netty.handler.codec.ByteToMessageDecoder

Throws:

Exception

failedResponse

protected MemcachedResponse failedResponse(Header header,
 Throwable t)

Specified by:

failedResponse in class MemcachedBaseDecoder

send

protected MemcachedResponse send(Header header,
 CompletionStage<?> response)

Specified by:

send in class MemcachedBaseDecoder

send

protected MemcachedResponse send(Header header,
 CompletionStage<?> response,
 io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)

Specified by:

send in class MemcachedBaseDecoder