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

Class StackedOutboundQueueNoBarrier

java.lang.Object

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

All Implemented Interfaces:

OutboundQueue

public class StackedOutboundQueueNoBarrier
extends Object

Class is designed for stacking Statistics and propagate immediate response for all another requests.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment	firstSegment
protected int	flushOffset
protected static AtomicLongFieldUpdater<org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractStackedOutboundQueue>	LAST_XID_OFFSET_UPDATER
protected org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractOutboundQueueManager<?,?>	manager
protected Integer	shutdownOffset
protected List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment>	uncompletedSegments
protected List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment>	unflushedSegments

Method Summary

Modifier and Type	Method and Description
void	commitEntry(Long xid, OfHeader message, com.google.common.util.concurrent.FutureCallback<OfHeader> callback) Commit the specified offset using a message.
void	commitEntry(Long xid, OfHeader message, com.google.common.util.concurrent.FutureCallback<OfHeader> callback, Function<OfHeader,Boolean> isCompletedFunction) Commit the specified offset using a message.
protected void	ensureSegment(org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment first, int offset)
protected org.opendaylight.openflowjava.protocol.impl.core.connection.OutboundQueueEntry	getEntry(Long xid)
Long	reserveEntry() Reserve an entry in the outbound queue.

Methods inherited from class java.lang.Object

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

Field Detail

LAST_XID_OFFSET_UPDATER

protected static final AtomicLongFieldUpdater<org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractStackedOutboundQueue> LAST_XID_OFFSET_UPDATER

firstSegment

protected volatile org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment firstSegment

unflushedSegments

protected final List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment> unflushedSegments

uncompletedSegments

protected final List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment> uncompletedSegments

shutdownOffset

protected Integer shutdownOffset

flushOffset

protected int flushOffset

manager

protected final org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractOutboundQueueManager<?,?> manager

Method Detail

commitEntry

public void commitEntry(Long xid,
                        OfHeader message,
                        com.google.common.util.concurrent.FutureCallback<OfHeader> callback,
                        Function<OfHeader,Boolean> isCompletedFunction)

Description copied from interface: OutboundQueue

Commit the specified offset using a message. Specified callback will be invoked once we know how it has resolved, either with a normal response, implied completion via a barrier, or failure (such as connection drop). For multipart responses, FutureCallback.onSuccess(Object) will be invoked multiple times as the corresponding responses arrive. If the request is completed with a response, the object reported will be non-null. If the request's completion is implied by a barrier, the object reported will be null.

If this request fails on the remote device, FutureCallback.onFailure(Throwable) will be called with an instance of DeviceRequestFailedException.

If the request fails due to local reasons, FutureCallback.onFailure(Throwable) will be called with an instance of OutboundQueueException. In particular, if this request failed because the device disconnected, OutboundQueueException.DEVICE_DISCONNECTED will be reported.

Parameters:

xid - Previously-reserved XID

message - Message which should be sent out, or null if the reservation should be cancelled.

callback - Callback to be invoked, or null if no callback should be invoked.

isCompletedFunction - Function to determine if OfHeader is processing is complete

commitEntry

public void commitEntry(Long xid,
                        OfHeader message,
                        com.google.common.util.concurrent.FutureCallback<OfHeader> callback)

Description copied from interface: OutboundQueue

Commit the specified offset using a message. Specified callback will be invoked once we know how it has resolved, either with a normal response, implied completion via a barrier, or failure (such as connection drop). For multipart responses, FutureCallback.onSuccess(Object) will be invoked multiple times as the corresponding responses arrive. If the request is completed with a response, the object reported will be non-null. If the request's completion is implied by a barrier, the object reported will be null.

If this request fails on the remote device, FutureCallback.onFailure(Throwable) will be called with an instance of DeviceRequestFailedException.

If the request fails due to local reasons, FutureCallback.onFailure(Throwable) will be called with an instance of OutboundQueueException. In particular, if this request failed because the device disconnected, OutboundQueueException.DEVICE_DISCONNECTED will be reported.

Specified by:

commitEntry in interface OutboundQueue

Parameters:

xid - Previously-reserved XID

message - Message which should be sent out, or null if the reservation should be cancelled.

callback - Callback to be invoked, or null if no callback should be invoked.

ensureSegment

protected void ensureSegment(org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment first,
                             int offset)

reserveEntry

public Long reserveEntry()

Description copied from interface: OutboundQueue

Reserve an entry in the outbound queue.

Specified by:

reserveEntry in interface OutboundQueue

Returns:

XID for the new message, or null if the queue is full

getEntry

protected org.opendaylight.openflowjava.protocol.impl.core.connection.OutboundQueueEntry getEntry(Long xid)