Package org.opendaylight.openflowplugin.impl.util

Class FlowUtil

java.lang.Object

org.opendaylight.openflowplugin.impl.util.FlowUtil

public final class FlowUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static 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>.
static 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.
static 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>.
static 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.
static 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>.
static 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 Summary

Modifier and Type	Method	Description
static FlowRef	buildFlowPath(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node> nodePath, org.opendaylight.yangtools.yang.common.Uint8 tableId, FlowId flowId)	Build flow path flow ref.
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.

Methods inherited from class java.lang.Object

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

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<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.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