org.opendaylight.netvirt.natservice.internal

Class AbstractSnatService

java.lang.Object

org.opendaylight.netvirt.natservice.internal.AbstractSnatService

All Implemented Interfaces:

SnatServiceListener

Direct Known Subclasses:

ConntrackBasedSnatService

public abstract class AbstractSnatService
extends Object
implements SnatServiceListener

Field Summary

Fields

Modifier and Type	Field and Description
protected org.opendaylight.controller.md.sal.binding.api.DataBroker	dataBroker
protected org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar	eventCallbacks
protected IFibManager	fibManager
protected org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService	idManager
protected org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager	interfaceManager
protected org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService	itmManager
protected org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager	mdsalManager
protected NAPTSwitchSelector	naptSwitchSelector
protected NatDataUtil	natDataUtil
protected org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService	odlInterfaceRpcService
protected IVpnFootprintService	vpnFootprintService

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

AbstractSnatService(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, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, IVpnFootprintService vpnFootprintService, IFibManager fibManager, NatDataUtil natDataUtil, org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar dataTreeEventCallbackRegistrar)

Method Summary

Modifier and Type	Method and Description
void	close()
protected long	createGroupId(String groupIdKey)
protected org.opendaylight.controller.md.sal.binding.api.DataBroker	getDataBroker()
protected String	getFlowRef(BigInteger dpnId, short tableId, long routerID)
protected String	getGroupIdKey(String routerName)
protected String	getTunnelInterfaceName(BigInteger srcDpId, BigInteger dstDpId)
boolean	handleCentralizedRouter(Routers routers, BigInteger primarySwitchId, BigInteger dpnId, int addOrRemove) Adds/removes flows for centralized switch for the dpnId.
boolean	handleCentralizedRouterAllSwitch(Routers routers, BigInteger primarySwitchId, int addOrRemove) Adds/removes flows for centralized switch for all dpns having ports on the router subnet.
boolean	handleSnat(Routers routers, BigInteger primarySwitchId, BigInteger dpnId, int addOrRemove) Adds/removes snat flows for the dpnId.
boolean	handleSnatAllSwitch(Routers routers, BigInteger primarySwitchId, int addOrRemove) Adds/removes snat flows for all dpns having ports on the router subnet.
void	init()
protected void	installCommonEntriesForNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
protected void	installCommonEntriesForNonNaptSwitch(Routers routers, BigInteger primarySwitchId, BigInteger dpnId, int addOrRemove)
protected void	installDefaultFibRouteForSNAT(BigInteger dpnId, Long extNetId, int addOrRemove)
protected void	installInboundFibEntry(BigInteger dpnId, String externalIp, Long routerId, long extSubnetId, String externalNetId, String subNetId, String routerMac, int addOrRemove)
protected void	installInboundTerminatingServiceTblEntry(BigInteger dpnId, Long routerId, long extSubnetId, int addOrRemove)
protected void	installSnatCommonEntriesForNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
protected void	installSnatCommonEntriesForNonNaptSwitch(Routers routers, BigInteger primarySwitchId, BigInteger dpnId, int addOrRemove)
protected void	installSnatMissEntry(BigInteger dpnId, Long routerId, String routerName, BigInteger primarySwitchId, int addOrRemove)
protected abstract void	installSnatSpecificEntriesForNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
protected abstract void	installSnatSpecificEntriesForNonNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
protected void	installTerminatingServiceTblEntry(BigInteger dpnId, Long routerId, int elanId, int addOrRemove)
protected void	removeMipAdjacencies(Routers routers)
protected void	syncFlow(BigInteger dpId, short tableId, String flowId, int priority, String flowName, BigInteger cookie, List<? extends org.opendaylight.genius.mdsalutil.MatchInfoBase> matches, List<org.opendaylight.genius.mdsalutil.InstructionInfo> instructions, int addOrRemove)

Methods inherited from class java.lang.Object

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

Field Detail

dataBroker

protected final org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker

mdsalManager

protected final org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager

idManager

protected final org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager

naptSwitchSelector

protected final NAPTSwitchSelector naptSwitchSelector

itmManager

protected final org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmManager

odlInterfaceRpcService

protected final org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService

interfaceManager

protected final org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager

vpnFootprintService

protected final IVpnFootprintService vpnFootprintService

fibManager

protected final IFibManager fibManager

natDataUtil

protected final NatDataUtil natDataUtil

eventCallbacks

protected final org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar eventCallbacks

Constructor Detail

AbstractSnatService

protected AbstractSnatService(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,
                              org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                              IVpnFootprintService vpnFootprintService,
                              IFibManager fibManager,
                              NatDataUtil natDataUtil,
                              org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar dataTreeEventCallbackRegistrar)

Method Detail

getDataBroker

protected org.opendaylight.controller.md.sal.binding.api.DataBroker getDataBroker()

init

public void init()

close

public void close()

handleSnatAllSwitch

public boolean handleSnatAllSwitch(Routers routers,
                                   BigInteger primarySwitchId,
                                   int addOrRemove)

Description copied from interface: SnatServiceListener

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

Specified by:

handleSnatAllSwitch in interface SnatServiceListener

Parameters:

routers - the router.

primarySwitchId - the primaryswitchId

addOrRemove - add or remove the flow.

Returns:

returns success/failure.

handleCentralizedRouterAllSwitch

public boolean handleCentralizedRouterAllSwitch(Routers routers,
                                                BigInteger primarySwitchId,
                                                int addOrRemove)

Description copied from interface: SnatServiceListener

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

Specified by:

handleCentralizedRouterAllSwitch in interface SnatServiceListener

Parameters:

routers - the router.

primarySwitchId - the primaryswitchId.

addOrRemove - add or remove the flow.

Returns:

returns success/failure.

handleCentralizedRouter

public boolean handleCentralizedRouter(Routers routers,
                                       BigInteger primarySwitchId,
                                       BigInteger dpnId,
                                       int addOrRemove)

Description copied from interface: SnatServiceListener

Adds/removes flows for centralized switch for the dpnId.

Specified by:

handleCentralizedRouter in interface SnatServiceListener

Parameters:

routers - routers the router.

primarySwitchId - the primaryswitchId.

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

addOrRemove - add or remove the flow.

Returns:

returns success/failure.

handleSnat

public boolean handleSnat(Routers routers,
                          BigInteger primarySwitchId,
                          BigInteger dpnId,
                          int addOrRemove)

Description copied from interface: SnatServiceListener

Adds/removes snat flows for the dpnId.

Specified by:

handleSnat in interface SnatServiceListener

Parameters:

routers - the router.

primarySwitchId - the primaryswitchId.

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

addOrRemove - add or remove the flow.

Returns:

returns success/failure.

installCommonEntriesForNaptSwitch

protected void installCommonEntriesForNaptSwitch(Routers routers,
                                                 BigInteger dpnId,
                                                 int addOrRemove)

installSnatCommonEntriesForNaptSwitch

protected void installSnatCommonEntriesForNaptSwitch(Routers routers,
                                                     BigInteger dpnId,
                                                     int addOrRemove)

installCommonEntriesForNonNaptSwitch

protected void installCommonEntriesForNonNaptSwitch(Routers routers,
                                                    BigInteger primarySwitchId,
                                                    BigInteger dpnId,
                                                    int addOrRemove)

installSnatCommonEntriesForNonNaptSwitch

protected void installSnatCommonEntriesForNonNaptSwitch(Routers routers,
                                                        BigInteger primarySwitchId,
                                                        BigInteger dpnId,
                                                        int addOrRemove)

installSnatSpecificEntriesForNaptSwitch

protected abstract void installSnatSpecificEntriesForNaptSwitch(Routers routers,
                                                                BigInteger dpnId,
                                                                int addOrRemove)

installSnatSpecificEntriesForNonNaptSwitch

protected abstract void installSnatSpecificEntriesForNonNaptSwitch(Routers routers,
                                                                   BigInteger dpnId,
                                                                   int addOrRemove)

installInboundFibEntry

protected void installInboundFibEntry(BigInteger dpnId,
                                      String externalIp,
                                      Long routerId,
                                      long extSubnetId,
                                      String externalNetId,
                                      String subNetId,
                                      String routerMac,
                                      int addOrRemove)

installSnatMissEntry

protected void installSnatMissEntry(BigInteger dpnId,
                                    Long routerId,
                                    String routerName,
                                    BigInteger primarySwitchId,
                                    int addOrRemove)

installInboundTerminatingServiceTblEntry

protected void installInboundTerminatingServiceTblEntry(BigInteger dpnId,
                                                        Long routerId,
                                                        long extSubnetId,
                                                        int addOrRemove)

installTerminatingServiceTblEntry

protected void installTerminatingServiceTblEntry(BigInteger dpnId,
                                                 Long routerId,
                                                 int elanId,
                                                 int addOrRemove)

installDefaultFibRouteForSNAT

protected void installDefaultFibRouteForSNAT(BigInteger dpnId,
                                             Long extNetId,
                                             int addOrRemove)

getFlowRef

protected String getFlowRef(BigInteger dpnId,
                            short tableId,
                            long routerID)

syncFlow

protected void syncFlow(BigInteger dpId,
                        short tableId,
                        String flowId,
                        int priority,
                        String flowName,
                        BigInteger cookie,
                        List<? extends org.opendaylight.genius.mdsalutil.MatchInfoBase> matches,
                        List<org.opendaylight.genius.mdsalutil.InstructionInfo> instructions,
                        int addOrRemove)

createGroupId

protected long createGroupId(String groupIdKey)

getGroupIdKey

protected String getGroupIdKey(String routerName)

getTunnelInterfaceName

protected String getTunnelInterfaceName(BigInteger srcDpId,
                                        BigInteger dstDpId)

removeMipAdjacencies

protected void removeMipAdjacencies(Routers routers)