org.opendaylight.openflowplugin.applications.bulk.o.matic

Class SalBulkFlowServiceImpl

java.lang.Object

org.opendaylight.openflowplugin.applications.bulk.o.matic.SalBulkFlowServiceImpl

All Implemented Interfaces:

SalBulkFlowService, org.opendaylight.yangtools.yang.binding.RpcService

public class SalBulkFlowServiceImpl
extends Object
implements SalBulkFlowService

Simple implementation providing bulk flows operations.

Constructor Summary

Constructors

Constructor and Description
SalBulkFlowServiceImpl(SalFlowService flowService, org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsDsOutput>>	addFlowsDs(AddFlowsDsInput input) Adding multiple flows to openflow device via dataStore.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsRpcOutput>>	addFlowsRpc(AddFlowsRpcInput input) Adding multiple flows to openflow device via direct rpc invocation.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddMultipleOutput>>	flowRpcAddMultiple(FlowRpcAddMultipleInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddTestOutput>>	flowRpcAddTest(FlowRpcAddTestInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowTestOutput>>	flowTest(FlowTestInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReadFlowTestOutput>>	readFlowTest(ReadFlowTestInput input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterOutput>>	register(RegisterInput input) register mbean etc.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsDsOutput>>	removeFlowsDs(RemoveFlowsDsInput input) Removing multiple flows from openflow device via dataStore.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsRpcOutput>>	removeFlowsRpc(RemoveFlowsRpcInput input) Removing multiple flows from openflow device via direct rpc invocation.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<TableTestOutput>>	tableTest(TableTestInput input)

Methods inherited from class java.lang.Object

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

Constructor Detail

SalBulkFlowServiceImpl

public SalBulkFlowServiceImpl(SalFlowService flowService,
                              org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)

Method Detail

addFlowsDs

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsDsOutput>> addFlowsDs(AddFlowsDsInput input)

Description copied from interface: SalBulkFlowService

Adding multiple flows to openflow device via dataStore.

Specified by:

addFlowsDs in interface SalBulkFlowService

removeFlowsDs

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsDsOutput>> removeFlowsDs(RemoveFlowsDsInput input)

Description copied from interface: SalBulkFlowService

Removing multiple flows from openflow device via dataStore.

Specified by:

removeFlowsDs in interface SalBulkFlowService

addFlowsRpc

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsRpcOutput>> addFlowsRpc(AddFlowsRpcInput input)

Description copied from interface: SalBulkFlowService

Adding multiple flows to openflow device via direct rpc invocation.

Specified by:

addFlowsRpc in interface SalBulkFlowService

readFlowTest

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReadFlowTestOutput>> readFlowTest(ReadFlowTestInput input)

Specified by:

readFlowTest in interface SalBulkFlowService

flowRpcAddTest

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddTestOutput>> flowRpcAddTest(FlowRpcAddTestInput input)

Specified by:

flowRpcAddTest in interface SalBulkFlowService

register

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterOutput>> register(RegisterInput input)

Description copied from interface: SalBulkFlowService

register mbean etc. via rpc invocation.

Specified by:

register in interface SalBulkFlowService

removeFlowsRpc

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsRpcOutput>> removeFlowsRpc(RemoveFlowsRpcInput input)

Description copied from interface: SalBulkFlowService

Removing multiple flows from openflow device via direct rpc invocation.

Specified by:

removeFlowsRpc in interface SalBulkFlowService

flowTest

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowTestOutput>> flowTest(FlowTestInput input)

Specified by:

flowTest in interface SalBulkFlowService

tableTest

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<TableTestOutput>> tableTest(TableTestInput input)

Specified by:

tableTest in interface SalBulkFlowService

flowRpcAddMultiple

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddMultipleOutput>> flowRpcAddMultiple(FlowRpcAddMultipleInput input)

Specified by:

flowRpcAddMultiple in interface SalBulkFlowService