Class FlowUtil


  • public final class FlowUtil
    extends Object
    • Field Detail

      • FLOW_REMOVE_COMPOSING_TRANSFORM

        public static final com.google.common.base.Function<org.apache.commons.lang3.tuple.Pair<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsBatchOutput>,​org.opendaylight.yangtools.yang.common.RpcResult<SendBarrierOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsBatchOutput>> FLOW_REMOVE_COMPOSING_TRANSFORM
        Attach barrier response to given RpcResult<RemoveFlowsBatchOutput>.
      • FLOW_ADD_COMPOSING_TRANSFORM

        public static final com.google.common.base.Function<org.apache.commons.lang3.tuple.Pair<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsBatchOutput>,​org.opendaylight.yangtools.yang.common.RpcResult<SendBarrierOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsBatchOutput>> FLOW_ADD_COMPOSING_TRANSFORM
        Attach barrier response to given RpcResult<AddFlowsBatchOutput>.
      • FLOW_UPDATE_COMPOSING_TRANSFORM

        public static final com.google.common.base.Function<org.apache.commons.lang3.tuple.Pair<org.opendaylight.yangtools.yang.common.RpcResult<UpdateFlowsBatchOutput>,​org.opendaylight.yangtools.yang.common.RpcResult<SendBarrierOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<UpdateFlowsBatchOutput>> FLOW_UPDATE_COMPOSING_TRANSFORM
        Attach barrier response to given RpcResult<UpdateFlowsBatchOutput>.
      • FLOW_REMOVE_TRANSFORM

        public static final com.google.common.base.Function<org.opendaylight.yangtools.yang.common.RpcResult<List<BatchFailedFlowsOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsBatchOutput>> FLOW_REMOVE_TRANSFORM
        Gather errors into collection and wrap it into RpcResult and propagate all RpcError.
      • FLOW_ADD_TRANSFORM

        public static final com.google.common.base.Function<org.opendaylight.yangtools.yang.common.RpcResult<List<BatchFailedFlowsOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsBatchOutput>> FLOW_ADD_TRANSFORM
        Gather errors into collection and wrap it into RpcResult and propagate all RpcError.
      • FLOW_UPDATE_TRANSFORM

        public static final com.google.common.base.Function<org.opendaylight.yangtools.yang.common.RpcResult<List<BatchFailedFlowsOutput>>,​org.opendaylight.yangtools.yang.common.RpcResult<UpdateFlowsBatchOutput>> FLOW_UPDATE_TRANSFORM
        Gather errors into collection and wrap it into RpcResult and propagate all RpcError.
    • Method Detail

      • buildFlowPath

        public static FlowRef buildFlowPath​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Node> nodePath,
                                            org.opendaylight.yangtools.yang.common.Uint8 tableId,
                                            FlowId flowId)
        Build flow path flow ref.
        Parameters:
        nodePath - path to Node
        tableId - path to Table under Node
        flowId - path to Flow under Table
        Returns:
        instance identifier assembled for given node, table and flow
      • createCumulatingFunction

        public static <O> com.google.common.base.Function<List<org.opendaylight.yangtools.yang.common.RpcResult<O>>,​org.opendaylight.yangtools.yang.common.RpcResult<List<BatchFailedFlowsOutput>>> createCumulatingFunction​(Collection<? extends BatchFlowIdGrouping> inputBatchFlows)
        Factory method: creates Function which keeps info of original inputs (passed to flow-rpc) and processes list of all flow-rpc results.
        Type Parameters:
        O - result container type
        Parameters:
        inputBatchFlows - collection of problematic flow-ids wrapped in container of given type <O>
        Returns:
        static reusable function