org.opendaylight.openflowplugin.impl.services.batch

Class FlatBatchFlowAdapters

java.lang.Object

org.opendaylight.openflowplugin.impl.services.batch.FlatBatchFlowAdapters

public final class FlatBatchFlowAdapters
extends Object

Transform between FlatBatch API and flow batch API.

Method Summary

Modifier and Type	Method and Description
static AddFlowsBatchInput	adaptFlatBatchAddFlow(BatchPlanStep planStep, org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node) Adapt flat batch add flow.
static RemoveFlowsBatchInput	adaptFlatBatchRemoveFlow(BatchPlanStep planStep, org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node) Adapt flat batch remove flow.
static UpdateFlowsBatchInput	adaptFlatBatchUpdateFlow(BatchPlanStep planStep, org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node) Adapt flat batch update flow.
static <T extends BatchFlowOutputListGrouping> com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>>	convertFlowBatchFutureForChain(Future<org.opendaylight.yangtools.yang.common.RpcResult<T>> resultUpdateFlowFuture, int currentOffset) Shortcut for convertBatchFlowResult(int) with conversion ListenableFuture.

Methods inherited from class java.lang.Object

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

Method Detail

adaptFlatBatchAddFlow

public static AddFlowsBatchInput adaptFlatBatchAddFlow(BatchPlanStep planStep,
                                                       org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node)

Adapt flat batch add flow.

Parameters:

planStep - batch step containing changes of the same type

node - pointer for RPC routing

Returns:

input suitable for .opendaylight.flows.service.rev160314.SalFlowsBatchService#addFlowsBatch(AddFlowsBatchInput)

adaptFlatBatchRemoveFlow

public static RemoveFlowsBatchInput adaptFlatBatchRemoveFlow(BatchPlanStep planStep,
                                                             org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node)

Adapt flat batch remove flow.

Parameters:

planStep - batch step containing changes of the same type

node - pointer for RPC routing

Returns:

input suitable for .opendaylight.flows.service.rev160314.SalFlowsBatchService#removeFlowsBatch(RemoveFlowsBatchInput)

adaptFlatBatchUpdateFlow

public static UpdateFlowsBatchInput adaptFlatBatchUpdateFlow(BatchPlanStep planStep,
                                                             org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node)

Adapt flat batch update flow.

Parameters:

planStep - batch step containing changes of the same type

node - pointer for RPC routing

Returns:

input suitable for .opendaylight.flows.service.rev160314.SalFlowsBatchService#updateFlowsBatch(UpdateFlowsBatchInput)

convertFlowBatchFutureForChain

public static <T extends BatchFlowOutputListGrouping> com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>> convertFlowBatchFutureForChain(Future<org.opendaylight.yangtools.yang.common.RpcResult<T>> resultUpdateFlowFuture,
                                                                                                                                                                                                                  int currentOffset)

Shortcut for convertBatchFlowResult(int) with conversion ListenableFuture.

Type Parameters:

T - exact type of batch flow output

Parameters:

resultUpdateFlowFuture - batch flow rpc-result (add/remove/update)

currentOffset - offset of current batch plan step with respect to entire chain of steps

Returns:

ListenableFuture with converted result ProcessFlatBatchOutput