Contents
- Description
- Nested Class Summary
- Field Summary
- Constructor Summary
- Method Summary
- Constructor Details
- Method Details
- decode(ChannelHandlerContext, ByteBuf, List)
- requestBytes()
- saslListMechs(BinaryHeader)
- saslAuth(BinaryHeader, byte[], byte[])
- saslStep(BinaryHeader, byte[], byte[])
- acquireHeader()
- handlerAdded(ChannelHandlerContext)
- config(BinaryHeader, byte[])
- response(BinaryHeader, MemcachedStatus)
- response(BinaryHeader, MemcachedStatus, byte[])
- response(BinaryHeader, MemcachedStatus, byte[], byte[])
- response(BinaryHeader, MemcachedStatus, int, byte[], byte[])
- response(BinaryHeader, MemcachedStatus, long)
- response(BinaryHeader, MemcachedStatus, Throwable)
- failedResponse(Header, Throwable)
- send(Header, CompletionStage)
- send(Header, CompletionStage, GenericFutureListener)
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
-
Nested Class Summary
-
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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected MemcachedResponse
config
(BinaryHeader header, byte[] key) void
protected MemcachedResponse
failedResponse
(Header header, Throwable t) void
handlerAdded
(io.netty.channel.ChannelHandlerContext ctx) int
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) send
(Header header, CompletionStage<?> response) 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
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
-
Constructor Details
-
Method Details
-
decode
-
requestBytes
public int requestBytes() -
saslListMechs
-
saslAuth
-
saslStep
-
acquireHeader
-
handlerAdded
- Specified by:
handlerAdded
in interfaceio.netty.channel.ChannelHandler
- Overrides:
handlerAdded
in classMemcachedBaseDecoder
- Throws:
Exception
-
config
-
response
-
response
-
response
-
response
protected void response(BinaryHeader header, MemcachedStatus status, int flags, byte[] key, byte[] value) -
response
-
response
-
failedResponse
- Specified by:
failedResponse
in classMemcachedBaseDecoder
-
send
- Specified by:
send
in classMemcachedBaseDecoder
-
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 classMemcachedBaseDecoder
-