org.opendaylight.genius.mdsalutil.internal

Class MDSALManager

java.lang.Object

org.opendaylight.infrautils.inject.AbstractLifecycle

org.opendaylight.genius.mdsalutil.internal.MDSALManager

All Implemented Interfaces:

IMdsalApiManager, org.opendaylight.infrautils.inject.Lifecycle

@Singleton
public class MDSALManager
extends org.opendaylight.infrautils.inject.AbstractLifecycle
implements IMdsalApiManager

Constructor Summary

Constructors

Constructor and Description
MDSALManager(org.opendaylight.controller.md.sal.binding.api.DataBroker db, org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService pktProcService) Writes the flows and Groups to the MD SAL DataStore which will be sent to the openflowplugin for installing flows/groups on the switch.

Method Summary

Modifier and Type	Method and Description
void	addBucket(BigInteger dpId, long groupId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket bucket, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	addBucketToTx(BigInteger dpId, long groupId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket bucket, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	addFlowToTx(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Add a Flow to batched transaction This is used to batch multiple ConfigDS changes in a single transaction and programming on specific DPN.
void	addFlowToTx(FlowEntity flowEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Add a Flow to batched transaction.
void	addGroupToTx(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Add a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction and programming on specific DPN.
void	addGroupToTx(GroupEntity groupEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Add a Group using batched transaction.
void	batchedAddFlow(BigInteger dpId, FlowEntity flowEntity)
void	batchedAddFlowInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)
void	batchedRemoveFlow(BigInteger dpId, FlowEntity flowEntity)
void	batchedRemoveFlowInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)
protected org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node	buildDpnNode(BigInteger dpnId)
void	deleteBucket(BigInteger dpId, long groupId, long bucketId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	deleteFlowEntityInternal(FlowEntity flowEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	deleteFlowInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
boolean	flowExists(BigInteger dpId, short tableId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey flowKey)
protected static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef	getNodeConnRef(String nodeId, String port)
boolean	groupExists(BigInteger dpId, long groupId) Check if OF group exist on DPN.
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installFlow(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installFlow(BigInteger dpId, FlowEntity flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installFlow(FlowEntity flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installFlowInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installFlowInternal(FlowEntity flowEntity)
void	installGroup(GroupEntity groupEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	installGroupInternal(GroupEntity groupEntity)
void	modifyGroup(GroupEntity groupEntity)
void	modifyGroupInternal(GroupEntity groupEntity)
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>	nodeToInstanceId(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node node)
void	removeBucketToTx(BigInteger dpId, long groupId, long bucketId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeFlow(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeFlow(BigInteger dpId, FlowEntity flowEntity)
com.google.common.util.concurrent.ListenableFuture<Void>	removeFlow(BigInteger dpId, short tableId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId flowId)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeFlow(FlowEntity flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeFlowInternal(FlowEntity flowEntity)
com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeFlowNewInternal(BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)
void	removeFlowToTx(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Remove a Flow using batched transaction.
void	removeFlowToTx(FlowEntity flowEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Remove a Flow using batched transaction.
void	removeGroup(BigInteger dpnId, long groupId) Remove a group.
void	removeGroup(BigInteger dpnId, long groupId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Remove a group, using an existing transaction.
void	removeGroup(GroupEntity groupEntity) Remove a group.
protected com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException>	removeGroupInternal(BigInteger dpnId, long groupId)
void	removeGroupInternal(BigInteger dpnId, long groupId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	removeGroupToTx(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Remove a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction.
void	removeGroupToTx(GroupEntity groupEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx) Remove a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction.
void	sendARPPacketOutWithActions(BigInteger dpnId, byte[] payload, List<ActionInfo> actionInfo)
void	sendARPPacketOutWithActionsInternal(BigInteger dpnId, byte[] payload, List<ActionInfo> actions)
void	sendPacketOut(BigInteger dpnId, int groupId, byte[] payload)
void	sendPacketOutInternal(BigInteger dpnId, int groupId, byte[] payload)
void	sendPacketOutWithActions(BigInteger dpnId, byte[] payload, List<ActionInfo> actionInfos)
void	sendPacketOutWithActions(BigInteger dpnId, long groupId, byte[] payload, List<ActionInfo> actionInfos) Send packet out with actions.
void	sendPacketOutWithActionsInternal(BigInteger dpnId, byte[] payload, List<ActionInfo> actionInfos)
protected void	start()
protected void	stop()
void	syncInstallFlow(FlowEntity flowEntity)
void	syncInstallFlow(FlowEntity flowEntity, long delayTime) Install a flow.
void	syncInstallGroup(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group)
void	syncInstallGroup(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group, long delayTime) Install a group.
void	syncInstallGroup(GroupEntity groupEntity)
void	syncInstallGroup(GroupEntity groupEntity, long delayTime) API to install the Group on Data Plane Node synchronously.
void	syncRemoveFlow(FlowEntity flowEntity)
void	syncRemoveFlow(FlowEntity flowEntity, long delayTime) API to remove the flow on Data Plane Node synchronously.
void	syncRemoveGroup(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group)
void	syncRemoveGroup(GroupEntity groupEntity) API to remove the Group on Data Plane Node synchronously.
void	syncSetUpFlowInternal(FlowEntity flowEntity, boolean isRemove)
void	syncSetUpGroupInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group, boolean isRemove)
void	syncSetUpGroupInternal(GroupEntity groupEntity, boolean isRemove)
void	writeFlowEntityInternal(FlowEntity flowEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	writeFlowInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	writeGroupEntityInternal(GroupEntity groupEntity, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	writeGroupInternal(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Methods inherited from class org.opendaylight.infrautils.inject.AbstractLifecycle

destroy, init, isRunning

Methods inherited from class java.lang.Object

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

Constructor Detail

MDSALManager

@Inject
public MDSALManager(org.opendaylight.controller.md.sal.binding.api.DataBroker db,
                            org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService pktProcService)

Writes the flows and Groups to the MD SAL DataStore which will be sent to the openflowplugin for installing flows/groups on the switch. Other modules of VPN service that wants to install flows / groups on the switch uses this utility

Parameters:

db - dataBroker reference

pktProcService - PacketProcessingService for sending the packet outs

Method Detail

start

protected void start()
              throws Exception

Specified by:

start in class org.opendaylight.infrautils.inject.AbstractLifecycle

Throws:

Exception

stop

protected void stop()
             throws Exception

Specified by:

stop in class org.opendaylight.infrautils.inject.AbstractLifecycle

Throws:

Exception

installFlowInternal

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installFlowInternal(FlowEntity flowEntity)

installFlowInternal

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installFlowInternal(BigInteger dpId,
                                                                                                                                                                     org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)

writeFlowEntityInternal

public void writeFlowEntityInternal(FlowEntity flowEntity,
                                    org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

writeFlowInternal

public void writeFlowInternal(BigInteger dpId,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow,
                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

batchedAddFlowInternal

public void batchedAddFlowInternal(BigInteger dpId,
                                   org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)

batchedRemoveFlowInternal

public void batchedRemoveFlowInternal(BigInteger dpId,
                                      org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow)

installGroupInternal

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installGroupInternal(GroupEntity groupEntity)

writeGroupEntityInternal

public void writeGroupEntityInternal(GroupEntity groupEntity,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

writeGroupInternal

public void writeGroupInternal(BigInteger dpId,
                               org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group,
                               org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

removeFlowInternal

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeFlowInternal(FlowEntity flowEntity)

deleteFlowEntityInternal

public void deleteFlowEntityInternal(FlowEntity flowEntity,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

removeFlowNewInternal

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeFlowNewInternal(BigInteger dpnId,
                                                                                                                                                                       org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)

deleteFlowInternal

public void deleteFlowInternal(BigInteger dpId,
                               org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow,
                               org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

removeGroupInternal

protected com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeGroupInternal(BigInteger dpnId,
                                                                                                                                                                        long groupId)

removeGroupInternal

public void removeGroupInternal(BigInteger dpnId,
                                long groupId,
                                org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

modifyGroupInternal

public void modifyGroupInternal(GroupEntity groupEntity)

sendPacketOutInternal

public void sendPacketOutInternal(BigInteger dpnId,
                                  int groupId,
                                  byte[] payload)

sendPacketOutWithActionsInternal

public void sendPacketOutWithActionsInternal(BigInteger dpnId,
                                             byte[] payload,
                                             List<ActionInfo> actionInfos)

sendARPPacketOutWithActionsInternal

public void sendARPPacketOutWithActionsInternal(BigInteger dpnId,
                                                byte[] payload,
                                                List<ActionInfo> actions)

nodeToInstanceId

protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node> nodeToInstanceId(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node node)

getNodeConnRef

protected static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef getNodeConnRef(String nodeId,
                                                                                                                   String port)

buildDpnNode

protected org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node buildDpnNode(BigInteger dpnId)

syncSetUpFlowInternal

public void syncSetUpFlowInternal(FlowEntity flowEntity,
                                  boolean isRemove)

syncSetUpGroupInternal

public void syncSetUpGroupInternal(GroupEntity groupEntity,
                                   boolean isRemove)

syncSetUpGroupInternal

public void syncSetUpGroupInternal(BigInteger dpId,
                                   org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group,
                                   boolean isRemove)

installFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installFlow(FlowEntity flowEntity)

Specified by:

installFlow in interface IMdsalApiManager

installFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installFlow(BigInteger dpId,
                                                                                                                                                             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)

Specified by:

installFlow in interface IMdsalApiManager

installFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> installFlow(BigInteger dpId,
                                                                                                                                                             FlowEntity flowEntity)

Specified by:

installFlow in interface IMdsalApiManager

removeFlow

public com.google.common.util.concurrent.ListenableFuture<Void> removeFlow(BigInteger dpId,
                                                                           short tableId,
                                                                           org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId flowId)

Specified by:

removeFlow in interface IMdsalApiManager

removeFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeFlow(BigInteger dpId,
                                                                                                                                                            org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flowEntity)

Specified by:

removeFlow in interface IMdsalApiManager

removeFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeFlow(BigInteger dpId,
                                                                                                                                                            FlowEntity flowEntity)

Specified by:

removeFlow in interface IMdsalApiManager

removeFlow

public com.google.common.util.concurrent.CheckedFuture<Void,org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException> removeFlow(FlowEntity flowEntity)

Specified by:

removeFlow in interface IMdsalApiManager

installGroup

public void installGroup(GroupEntity groupEntity)

Specified by:

installGroup in interface IMdsalApiManager

modifyGroup

public void modifyGroup(GroupEntity groupEntity)

Specified by:

modifyGroup in interface IMdsalApiManager

removeGroup

public void removeGroup(GroupEntity groupEntity)

Description copied from interface: IMdsalApiManager

Remove a group.

Specified by:

removeGroup in interface IMdsalApiManager

removeGroup

public void removeGroup(BigInteger dpnId,
                        long groupId)

Description copied from interface: IMdsalApiManager

Remove a group.

Specified by:

removeGroup in interface IMdsalApiManager

Parameters:

dpnId - The DP id.

groupId - The group id.

removeGroup

public void removeGroup(BigInteger dpnId,
                        long groupId,
                        org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Remove a group, using an existing transaction.

Specified by:

removeGroup in interface IMdsalApiManager

Parameters:

dpnId - The DP id.

groupId - The group id.

tx - The transaction.

sendPacketOut

public void sendPacketOut(BigInteger dpnId,
                          int groupId,
                          byte[] payload)

Specified by:

sendPacketOut in interface IMdsalApiManager

sendPacketOutWithActions

public void sendPacketOutWithActions(BigInteger dpnId,
                                     long groupId,
                                     byte[] payload,
                                     List<ActionInfo> actionInfos)

Description copied from interface: IMdsalApiManager

Send packet out with actions.

Specified by:

sendPacketOutWithActions in interface IMdsalApiManager

sendPacketOutWithActions

public void sendPacketOutWithActions(BigInteger dpnId,
                                     byte[] payload,
                                     List<ActionInfo> actionInfos)

Specified by:

sendPacketOutWithActions in interface IMdsalApiManager

sendARPPacketOutWithActions

public void sendARPPacketOutWithActions(BigInteger dpnId,
                                        byte[] payload,
                                        List<ActionInfo> actionInfo)

Specified by:

sendARPPacketOutWithActions in interface IMdsalApiManager

syncRemoveFlow

public void syncRemoveFlow(FlowEntity flowEntity,
                           long delayTime)

Description copied from interface: IMdsalApiManager

API to remove the flow on Data Plane Node synchronously. It internally waits for Flow Change Notification to confirm flow delete request is being sent with-in delayTime.

Specified by:

syncRemoveFlow in interface IMdsalApiManager

syncRemoveFlow

public void syncRemoveFlow(FlowEntity flowEntity)

Specified by:

syncRemoveFlow in interface IMdsalApiManager

syncInstallFlow

public void syncInstallFlow(FlowEntity flowEntity,
                            long delayTime)

Description copied from interface: IMdsalApiManager

Install a flow.

Specified by:

syncInstallFlow in interface IMdsalApiManager

syncInstallFlow

public void syncInstallFlow(FlowEntity flowEntity)

Specified by:

syncInstallFlow in interface IMdsalApiManager

syncInstallGroup

public void syncInstallGroup(GroupEntity groupEntity,
                             long delayTime)

Description copied from interface: IMdsalApiManager

API to install the Group on Data Plane Node synchronously. It internally waits for Group Change Notification to confirm group mod request is being sent with-in delayTime

Specified by:

syncInstallGroup in interface IMdsalApiManager

syncInstallGroup

public void syncInstallGroup(GroupEntity groupEntity)

Specified by:

syncInstallGroup in interface IMdsalApiManager

syncInstallGroup

public void syncInstallGroup(BigInteger dpId,
                             org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group,
                             long delayTime)

Description copied from interface: IMdsalApiManager

Install a group.

Specified by:

syncInstallGroup in interface IMdsalApiManager

syncInstallGroup

public void syncInstallGroup(BigInteger dpId,
                             org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group)

Specified by:

syncInstallGroup in interface IMdsalApiManager

syncRemoveGroup

public void syncRemoveGroup(GroupEntity groupEntity)

Description copied from interface: IMdsalApiManager

API to remove the Group on Data Plane Node synchronously. It internally waits for Group Change Notification to confirm group delete request is being sent.

Specified by:

syncRemoveGroup in interface IMdsalApiManager

syncRemoveGroup

public void syncRemoveGroup(BigInteger dpId,
                            org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group)

Specified by:

syncRemoveGroup in interface IMdsalApiManager

addFlowToTx

public void addFlowToTx(FlowEntity flowEntity,
                        org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Add a Flow to batched transaction. This is used to batch multiple ConfigDS changes in a single transaction.

Specified by:

addFlowToTx in interface IMdsalApiManager

Parameters:

flowEntity - Flow being added

tx - batched transaction

addFlowToTx

public void addFlowToTx(BigInteger dpId,
                        org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow,
                        org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Add a Flow to batched transaction This is used to batch multiple ConfigDS changes in a single transaction and programming on specific DPN.

Specified by:

addFlowToTx in interface IMdsalApiManager

Parameters:

dpId - dpn Id

flow - Flow being added

tx - batched transaction

removeFlowToTx

public void removeFlowToTx(BigInteger dpId,
                           org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow,
                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Remove a Flow using batched transaction. This is used to batch multiple ConfigDS changes in a single transaction for removing on specific DPN.

Specified by:

removeFlowToTx in interface IMdsalApiManager

Parameters:

dpId - dpn Id

flow - Flow being removed

tx - batched transaction

removeFlowToTx

public void removeFlowToTx(FlowEntity flowEntity,
                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Remove a Flow using batched transaction. This is used to batch multiple ConfigDS changes in a single transaction

Specified by:

removeFlowToTx in interface IMdsalApiManager

Parameters:

flowEntity - Flow being removed

tx - batched transaction

addGroupToTx

public void addGroupToTx(GroupEntity groupEntity,
                         org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Add a Group using batched transaction. This is used to batch multiple ConfigDS changes in a single transaction

Specified by:

addGroupToTx in interface IMdsalApiManager

Parameters:

groupEntity - group being added

tx - batched transaction

addGroupToTx

public void addGroupToTx(BigInteger dpId,
                         org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group,
                         org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Add a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction and programming on specific DPN.

Specified by:

addGroupToTx in interface IMdsalApiManager

Parameters:

dpId - dpn Id

group - group being added

tx - batched transaction

removeGroupToTx

public void removeGroupToTx(GroupEntity groupEntity,
                            org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Remove a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction.

Specified by:

removeGroupToTx in interface IMdsalApiManager

Parameters:

groupEntity - group being removed

tx - batched transaction

removeGroupToTx

public void removeGroupToTx(BigInteger dpId,
                            org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group group,
                            org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Description copied from interface: IMdsalApiManager

Remove a Group using batched transaction This is used to batch multiple ConfigDS changes in a single transaction.

Specified by:

removeGroupToTx in interface IMdsalApiManager

Parameters:

dpId - dpn Id

group - group being removed

tx - batched transaction

batchedAddFlow

public void batchedAddFlow(BigInteger dpId,
                           FlowEntity flowEntity)

Specified by:

batchedAddFlow in interface IMdsalApiManager

batchedRemoveFlow

public void batchedRemoveFlow(BigInteger dpId,
                              FlowEntity flowEntity)

Specified by:

batchedRemoveFlow in interface IMdsalApiManager

addBucketToTx

public void addBucketToTx(BigInteger dpId,
                          long groupId,
                          org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket bucket,
                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Specified by:

addBucketToTx in interface IMdsalApiManager

removeBucketToTx

public void removeBucketToTx(BigInteger dpId,
                             long groupId,
                             long bucketId,
                             org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

Specified by:

removeBucketToTx in interface IMdsalApiManager

deleteBucket

public void deleteBucket(BigInteger dpId,
                         long groupId,
                         long bucketId,
                         org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

addBucket

public void addBucket(BigInteger dpId,
                      long groupId,
                      org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket bucket,
                      org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

groupExists

public boolean groupExists(BigInteger dpId,
                           long groupId)

Description copied from interface: IMdsalApiManager

Check if OF group exist on DPN.

Specified by:

groupExists in interface IMdsalApiManager

Parameters:

dpId - dpn id

groupId - OF group id

Returns:

true if group exists and false otherwise

flowExists

public boolean flowExists(BigInteger dpId,
                          short tableId,
                          org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey flowKey)