Class BinaryOpDecoderImpl

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.binary.BinaryOpDecoderImpl

All Implemented Interfaces:

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

public class BinaryOpDecoderImpl
extends MemcachedBaseDecoder

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 inherited from class org.infinispan.server.memcached.MemcachedBaseDecoder

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

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

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

Constructor Summary

Constructors

Constructor	Description
BinaryOpDecoderImpl(MemcachedServer server)
BinaryOpDecoderImpl(MemcachedServer server, Subject subject)

Method Summary

Modifier and Type	Method	Description
BinaryHeader	acquireHeader()
protected MemcachedResponse	add(BinaryHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
protected MemcachedResponse	append(BinaryHeader header, byte[] key, byte[] value, boolean quiet)
protected MemcachedResponse	config(BinaryHeader header, byte[] key)
void	decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf buf, List<Object> out)
protected MemcachedResponse	delete(BinaryHeader header, byte[] key, boolean quiet)
protected MemcachedResponse	failedResponse(Header header, Throwable t)
protected MemcachedResponse	flush(BinaryHeader header, int expiration, boolean quiet)
protected MemcachedResponse	gat(BinaryHeader header, byte[] key, int expiration, boolean quiet)
protected MemcachedResponse	get(BinaryHeader header, byte[] key, boolean quiet)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
protected MemcachedResponse	increment(BinaryHeader header, byte[] key, long delta, long initial, int expiration, boolean quiet)
protected MemcachedResponse	noop(BinaryHeader header)
protected MemcachedResponse	prepend(BinaryHeader header, byte[] key, byte[] value, boolean quiet)
protected MemcachedResponse	quit(BinaryHeader header, boolean quiet)
protected MemcachedResponse	replace(BinaryHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
int	requestBytes()
protected void	response(BinaryHeader header, MemcachedStatus status)
protected void	response(BinaryHeader header, MemcachedStatus status, byte[] value)
protected void	response(BinaryHeader header, MemcachedStatus status, byte[] key, byte[] value)
protected void	response(BinaryHeader header, MemcachedStatus status, int flags, byte[] key, byte[] value)
protected void	response(BinaryHeader header, MemcachedStatus status, long number)
protected void	response(BinaryHeader header, MemcachedStatus status, Throwable t)
MemcachedResponse	send(Header header, CompletionStage<?> response)
MemcachedResponse	send(Header header, CompletionStage<?> response, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)
protected MemcachedResponse	set(BinaryHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet)
protected MemcachedResponse	stat(BinaryHeader header, byte[] key)
protected MemcachedResponse	touch(BinaryHeader header, byte[] key, int expiration)
protected MemcachedResponse	verbosityLevel(BinaryHeader header, int verbosity)
protected MemcachedResponse	version(BinaryHeader header)

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

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

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

actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, 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

Constructor Details

BinaryOpDecoderImpl

public BinaryOpDecoderImpl(MemcachedServer server,
 Subject subject)

BinaryOpDecoderImpl

public BinaryOpDecoderImpl(MemcachedServer server)

Method Details

decode

public void decode(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.buffer.ByteBuf buf,
 List<Object> out)
            throws Exception

Specified by:

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

Throws:

Exception

requestBytes

public int requestBytes()

get

protected MemcachedResponse get(BinaryHeader header,
 byte[] key,
 boolean quiet)

set

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

add

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

replace

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

delete

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

increment

protected MemcachedResponse increment(BinaryHeader header,
 byte[] key,
 long delta,
 long initial,
 int expiration,
 boolean quiet)

append

protected MemcachedResponse append(BinaryHeader header,
 byte[] key,
 byte[] value,
 boolean quiet)

prepend

protected MemcachedResponse prepend(BinaryHeader header,
 byte[] key,
 byte[] value,
 boolean quiet)

quit

protected MemcachedResponse quit(BinaryHeader header,
 boolean quiet)

version

protected MemcachedResponse version(BinaryHeader header)

noop

protected MemcachedResponse noop(BinaryHeader header)

touch

protected MemcachedResponse touch(BinaryHeader header,
 byte[] key,
 int expiration)

gat

protected MemcachedResponse gat(BinaryHeader header,
 byte[] key,
 int expiration,
 boolean quiet)

stat

protected MemcachedResponse stat(BinaryHeader header,
 byte[] key)

flush

protected MemcachedResponse flush(BinaryHeader header,
 int expiration,
 boolean quiet)

verbosityLevel

protected MemcachedResponse verbosityLevel(BinaryHeader header,
 int verbosity)

acquireHeader

public BinaryHeader acquireHeader()

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

config

protected MemcachedResponse config(BinaryHeader header,
 byte[] key)

response

protected void response(BinaryHeader header,
 MemcachedStatus status)

response

protected void response(BinaryHeader header,
 MemcachedStatus status,
 byte[] value)

response

protected void response(BinaryHeader header,
 MemcachedStatus status,
 byte[] key,
 byte[] value)

response

protected void response(BinaryHeader header,
 MemcachedStatus status,
 int flags,
 byte[] key,
 byte[] value)

response

protected void response(BinaryHeader header,
 MemcachedStatus status,
 long number)

response

protected void response(BinaryHeader header,
 MemcachedStatus status,
 Throwable t)

failedResponse

protected MemcachedResponse failedResponse(Header header,
 Throwable t)

Specified by:

failedResponse in class MemcachedBaseDecoder

send

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

Specified by:

send in class MemcachedBaseDecoder

send

public 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