Package org.opendaylight.openflowplugin.impl.util

Class BarrierUtil

java.lang.Object

org.opendaylight.openflowplugin.impl.util.BarrierUtil

public final class BarrierUtil
extends Object

Provides barrier message chaining and factory methods.

Method Summary

Modifier and Type	Method	Description
static <T> com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<T>>	chainBarrier(com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<T>> input, NodeRef nodeRef, FlowCapableTransactionService transactionService, com.google.common.base.Function<org.apache.commons.lang3.tuple.Pair<org.opendaylight.yangtools.yang.common.RpcResult<T>,org.opendaylight.yangtools.yang.common.RpcResult<SendBarrierOutput>>,org.opendaylight.yangtools.yang.common.RpcResult<T>> compositeTransform)	Chain a barrier message - regardless of previous result and use given Function to combine original result and barrier result.
static SendBarrierInput	createSendBarrierInput(NodeRef nodeRef)	Creates barrier input.

Methods inherited from class java.lang.Object

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

Method Details

chainBarrier

public static <T>
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<T>> chainBarrier(com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<T>> input,
 NodeRef nodeRef,
 FlowCapableTransactionService transactionService,
 com.google.common.base.Function<org.apache.commons.lang3.tuple.Pair<org.opendaylight.yangtools.yang.common.RpcResult<T>,org.opendaylight.yangtools.yang.common.RpcResult<SendBarrierOutput>>,org.opendaylight.yangtools.yang.common.RpcResult<T>> compositeTransform)

Chain a barrier message - regardless of previous result and use given Function to combine original result and barrier result.

Type Parameters:

T - type of input future

Parameters:

input - future to chain barrier to

nodeRef - target device

transactionService - barrier service

compositeTransform - composite transform

Returns:

future holding both results (input and of the barrier)

createSendBarrierInput

public static SendBarrierInput createSendBarrierInput(NodeRef nodeRef)

Creates barrier input.

Parameters:

nodeRef - rpc routing context

Returns:

input for FlowCapableTransactionService.sendBarrier(SendBarrierInput)