Class HotRodDecoder

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

    public class HotRodDecoder
    extends io.netty.handler.codec.ByteToMessageDecoder
    • 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected <T> java.util.List<T> allocList​(int size)  
      protected <K,​V>
      java.util.Map<K,​V>
      allocMap​(int size)
      We usually know the size of the map ahead, and we want to return static empty map if we're not going to add anything.
      protected <T> java.util.Set<T> allocSet​(int size)  
      void channelActive​(io.netty.channel.ChannelHandlerContext ctx)  
      void channelWritabilityChanged​(io.netty.channel.ChannelHandlerContext ctx)  
      void decode​(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf buf, java.util.List<java.lang.Object> out)  
      protected int defaultExpiration​(int duration, int flags, ProtocolFlag defaultFlag)  
      void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable t)  
      java.util.concurrent.Executor getExecutor()  
      protected HotRodHeader getHeader()  
      void handlerAdded​(io.netty.channel.ChannelHandlerContext ctx)  
      protected void handlerRemoved0​(io.netty.channel.ChannelHandlerContext ctx)  
      int requestBytes()  
      • Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder

        actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
      • Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

        channelRegistered, channelUnregistered
      • 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 Detail

      • log

        protected static final org.infinispan.server.hotrod.logging.Log log
      • trace

        protected static final boolean trace
      • executor

        protected final java.util.concurrent.Executor executor
      • cacheProcessor

        protected org.infinispan.server.hotrod.TransactionRequestProcessor cacheProcessor
      • counterProcessor

        protected org.infinispan.server.hotrod.CounterRequestProcessor counterProcessor
      • multimapProcessor

        protected org.infinispan.server.hotrod.MultimapRequestProcessor multimapProcessor
    • Method Detail

      • decode

        public void decode​(io.netty.channel.ChannelHandlerContext ctx,
                           io.netty.buffer.ByteBuf buf,
                           java.util.List<java.lang.Object> out)
                    throws java.lang.Exception
        Specified by:
        decode in class io.netty.handler.codec.ByteToMessageDecoder
        Throws:
        java.lang.Exception
      • requestBytes

        public int requestBytes()
      • getExecutor

        public java.util.concurrent.Executor getExecutor()
      • handlerAdded

        public void handlerAdded​(io.netty.channel.ChannelHandlerContext ctx)
        Specified by:
        handlerAdded in interface io.netty.channel.ChannelHandler
        Overrides:
        handlerAdded in class io.netty.channel.ChannelHandlerAdapter
      • handlerRemoved0

        protected void handlerRemoved0​(io.netty.channel.ChannelHandlerContext ctx)
                                throws java.lang.Exception
        Overrides:
        handlerRemoved0 in class io.netty.handler.codec.ByteToMessageDecoder
        Throws:
        java.lang.Exception
      • channelActive

        public void channelActive​(io.netty.channel.ChannelHandlerContext ctx)
                           throws java.lang.Exception
        Specified by:
        channelActive in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelActive in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        java.lang.Exception
      • channelWritabilityChanged

        public void channelWritabilityChanged​(io.netty.channel.ChannelHandlerContext ctx)
                                       throws java.lang.Exception
        Specified by:
        channelWritabilityChanged in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelWritabilityChanged in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        java.lang.Exception
      • exceptionCaught

        public void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx,
                                    java.lang.Throwable t)
                             throws java.lang.Exception
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelHandler
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        java.lang.Exception
      • defaultExpiration

        protected int defaultExpiration​(int duration,
                                        int flags,
                                        ProtocolFlag defaultFlag)
      • allocMap

        protected <K,​V> java.util.Map<K,​V> allocMap​(int size)
        We usually know the size of the map ahead, and we want to return static empty map if we're not going to add anything.
      • allocList

        protected <T> java.util.List<T> allocList​(int size)
      • allocSet

        protected <T> java.util.Set<T> allocSet​(int size)