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 and 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, org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.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<Void>>,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(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef nodeRef) Creates barrier input.

Methods inherited from class java.lang.Object

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

Method Detail

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,
                                                                                                                                       org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.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<Void>>,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(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef nodeRef)

Creates barrier input.

Parameters:

nodeRef - rpc routing context

Returns:

input for FlowCapableTransactionService.sendBarrier(SendBarrierInput)