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, SendBarrier sendBarrier, 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.

    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, SendBarrier sendBarrier, 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
      sendBarrier - barrier service
      compositeTransform - composite transform
      Returns:
      future holding both results (input and of the barrier)