Class OutboundQueueManagerNoBarrier<T extends OutboundQueueHandler>

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

    public class OutboundQueueManagerNoBarrier<T extends OutboundQueueHandler>
    extends io.netty.channel.ChannelInboundHandlerAdapter
    • Field Detail

      • currentQueue

        protected final O extends org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractStackedOutboundQueue currentQueue
      • shuttingDown

        protected boolean shuttingDown
      • flushRunnable

        protected final Runnable flushRunnable
    • Method Detail

      • initializeStackedOutboudnqueue

        protected StackedOutboundQueueNoBarrier initializeStackedOutboudnqueue()
        Method has to initialize some child of AbstractStackedOutboundQueue.
        Returns:
        correct implementation of StacketOutboundqueue
      • 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
      • 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
      • channelReadComplete

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

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

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

        public void channelRead​(io.netty.channel.ChannelHandlerContext ctx,
                                Object msg)
                         throws Exception
        Specified by:
        channelRead in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelRead in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        Exception
      • makeMessageListenerWrapper

        protected Object makeMessageListenerWrapper​(@NonNull OfHeader msg)
        Wraps outgoing message and includes listener attached to this message which is send to OFEncoder for serialization. Correct wrapper is selected by communication pipeline.
      • flush

        protected void flush()
        Perform a single flush operation. We keep it here so we do not generate syntetic accessors for private fields. Otherwise it could be moved into flushRunnable.