Package org.opendaylight.openflowplugin.applications.frsync.impl.strategy

Class FlowForwarder

java.lang.Object

org.opendaylight.openflowplugin.applications.frsync.impl.strategy.FlowForwarder

All Implemented Interfaces:

ForwardingRulesAddCommitter<Flow,AddFlowOutput>, ForwardingRulesCommitter<Flow,AddFlowOutput,RemoveFlowOutput,UpdateFlowOutput>, ForwardingRulesRemoveCommitter<Flow,RemoveFlowOutput>, ForwardingRulesUpdateCommitter<Flow,UpdateFlowOutput>

public class FlowForwarder
extends Object
implements ForwardingRulesCommitter<Flow,AddFlowOutput,RemoveFlowOutput,UpdateFlowOutput>

Implements ForwardingRulesCommitter methods for processing add, update and remove of Flow.

Constructor Summary

Constructors

Constructor	Description
FlowForwarder(SalFlowService salFlowService)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowOutput>>	add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier, Flow addDataObj, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)	Method adds the DataObject which is identified by InstanceIdentifier to device.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowOutput>>	remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier, Flow removeDataObj, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)	Method removes DataObject which is identified by InstanceIdentifier from device.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UpdateFlowOutput>>	update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier, Flow original, Flow update, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)	Method updates the original DataObject to the update DataObject in device.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowForwarder

public FlowForwarder(SalFlowService salFlowService)

Method Detail

remove

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowOutput>> remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier,
                                                                                                                                     Flow removeDataObj,
                                                                                                                                     org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)

Description copied from interface: ForwardingRulesRemoveCommitter

Method removes DataObject which is identified by InstanceIdentifier from device.

Specified by:

remove in interface ForwardingRulesRemoveCommitter<Flow,RemoveFlowOutput>

Parameters:

identifier - - the whole path to DataObject

removeDataObj - - DataObject for removing

nodeIdent - - Node InstanceIdentifier

Returns:

RpcResult of action

update

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UpdateFlowOutput>> update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier,
                                                                                                                                     Flow original,
                                                                                                                                     Flow update,
                                                                                                                                     org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)

Description copied from interface: ForwardingRulesUpdateCommitter

Method updates the original DataObject to the update DataObject in device. Both are identified by same InstanceIdentifier

Specified by:

update in interface ForwardingRulesUpdateCommitter<Flow,UpdateFlowOutput>

Parameters:

identifier - - the whole path to DataObject

original - - original DataObject (for update)

update - - changed DataObject (contain updates)

nodeIdent - - Node InstanceIdentifier

Returns:

RpcResult of action

add

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowOutput>> add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Flow> identifier,
                                                                                                                               Flow addDataObj,
                                                                                                                               org.opendaylight.yangtools.yang.binding.InstanceIdentifier<FlowCapableNode> nodeIdent)

Description copied from interface: ForwardingRulesAddCommitter

Method adds the DataObject which is identified by InstanceIdentifier to device.

Specified by:

add in interface ForwardingRulesAddCommitter<Flow,AddFlowOutput>

Parameters:

identifier - - the whole path to new DataObject

addDataObj - - new DataObject

nodeIdent - - Node InstanceIdentifier

Returns:

RpcResult of action