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.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService	idManager
protected org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService	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

Constructor Summary

Constructors

Constructor and Description

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 interfaceManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager, NAPTSwitchSelector naptSwitchSelector)

Method Summary

Modifier and Type	Method and Description
void	close()
protected String	getFlowRef(BigInteger dpnId, short tableId, long routerID)
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	installDefaultFibRouteForSNAT(BigInteger dpnId, Long extNetId, int addOrRemove)
protected void	installInboundFibEntry(BigInteger dpnId, String externalIp, String routerName, Long routerId, long extSubnetId, int addOrRemove)
protected void	installInboundTerminatingServiceTblEntry(BigInteger dpnId, Long routerId, String routerName, String externalIp, 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, String externalIp, long extSubnetId, int addOrRemove)
protected abstract void	installSnatSpecificEntriesForNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
protected abstract void	installSnatSpecificEntriesForNonNaptSwitch(Routers routers, BigInteger dpnId, int addOrRemove)
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

interfaceManager

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

Constructor Detail

AbstractSnatService

public 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 interfaceManager,
                           org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager,
                           NAPTSwitchSelector naptSwitchSelector)

Method Detail

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.

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.

installSnatCommonEntriesForNaptSwitch

protected void installSnatCommonEntriesForNaptSwitch(Routers routers,
                                                     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,
                                      String routerName,
                                      Long routerId,
                                      long extSubnetId,
                                      int addOrRemove)

installSnatMissEntry

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

installInboundTerminatingServiceTblEntry

protected void installInboundTerminatingServiceTblEntry(BigInteger dpnId,
                                                        Long routerId,
                                                        String routerName,
                                                        String externalIp,
                                                        long extSubnetId,
                                                        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)