org.opendaylight.netvirt.cloudservicechain.utils

Class ElanServiceChainUtils

java.lang.Object

org.opendaylight.netvirt.cloudservicechain.utils.ElanServiceChainUtils

public class ElanServiceChainUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ElanServiceChainUtils()

Method Summary

Modifier and Type	Method and Description
static List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction>	buildSetLportTagAndGotoLportDispInstructions(int lportTag) Builds a List of Instructions that set the ElanPseudoPort Tag in metadata and sends to LPortDispatcher table (via Table 80).
static Collection<BigInteger>	getElanDpnsByName(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String elanInstanceName)
static com.google.common.base.Optional<ElanInstance>	getElanInstanceByName(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String elanName)
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInstance>	getElanInstanceConfigDataPath(String elanInstanceName)
static BigInteger	getElanMetadataLabel(long elanTag)
static com.google.common.base.Optional<ElanServiceChainState>	getElanServiceChainState(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String elanInstanceName) Read from ElanToLportTagMap the PsuedoLogicalPort related with a given elan.
static void	programExternalTunnelTable(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, BigInteger dpnId, int elanLportTag, long vni, int elanTag, int addOrRemove) This flow is in charge of receiving packets from the TOR and sending them to the SCF Pipeline by setting the LportTag of ElanPseudoPort.
static void	programLPortDispatcherFromScf(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, BigInteger dpnId, int elanLportTag, long elanTag, int addOrRemove) This flow is in charge of handling packets coming from the SCF Pipeline when there is no matching ServiceChain.
static void	programLPortDispatcherToScf(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, BigInteger dpnId, long elanTag, int elanLportTag, short tableId, long scfTag, int addOrRemove) This flow is in charge of handling packets coming from ExtTunnelTable that must be redirected to the SCF Pipeline.
static void	updateElanToLportTagMap(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String elanInstanceName, int lportTag, long scfTag, int addOrRemove) Stores the relation between ElanLport and scfTag.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElanServiceChainUtils

public ElanServiceChainUtils()

Method Detail

getElanInstanceConfigDataPath

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInstance> getElanInstanceConfigDataPath(String elanInstanceName)

getElanInstanceByName

public static com.google.common.base.Optional<ElanInstance> getElanInstanceByName(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                                                                  String elanName)

getElanDpnsByName

public static Collection<BigInteger> getElanDpnsByName(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                                       String elanInstanceName)

getElanMetadataLabel

public static BigInteger getElanMetadataLabel(long elanTag)

programLPortDispatcherToScf

public static void programLPortDispatcherToScf(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                                               BigInteger dpnId,
                                               long elanTag,
                                               int elanLportTag,
                                               short tableId,
                                               long scfTag,
                                               int addOrRemove)

This flow is in charge of handling packets coming from ExtTunnelTable that must be redirected to the SCF Pipeline. + Matches on lportTag=ElanPseudoLportTag + SI=1 + Sets scfTag and sends to the DlSubsFilter table.

Parameters:

dpnId - Dpn Id where the flow must be installed

elanLportTag - the Elan Pseudo Lport Id in Dataplane

elanTag - the Elan Id in the Dataplane

addOrRemove - States if the flow must be added or removed

programLPortDispatcherFromScf

public static void programLPortDispatcherFromScf(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                                                 BigInteger dpnId,
                                                 int elanLportTag,
                                                 long elanTag,
                                                 int addOrRemove)

This flow is in charge of handling packets coming from the SCF Pipeline when there is no matching ServiceChain.

• Matches on ElanPseudoPortTag and SI=3 (ELAN)
• Sets elanTag and sends to DMAC table

Parameters:

dpnId - Dpn Id where the flow must be installed

elanLportTag - the Elan Pseudo Lport Id to be used in the Dataplane

elanTag - the Elan Id to be used in the Dataplane

addOrRemove - States if the flow must be added or removed

programExternalTunnelTable

public static void programExternalTunnelTable(org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                                              BigInteger dpnId,
                                              int elanLportTag,
                                              long vni,
                                              int elanTag,
                                              int addOrRemove)

This flow is in charge of receiving packets from the TOR and sending them to the SCF Pipeline by setting the LportTag of ElanPseudoPort. Note that ELAN already has a flow in this table that redirects packets to the ELAN Pipeline. However, the flow for the SCF Pipeline will have higher priority, and will only be present when there is a ServiceChain using this ElanPseudoPort.

• Matches on the VNI
• Sets SI=1 and ElanPseudoPort tag in the Metadata and sends to LPortDispatcher via table 80.

Parameters:

dpnId - Dpn Id where the flow must be installed

elanLportTag - the Elan Pseudo Lport Id to be used in the Dataplane

vni - the VNI to which the Elan is related

elanTag - the Elan Id to be used in the Dataplane

addOrRemove - States if the flow must be added or removed

buildSetLportTagAndGotoLportDispInstructions

public static List<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction> buildSetLportTagAndGotoLportDispInstructions(int lportTag)

Builds a List of Instructions that set the ElanPseudoPort Tag in metadata and sends to LPortDispatcher table (via Table 80).

Parameters:

lportTag - Dataplane identifier of the ElanPseudoPort

Returns:

the List of Instructions

updateElanToLportTagMap

public static void updateElanToLportTagMap(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                           String elanInstanceName,
                                           int lportTag,
                                           long scfTag,
                                           int addOrRemove)

Stores the relation between ElanLport and scfTag.

Parameters:

broker - dataBroker service reference

elanInstanceName - Name of the ELAN. Typically its UUID

lportTag - Dataplane identifier of the ElanPseudoPort

scfTag - Dataplane identifier of the SCF

addOrRemove - States if flows must be added or removed

getElanServiceChainState

public static com.google.common.base.Optional<ElanServiceChainState> getElanServiceChainState(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                                                                              String elanInstanceName)

Read from ElanToLportTagMap the PsuedoLogicalPort related with a given elan.

Parameters:

broker - dataBroker service reference

elanInstanceName - the name of the Elan

Returns:

the ElanToPseudoPortData object or Optional.absent() if it cannot be found