org.opendaylight.genius.interfacemanager.servicebindings.flowbased.utilities

Class FlowBasedServicesUtils

java.lang.Object

org.opendaylight.genius.interfacemanager.servicebindings.flowbased.utilities.FlowBasedServicesUtils

public final class FlowBasedServicesUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlowBasedServicesUtils.ServiceMode

Field Summary

Fields

Modifier and Type	Field and Description
static Collection<String>	INTERFACE_TYPE_BASED_SERVICE_BINDING_KEYWORDS
static com.google.common.collect.ImmutableBiMap<FlowBasedServicesUtils.ServiceMode,Class<? extends ServiceModeBase>>	SERVICE_MODE_MAP

Method Summary

Modifier and Type	Method and Description
static void	addBoundServicesState(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, ManagedNewTransactionRunner txRunner, String interfaceName, BoundServicesState interfaceBoundServicesState)
static void	bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner, List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface interfaceInfo, String interfaceName, int ifIndex, long groupId)
static void	bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner, List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface interfaceInfo, String portNo, String interfaceName, int ifIndex)
static void	bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner, List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, String interfaceName, List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction> instructions)
static BoundServicesState	buildBoundServicesState(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState, Class<? extends ServiceModeBase> serviceMode)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices>	buildDefaultServiceId(String interfaceName)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices>	buildServiceId(String interfaceName, short serviceIndex)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices>	buildServiceId(String interfaceName, short serviceIndex, Class<? extends ServiceModeBase> serviceMode)
static BoundServices	getBoundServices(String serviceName, short servicePriority, int flowPriority, BigInteger cookie, List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction> instructions)
static BoundServicesState	getBoundServicesState(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, String interfaceName, Class<? extends ServiceModeBase> serviceMode)
static BigInteger	getDpnIdFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState)
static String	getFlowRef(short tableId, BigInteger dpnId, String infName)
static BoundServices[]	getHighAndLowPriorityService(List<BoundServices> serviceInfos, BoundServices currentServiceInfo) This utility method returns an array of ServiceInfo in which index 0 will have the immediate lower priority service and index 1 will have the immediate higher priority service among the list of existing serviceInfos.
static BoundServices	getHighestPriorityService(List<BoundServices> serviceInfos)
static List<MatchInfo>	getMatchInfoForDispatcherTable(int interfaceTag, short servicePriority)
static List<MatchInfoBase>	getMatchInfoForEgressDispatcherTable(int interfaceTag, short serviceIndex)
static List<MatchInfo>	getMatchInfoForTunnelPortAtIngressTable(BigInteger dpId, long portNo)
static List<MatchInfo>	getMatchInfoForVlanPortAtIngressTable(BigInteger dpId, long portNo, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)
static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId	getNodeConnectorIdFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState)
static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId	getNodeConnectorIdFromInterface(String interfaceName, InterfaceManagerCommonUtils interfaceManagerCommonUtils)
static ServicesInfo	getServicesInfoForInterface(String interfaceName, Class<? extends ServiceModeBase> serviceMode, org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)
static void	installEgressDispatcherFlows(BigInteger dpId, BoundServices boundService, String interfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, int interfaceTag, short currentServiceIndex, short nextServiceIndex, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)
static void	installEgressDispatcherSplitHorizonFlow(BigInteger dpId, BoundServices boundService, String interfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, int interfaceTag, short currentServiceIndex, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)
static void	installFlow(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction)
static void	installInterfaceIngressFlow(BigInteger dpId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface, BoundServices boundServiceNew, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, List<MatchInfo> matches, int lportTag, short tableId)
static void	installLPortDispatcherFlow(BigInteger dpId, BoundServices boundService, String interfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, int interfaceTag, short currentServiceIndex, short nextServiceIndex)
static void	installLportIngressFlow(BigInteger dpId, long portNo, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface, List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, ManagedNewTransactionRunner txRunner, int lportTag)
static boolean	isInterfaceTypeBasedServiceBinding(String interfaceName)
static void	removeBoundServicesState(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures, ManagedNewTransactionRunner txRunner, String interfaceName, Class<? extends ServiceModeBase> serviceMode)
static void	removeEgressDispatcherFlows(BigInteger dpId, String iface, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, short currentServiceIndex)
static void	removeEgressSplitHorizonDispatcherFlow(BigInteger dpId, String iface, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction)
static void	removeIngressFlow(String interfaceName, BigInteger dpId, ManagedNewTransactionRunner txRunner, List<com.google.common.util.concurrent.ListenableFuture<Void>> futures)
static void	removeIngressFlow(String name, BoundServices serviceOld, BigInteger dpId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction)
static void	removeLPortDispatcherFlow(BigInteger dpId, String iface, BoundServices boundServicesOld, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction, short currentServiceIndex)

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_MODE_MAP

public static final com.google.common.collect.ImmutableBiMap<FlowBasedServicesUtils.ServiceMode,Class<? extends ServiceModeBase>> SERVICE_MODE_MAP

INTERFACE_TYPE_BASED_SERVICE_BINDING_KEYWORDS

public static final Collection<String> INTERFACE_TYPE_BASED_SERVICE_BINDING_KEYWORDS

Method Detail

getServicesInfoForInterface

public static ServicesInfo getServicesInfoForInterface(String interfaceName,
                                                       Class<? extends ServiceModeBase> serviceMode,
                                                       org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker)

getNodeConnectorIdFromInterface

public static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId getNodeConnectorIdFromInterface(String interfaceName,
                                                                                                                                InterfaceManagerCommonUtils interfaceManagerCommonUtils)

getNodeConnectorIdFromInterface

public static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId getNodeConnectorIdFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState)

getDpnIdFromInterface

@Nullable
public static BigInteger getDpnIdFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState)

getMatchInfoForVlanPortAtIngressTable

public static List<MatchInfo> getMatchInfoForVlanPortAtIngressTable(BigInteger dpId,
                                                                    long portNo,
                                                                    org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)

getMatchInfoForTunnelPortAtIngressTable

@Nonnull
public static List<MatchInfo> getMatchInfoForTunnelPortAtIngressTable(BigInteger dpId,
                                                                               long portNo)

getMatchInfoForDispatcherTable

public static List<MatchInfo> getMatchInfoForDispatcherTable(int interfaceTag,
                                                             short servicePriority)

getMatchInfoForEgressDispatcherTable

public static List<MatchInfoBase> getMatchInfoForEgressDispatcherTable(int interfaceTag,
                                                                       short serviceIndex)

installInterfaceIngressFlow

public static void installInterfaceIngressFlow(BigInteger dpId,
                                               org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface,
                                               BoundServices boundServiceNew,
                                               org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                               List<MatchInfo> matches,
                                               int lportTag,
                                               short tableId)

installFlow

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

installLPortDispatcherFlow

public static void installLPortDispatcherFlow(BigInteger dpId,
                                              BoundServices boundService,
                                              String interfaceName,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                              int interfaceTag,
                                              short currentServiceIndex,
                                              short nextServiceIndex)

installEgressDispatcherFlows

public static void installEgressDispatcherFlows(BigInteger dpId,
                                                BoundServices boundService,
                                                String interfaceName,
                                                org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                                int interfaceTag,
                                                short currentServiceIndex,
                                                short nextServiceIndex,
                                                org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)

installEgressDispatcherSplitHorizonFlow

public static void installEgressDispatcherSplitHorizonFlow(BigInteger dpId,
                                                           BoundServices boundService,
                                                           String interfaceName,
                                                           org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                                           int interfaceTag,
                                                           short currentServiceIndex,
                                                           org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface)

getBoundServices

public static BoundServices getBoundServices(String serviceName,
                                             short servicePriority,
                                             int flowPriority,
                                             BigInteger cookie,
                                             List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction> instructions)

buildServiceId

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices> buildServiceId(String interfaceName,
                                                                                                       short serviceIndex)

buildServiceId

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices> buildServiceId(String interfaceName,
                                                                                                       short serviceIndex,
                                                                                                       Class<? extends ServiceModeBase> serviceMode)

buildDefaultServiceId

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<BoundServices> buildDefaultServiceId(String interfaceName)

bindDefaultEgressDispatcherService

public static void bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner,
                                                      List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                                      org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface interfaceInfo,
                                                      String portNo,
                                                      String interfaceName,
                                                      int ifIndex)

bindDefaultEgressDispatcherService

public static void bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner,
                                                      List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                                      org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface interfaceInfo,
                                                      String interfaceName,
                                                      int ifIndex,
                                                      long groupId)

bindDefaultEgressDispatcherService

public static void bindDefaultEgressDispatcherService(ManagedNewTransactionRunner txRunner,
                                                      List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                                      String interfaceName,
                                                      List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction> instructions)

removeIngressFlow

public static void removeIngressFlow(String interfaceName,
                                     BigInteger dpId,
                                     ManagedNewTransactionRunner txRunner,
                                     List<com.google.common.util.concurrent.ListenableFuture<Void>> futures)

removeIngressFlow

public static void removeIngressFlow(String name,
                                     BoundServices serviceOld,
                                     BigInteger dpId,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction)

removeLPortDispatcherFlow

public static void removeLPortDispatcherFlow(BigInteger dpId,
                                             String iface,
                                             BoundServices boundServicesOld,
                                             org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                             short currentServiceIndex)

removeEgressDispatcherFlows

public static void removeEgressDispatcherFlows(BigInteger dpId,
                                               String iface,
                                               org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction,
                                               short currentServiceIndex)

removeEgressSplitHorizonDispatcherFlow

public static void removeEgressSplitHorizonDispatcherFlow(BigInteger dpId,
                                                          String iface,
                                                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeTransaction)

getFlowRef

public static String getFlowRef(short tableId,
                                BigInteger dpnId,
                                String infName)

getHighAndLowPriorityService

public static BoundServices[] getHighAndLowPriorityService(List<BoundServices> serviceInfos,
                                                           BoundServices currentServiceInfo)

This utility method returns an array of ServiceInfo in which index 0 will have the immediate lower priority service and index 1 will have the immediate higher priority service among the list of existing serviceInfos.

Parameters:

serviceInfos - list of services bound

currentServiceInfo - current service bound

Returns:

array bound services

getHighestPriorityService

public static BoundServices getHighestPriorityService(List<BoundServices> serviceInfos)

installLportIngressFlow

public static void installLportIngressFlow(BigInteger dpId,
                                           long portNo,
                                           org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface,
                                           List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                           ManagedNewTransactionRunner txRunner,
                                           int lportTag)

buildBoundServicesState

public static BoundServicesState buildBoundServicesState(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState,
                                                         Class<? extends ServiceModeBase> serviceMode)

getBoundServicesState

public static BoundServicesState getBoundServicesState(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                                       String interfaceName,
                                                       Class<? extends ServiceModeBase> serviceMode)

addBoundServicesState

public static void addBoundServicesState(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                         ManagedNewTransactionRunner txRunner,
                                         String interfaceName,
                                         BoundServicesState interfaceBoundServicesState)

removeBoundServicesState

public static void removeBoundServicesState(List<com.google.common.util.concurrent.ListenableFuture<Void>> futures,
                                            ManagedNewTransactionRunner txRunner,
                                            String interfaceName,
                                            Class<? extends ServiceModeBase> serviceMode)

isInterfaceTypeBasedServiceBinding

public static boolean isInterfaceTypeBasedServiceBinding(String interfaceName)