Package org.opendaylight.openflowjava.protocol.impl.core.connection

Class OutboundQueueManagerNoBarrier<T extends OutboundQueueHandler>

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.opendaylight.openflowjava.protocol.impl.core.connection.OutboundQueueManagerNoBarrier<T>

All Implemented Interfaces:

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

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

Nested Class Summary

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 InetSocketAddress	address
protected final StackedOutboundQueueNoBarrier	currentQueue
protected final Runnable	flushRunnable
protected final ConnectionAdapterImpl	parent
protected boolean	shuttingDown

Method Summary

Modifier and Type	Method	Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
void	channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx)
void	close()
protected void	flush()	Perform a single flush operation.
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
protected StackedOutboundQueueNoBarrier	initializeStackedOutboudnqueue()	Method has to initialize some child of AbstractStackedOutboundQueue.
protected Object	makeMessageListenerWrapper(@NonNull OfHeader msg)	Wraps outgoing message and includes listener attached to this message which is send to OFEncoder for serialization.
String	toString()

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelRegistered, channelUnregistered, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Field Details

parent

protected final ConnectionAdapterImpl parent

address

protected final InetSocketAddress address

currentQueue

protected final StackedOutboundQueueNoBarrier currentQueue

shuttingDown

protected boolean shuttingDown

flushRunnable

protected final Runnable flushRunnable

Method Details

initializeStackedOutboudnqueue

protected StackedOutboundQueueNoBarrier initializeStackedOutboudnqueue()

Method has to initialize some child of AbstractStackedOutboundQueue.

Returns:

correct implementation of StacketOutboundqueue

close

public void close()

Specified by:

close in interface AutoCloseable

toString

public String toString()

Overrides:

toString in class Object

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.