Class MemcachedBaseDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.ByteToMessageDecoder

org.infinispan.server.core.transport.RequestLimitDecoder

org.infinispan.server.memcached.MemcachedBaseDecoder

All Implemented Interfaces:

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

Direct Known Subclasses:

BinaryAuthDecoderImpl, BinaryOpDecoderImpl, TextAuthDecoder, TextOpDecoder

public abstract class MemcachedBaseDecoder
extends RequestLimitDecoder

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 final boolean	accessLogging
protected static final Subject	ANONYMOUS
protected AdvancedCache<byte[],byte[]>	cache
protected boolean	closing
protected io.netty.channel.ChannelHandlerContext	ctx
protected final ByRef<MemcachedResponse>	current
protected static final org.infinispan.server.core.logging.Log	log
protected final String	principalName
protected Temporal	requestStart
protected final MemcachedServer	server
protected MemcachedStats	statistics
protected boolean	statsEnabled
protected final Subject	subject
protected TimeService	timeService
protected VersionGenerator	versionGenerator

Fields inherited from class RequestLimitDecoder

maxContentLength

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

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected final void	assertCacheIsReady()
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
protected abstract AdvancedCache<byte[],byte[]>	createCache(MemcachedServer server)
protected final void	exceptionCaught(org.infinispan.server.memcached.logging.Header header, Throwable t)
protected abstract MemcachedResponse	failedResponse(org.infinispan.server.memcached.logging.Header header, Throwable t)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
protected Metadata	metadata(int flags, int expiration)
void	registerExceptionHandler(BiConsumer<io.netty.channel.ChannelHandlerContext, MemcachedResponse> handler)
void	resumeRead()
protected abstract MemcachedResponse	send(org.infinispan.server.memcached.logging.Header header, CompletionStage<?> response)
protected abstract MemcachedResponse	send(org.infinispan.server.memcached.logging.Header header, CompletionStage<?> response, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)
protected Map<WrappedByteArray, byte[]>	statsMap()
protected long	toMillis(int lifespan)
protected Metadata	touchMetadata(CacheEntry<?,?> entry, int expiration)
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

Methods inherited from class RequestLimitDecoder

bytesAvailable, callDecode, currentRequestBytes, maxContentLength, startRequest

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

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

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class Object

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

Field Details

ANONYMOUS

protected static final Subject ANONYMOUS

log

protected static final org.infinispan.server.core.logging.Log log

server

protected final MemcachedServer server

statistics

protected MemcachedStats statistics

statsEnabled

protected boolean statsEnabled

accessLogging

protected final boolean accessLogging

requestStart

protected Temporal requestStart

ctx

protected io.netty.channel.ChannelHandlerContext ctx

timeService

protected TimeService timeService

versionGenerator

protected VersionGenerator versionGenerator

cache

protected AdvancedCache<byte[],byte[]> cache

subject

protected final Subject subject

principalName

protected final String principalName

current

protected final ByRef<MemcachedResponse> current

closing

protected boolean closing

Constructor Details

MemcachedBaseDecoder

protected MemcachedBaseDecoder(MemcachedServer server,
 Subject subject)

Method Details

assertCacheIsReady

protected final void assertCacheIsReady()

registerExceptionHandler

public void registerExceptionHandler(BiConsumer<io.netty.channel.ChannelHandlerContext, MemcachedResponse> handler)

exceptionCaught

protected final void exceptionCaught(org.infinispan.server.memcached.logging.Header header,
 Throwable t)

createCache

protected abstract AdvancedCache<byte[],byte[]> createCache(MemcachedServer server)

handlerAdded

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

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
 Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Overrides:

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

Throws:

Exception

channelActive

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

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

resumeRead

public void resumeRead()

failedResponse

protected abstract MemcachedResponse failedResponse(org.infinispan.server.memcached.logging.Header header,
 Throwable t)

send

protected abstract MemcachedResponse send(org.infinispan.server.memcached.logging.Header header,
 CompletionStage<?> response)

send

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

statsMap

protected Map<WrappedByteArray, byte[]> statsMap()

touchMetadata

protected Metadata touchMetadata(CacheEntry<?,?> entry,
 int expiration)

toMillis

protected long toMillis(int lifespan)

metadata

protected Metadata metadata(int flags,
 int expiration)