org.opendaylight.netvirt.natservice.internal

Class VxlanGreConntrackBasedSnatService

java.lang.Object

org.opendaylight.netvirt.natservice.internal.AbstractSnatService

org.opendaylight.netvirt.natservice.internal.ConntrackBasedSnatService

org.opendaylight.netvirt.natservice.internal.VxlanGreConntrackBasedSnatService

All Implemented Interfaces:

SnatServiceListener

public class VxlanGreConntrackBasedSnatService
extends ConntrackBasedSnatService

Field Summary

Fields inherited from class org.opendaylight.netvirt.natservice.internal.ConntrackBasedSnatService

DNAT_CT_STATE, DNAT_CT_STATE_MASK, SNAT_CT_STATE, SNAT_CT_STATE_MASK, TRACKED_NEW_CT_MASK, TRACKED_NEW_CT_STATE

Fields inherited from class org.opendaylight.netvirt.natservice.internal.AbstractSnatService

dataBroker, eventCallbacks, fibManager, idManager, interfaceManager, itmManager, mdsalManager, naptSwitchSelector, natDataUtil, odlInterfaceRpcService, txRunner, vpnFootprintService

Constructor Summary

Constructors

Constructor and Description

VxlanGreConntrackBasedSnatService(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager, NAPTSwitchSelector naptSwitchSelector, ExternalRoutersListener externalRouterListener, IElanService elanManager, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, IVpnFootprintService vpnFootprintService, IFibManager fibManager, NatDataUtil natDataUtil, org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar eventCallbacks, NatOverVxlanUtil natOverVxlanUtil)

Method Summary

Modifier and Type	Method and Description
boolean	addCentralizedRouter(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId, BigInteger dpnId) Adds flows for centralized switch for the dpnId.
boolean	addCentralizedRouterAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId) Adds flows for centralized switch for all dpns having ports on the router subnet.
protected void	addInboundEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, Long extNeVpnId, List<ExternalIps> externalIps, int elanId)
protected void	addNaptPfibFlowForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId, Long extNetVpnId)
protected void	addOutboundTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, Long extNetVpnId, List<ExternalIps> externalIps, int elanId)
protected void	addOutboundTblTrackEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId, Long extNetVpnId)
boolean	addSnat(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId, BigInteger dpnId) Adds snat flows for the dpnId.
boolean	addSnatAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId) Adds snat flows for all dpns having ports on the router subnet.
protected void	addSnatMissEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId, String routerName, BigInteger primarySwitchId)
protected void	addSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected void	addTerminatingServiceTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, String routerName, Long routerId, int elanId)
boolean	removeCentralizedRouter(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId, BigInteger dpnId) Removes flows for centralized switch for the dpnId.
boolean	removeCentralizedRouterAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId) Removes flows for centralized switch for all dpns having ports on the router subnet.
protected void	removeInboundEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, List<ExternalIps> externalIps)
protected void	removeNaptPfibFlowForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId, Long extNetVpnId)
protected void	removeOutboundTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, List<ExternalIps> externalIps)
protected void	removeOutboundTblTrackEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId)
boolean	removeSnat(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId, BigInteger dpnId) Removes snat flows for the dpnId.
boolean	removeSnatAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger primarySwitchId) Removes snat flows for all dpns having ports on the router subnet.
protected void	removeSnatMissEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId, String routerName)
protected void	removeSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected void	removeTerminatingServiceTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId)

Methods inherited from class org.opendaylight.netvirt.natservice.internal.ConntrackBasedSnatService

addInboundEntry, addNaptPfibEntry, addNaptPfibFlow, addOutboundTblEntry, addOutboundTblTrackEntry, addSnatMissEntryForPrimrySwch, addSnatSpecificEntriesForNonNaptSwitch, removeInboundEntry, removeNaptPfibEntry, removeNaptPfibFlow, removeOutboundTblEntry, removeOutboundTblTrackEntry, removeSnatMissEntryForPrimrySwch, removeSnatSpecificEntriesForNonNaptSwitch

Methods inherited from class org.opendaylight.netvirt.natservice.internal.AbstractSnatService

addCommonEntriesForNaptSwitch, addCommonEntriesForNonNaptSwitch, addDefaultFibRouteForSNAT, addInboundFibEntry, addInboundTerminatingServiceTblEntry, addSnatCommonEntriesForNaptSwitch, addSnatCommonEntriesForNonNaptSwitch, addTerminatingServiceTblEntry, close, createGroupId, getDataBroker, getFlowRef, getGroupIdKey, handleRouterUpdate, init, removeCommonEntriesForNaptSwitch, removeCommonEntriesForNonNaptSwitch, removeDefaultFibRouteForSNAT, removeInboundFibEntry, removeInboundTerminatingServiceTblEntry, removeMipAdjacencies, removeSnatCommonEntriesForNaptSwitch, removeSnatCommonEntriesForNonNaptSwitch, removeTerminatingServiceTblEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

VxlanGreConntrackBasedSnatService

public VxlanGreConntrackBasedSnatService(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                         org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                                         org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager,
                                         org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService,
                                         org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager,
                                         NAPTSwitchSelector naptSwitchSelector,
                                         ExternalRoutersListener externalRouterListener,
                                         IElanService elanManager,
                                         org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                                         IVpnFootprintService vpnFootprintService,
                                         IFibManager fibManager,
                                         NatDataUtil natDataUtil,
                                         org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar eventCallbacks,
                                         NatOverVxlanUtil natOverVxlanUtil)

Method Detail

addSnatAllSwitch

public boolean addSnatAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                Routers routers,
                                BigInteger primarySwitchId)

Description copied from interface: SnatServiceListener

Adds snat flows for all dpns having ports on the router subnet.

Specified by:

addSnatAllSwitch in interface SnatServiceListener

Overrides:

addSnatAllSwitch in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId

Returns:

returns success/failure.

removeSnatAllSwitch

public boolean removeSnatAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                   Routers routers,
                                   BigInteger primarySwitchId)
                            throws ExecutionException,
                                   InterruptedException

Description copied from interface: SnatServiceListener

Removes snat flows for all dpns having ports on the router subnet.

Specified by:

removeSnatAllSwitch in interface SnatServiceListener

Overrides:

removeSnatAllSwitch in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId

Returns:

returns success/failure.

Throws:

ExecutionException

InterruptedException

addCentralizedRouterAllSwitch

public boolean addCentralizedRouterAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                             Routers routers,
                                             BigInteger primarySwitchId)

Description copied from interface: SnatServiceListener

Adds flows for centralized switch for all dpns having ports on the router subnet.

Specified by:

addCentralizedRouterAllSwitch in interface SnatServiceListener

Overrides:

addCentralizedRouterAllSwitch in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

Returns:

returns success/failure.

removeCentralizedRouterAllSwitch

public boolean removeCentralizedRouterAllSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                Routers routers,
                                                BigInteger primarySwitchId)
                                         throws ExecutionException,
                                                InterruptedException

Description copied from interface: SnatServiceListener

Removes flows for centralized switch for all dpns having ports on the router subnet.

Specified by:

removeCentralizedRouterAllSwitch in interface SnatServiceListener

Overrides:

removeCentralizedRouterAllSwitch in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

Returns:

returns success/failure.

Throws:

ExecutionException

InterruptedException

addCentralizedRouter

public boolean addCentralizedRouter(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                    Routers routers,
                                    BigInteger primarySwitchId,
                                    BigInteger dpnId)

Description copied from interface: SnatServiceListener

Adds flows for centralized switch for the dpnId.

Specified by:

addCentralizedRouter in interface SnatServiceListener

Overrides:

addCentralizedRouter in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

dpnId - the dpnId for which the flows needs to be added.

Returns:

returns success/failure.

removeCentralizedRouter

public boolean removeCentralizedRouter(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                       Routers routers,
                                       BigInteger primarySwitchId,
                                       BigInteger dpnId)
                                throws ExecutionException,
                                       InterruptedException

Description copied from interface: SnatServiceListener

Removes flows for centralized switch for the dpnId.

Specified by:

removeCentralizedRouter in interface SnatServiceListener

Overrides:

removeCentralizedRouter in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

dpnId - the dpnId for which the flows needs to be removed.

Returns:

returns success/failure.

Throws:

ExecutionException

InterruptedException

addSnat

public boolean addSnat(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                       Routers routers,
                       BigInteger primarySwitchId,
                       BigInteger dpnId)

Description copied from interface: SnatServiceListener

Adds snat flows for the dpnId.

Specified by:

addSnat in interface SnatServiceListener

Overrides:

addSnat in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

dpnId - the dpnId for which the flows needs to be added.

Returns:

returns success/failure.

removeSnat

public boolean removeSnat(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                          Routers routers,
                          BigInteger primarySwitchId,
                          BigInteger dpnId)
                   throws ExecutionException,
                          InterruptedException

Description copied from interface: SnatServiceListener

Removes snat flows for the dpnId.

Specified by:

removeSnat in interface SnatServiceListener

Overrides:

removeSnat in class AbstractSnatService

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId.

dpnId - the dpnId for which the flows needs to be removed.

Returns:

returns success/failure.

Throws:

ExecutionException

InterruptedException

addSnatSpecificEntriesForNaptSwitch

protected void addSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                   Routers routers,
                                                   BigInteger dpnId)

Overrides:

addSnatSpecificEntriesForNaptSwitch in class ConntrackBasedSnatService

removeSnatSpecificEntriesForNaptSwitch

protected void removeSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                      Routers routers,
                                                      BigInteger dpnId)
                                               throws ExecutionException,
                                                      InterruptedException

Overrides:

removeSnatSpecificEntriesForNaptSwitch in class ConntrackBasedSnatService

Throws:

ExecutionException

InterruptedException

addOutboundTblTrackEntryForVxlanGre

protected void addOutboundTblTrackEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                   BigInteger dpnId,
                                                   Long routerId,
                                                   Long extNetVpnId)

removeOutboundTblTrackEntryForVxlanGre

protected void removeOutboundTblTrackEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                      BigInteger dpnId,
                                                      Long routerId)
                                               throws ExecutionException,
                                                      InterruptedException

Throws:

ExecutionException

InterruptedException

addOutboundTblEntryForVxlanGre

protected void addOutboundTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                              BigInteger dpnId,
                                              long routerId,
                                              Long extNetVpnId,
                                              List<ExternalIps> externalIps,
                                              int elanId)

removeOutboundTblEntryForVxlanGre

protected void removeOutboundTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                 BigInteger dpnId,
                                                 long routerId,
                                                 List<ExternalIps> externalIps)
                                          throws ExecutionException,
                                                 InterruptedException

Throws:

ExecutionException

InterruptedException

addNaptPfibFlowForVxlanGre

protected void addNaptPfibFlowForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                          Routers routers,
                                          BigInteger dpnId,
                                          Long extNetVpnId)

removeNaptPfibFlowForVxlanGre

protected void removeNaptPfibFlowForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                             Routers routers,
                                             BigInteger dpnId,
                                             Long extNetVpnId)
                                      throws ExecutionException,
                                             InterruptedException

Throws:

ExecutionException

InterruptedException

addInboundEntryForVxlanGre

protected void addInboundEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                          BigInteger dpnId,
                                          long routerId,
                                          Long extNeVpnId,
                                          List<ExternalIps> externalIps,
                                          int elanId)

removeInboundEntryForVxlanGre

protected void removeInboundEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                             BigInteger dpnId,
                                             long routerId,
                                             List<ExternalIps> externalIps)
                                      throws ExecutionException,
                                             InterruptedException

Throws:

ExecutionException

InterruptedException

addTerminatingServiceTblEntryForVxlanGre

protected void addTerminatingServiceTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                        BigInteger dpnId,
                                                        String routerName,
                                                        Long routerId,
                                                        int elanId)

removeTerminatingServiceTblEntryForVxlanGre

protected void removeTerminatingServiceTblEntryForVxlanGre(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                           BigInteger dpnId,
                                                           Long routerId)
                                                    throws ExecutionException,
                                                           InterruptedException

Throws:

ExecutionException

InterruptedException

addSnatMissEntry

protected void addSnatMissEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                BigInteger dpnId,
                                Long routerId,
                                String routerName,
                                BigInteger primarySwitchId)

Overrides:

addSnatMissEntry in class AbstractSnatService

removeSnatMissEntry

protected void removeSnatMissEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                   BigInteger dpnId,
                                   Long routerId,
                                   String routerName)
                            throws ExecutionException,
                                   InterruptedException

Overrides:

removeSnatMissEntry in class AbstractSnatService

Throws:

ExecutionException

InterruptedException