Package org.infinispan.server.memcached.binary

Class BinaryAuthDecoderImpl

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.BinaryAuthDecoderImpl

All Implemented Interfaces:

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

public class BinaryAuthDecoderImpl
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, 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
BinaryAuthDecoderImpl(MemcachedServer server)

Method Summary

Modifier and Type	Method	Description
BinaryHeader	acquireHeader()
protected MemcachedResponse	config(BinaryHeader header, byte[] key)
void	decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf buf, List<Object> out)
protected MemcachedResponse	failedResponse(Header header, Throwable t)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
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)
protected MemcachedResponse	saslAuth(BinaryHeader header, byte[] mech, byte[] data)
protected MemcachedResponse	saslListMechs(BinaryHeader header)
protected MemcachedResponse	saslStep(BinaryHeader header, byte[] mech, byte[] data)
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)

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, 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

BinaryAuthDecoderImpl

public BinaryAuthDecoderImpl(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()

saslListMechs

protected MemcachedResponse saslListMechs(BinaryHeader header)

saslAuth

protected MemcachedResponse saslAuth(BinaryHeader header,
 byte[] mech,
 byte[] data)

saslStep

protected MemcachedResponse saslStep(BinaryHeader header,
 byte[] mech,
 byte[] data)

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