Package 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	Description
protected @GuardedBy("unflushedSegments") org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment	firstSegment
protected int	flushOffset
protected static final AtomicLongFieldUpdater<org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractStackedOutboundQueue>	LAST_XID_OFFSET_UPDATER
protected final org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractOutboundQueueManager<?,?>	manager
protected @GuardedBy("unflushedSegments") Integer	shutdownOffset
protected final @GuardedBy("unflushedSegments") List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment>	uncompletedSegments
protected final @GuardedBy("unflushedSegments") List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment>	unflushedSegments

Method Summary

Modifier and Type	Method	Description
void	commitEntry(org.opendaylight.yangtools.yang.common.Uint32 xid, OfHeader message, com.google.common.util.concurrent.FutureCallback<OfHeader> callback)	Commit the specified offset using a message.
void	commitEntry(org.opendaylight.yangtools.yang.common.Uint32 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)
org.opendaylight.yangtools.yang.common.Uint32	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 Details

LAST_XID_OFFSET_UPDATER

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

firstSegment

protected volatile @GuardedBy("unflushedSegments") org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment firstSegment

unflushedSegments

protected final @GuardedBy("unflushedSegments") List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment> unflushedSegments

uncompletedSegments

protected final @GuardedBy("unflushedSegments") List<org.opendaylight.openflowjava.protocol.impl.core.connection.StackedSegment> uncompletedSegments

shutdownOffset

protected @GuardedBy("unflushedSegments") Integer shutdownOffset

flushOffset

protected int flushOffset

manager

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

Method Details

commitEntry

public void commitEntry(org.opendaylight.yangtools.yang.common.Uint32 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(org.opendaylight.yangtools.yang.common.Uint32 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

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

reserveEntry

public org.opendaylight.yangtools.yang.common.Uint32 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)