Package 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	Description
SalBulkFlowServiceImpl(SalFlowService flowService, org.opendaylight.mdsal.binding.api.DataBroker dataBroker)

Method Summary

Modifier and Type	Method	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.mdsal.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