org.opendaylight.netvirt.natservice.internal

Class ConntrackBasedSnatService

java.lang.Object

org.opendaylight.netvirt.natservice.internal.AbstractSnatService

org.opendaylight.netvirt.natservice.internal.ConntrackBasedSnatService

All Implemented Interfaces:

SnatServiceListener

Direct Known Subclasses:

FlatVlanConntrackBasedSnatService, VxlanGreConntrackBasedSnatService

public abstract class ConntrackBasedSnatService
extends AbstractSnatService

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DNAT_CT_STATE
protected static int	DNAT_CT_STATE_MASK
protected static int	SNAT_CT_STATE
protected static int	SNAT_CT_STATE_MASK
protected static int	TRACKED_NEW_CT_MASK
protected static int	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

ConntrackBasedSnatService(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.idmanager.rev160406.IdManagerService idManager, NAPTSwitchSelector naptSwitchSelector, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, IVpnFootprintService vpnFootprintService, IFibManager fibManager, NatDataUtil natDataUtil, org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar eventCallbacks)

Method Summary

Modifier and Type	Method and Description
protected void	addInboundEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, String externalIp, int elanId, long extSubnetId)
protected void	addNaptPfibEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId)
protected void	addNaptPfibFlow(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId, long routerId, long extSubnetId)
protected void	addOutboundTblEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId, String externalIp, int elanId, String extGwMacAddress)
protected void	addOutboundTblTrackEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId, String extGwMacAddress)
protected void	addSnatMissEntryForPrimrySwch(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId, int elanId)
protected void	addSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected void	addSnatSpecificEntriesForNonNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected void	removeInboundEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId)
protected void	removeNaptPfibEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId)
protected void	removeNaptPfibFlow(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId, long routerId)
protected void	removeOutboundTblEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, long routerId)
protected void	removeOutboundTblTrackEntry(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId)
protected void	removeSnatMissEntryForPrimrySwch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, BigInteger dpnId, Long routerId)
protected void	removeSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected void	removeSnatSpecificEntriesForNonNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)

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

addCentralizedRouter, addCentralizedRouterAllSwitch, addCommonEntriesForNaptSwitch, addCommonEntriesForNonNaptSwitch, addDefaultFibRouteForSNAT, addInboundFibEntry, addInboundTerminatingServiceTblEntry, addSnat, addSnatAllSwitch, addSnatCommonEntriesForNaptSwitch, addSnatCommonEntriesForNonNaptSwitch, addSnatMissEntry, addTerminatingServiceTblEntry, close, createGroupId, getDataBroker, getFlowRef, getGroupIdKey, handleRouterUpdate, init, removeCentralizedRouter, removeCentralizedRouterAllSwitch, removeCommonEntriesForNaptSwitch, removeCommonEntriesForNonNaptSwitch, removeDefaultFibRouteForSNAT, removeInboundFibEntry, removeInboundTerminatingServiceTblEntry, removeMipAdjacencies, removeSnat, removeSnatAllSwitch, removeSnatCommonEntriesForNaptSwitch, removeSnatCommonEntriesForNonNaptSwitch, removeSnatMissEntry, removeTerminatingServiceTblEntry

Methods inherited from class java.lang.Object

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

Field Detail

TRACKED_NEW_CT_STATE

protected static final int TRACKED_NEW_CT_STATE

See Also:

Constant Field Values

TRACKED_NEW_CT_MASK

protected static final int TRACKED_NEW_CT_MASK

See Also:

Constant Field Values

SNAT_CT_STATE

protected static final int SNAT_CT_STATE

See Also:

Constant Field Values

SNAT_CT_STATE_MASK

protected static final int SNAT_CT_STATE_MASK

See Also:

Constant Field Values

DNAT_CT_STATE

protected static final int DNAT_CT_STATE

See Also:

Constant Field Values

DNAT_CT_STATE_MASK

protected static final int DNAT_CT_STATE_MASK

See Also:

Constant Field Values

Constructor Detail

ConntrackBasedSnatService

public ConntrackBasedSnatService(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.idmanager.rev160406.IdManagerService idManager,
                                 NAPTSwitchSelector naptSwitchSelector,
                                 org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService odlInterfaceRpcService,
                                 org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                                 IVpnFootprintService vpnFootprintService,
                                 IFibManager fibManager,
                                 NatDataUtil natDataUtil,
                                 org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar eventCallbacks)

Method Detail

addSnatSpecificEntriesForNaptSwitch

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

Specified by:

addSnatSpecificEntriesForNaptSwitch in class AbstractSnatService

removeSnatSpecificEntriesForNaptSwitch

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

Specified by:

removeSnatSpecificEntriesForNaptSwitch in class AbstractSnatService

Throws:

ExecutionException

InterruptedException

addSnatSpecificEntriesForNonNaptSwitch

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

Specified by:

addSnatSpecificEntriesForNonNaptSwitch in class AbstractSnatService

removeSnatSpecificEntriesForNonNaptSwitch

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

Specified by:

removeSnatSpecificEntriesForNonNaptSwitch in class AbstractSnatService

addSnatMissEntryForPrimrySwch

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

removeSnatMissEntryForPrimrySwch

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

Throws:

ExecutionException

InterruptedException

addOutboundTblTrackEntry

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

removeOutboundTblTrackEntry

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

Throws:

ExecutionException

InterruptedException

addOutboundTblEntry

protected void addOutboundTblEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                   BigInteger dpnId,
                                   long routerId,
                                   String externalIp,
                                   int elanId,
                                   String extGwMacAddress)

removeOutboundTblEntry

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

Throws:

ExecutionException

InterruptedException

addNaptPfibFlow

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

removeNaptPfibFlow

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

Throws:

ExecutionException

InterruptedException

addInboundEntry

protected void addInboundEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                               BigInteger dpnId,
                               long routerId,
                               String externalIp,
                               int elanId,
                               long extSubnetId)

removeInboundEntry

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

Throws:

ExecutionException

InterruptedException

addNaptPfibEntry

protected void addNaptPfibEntry(org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                BigInteger dpnId,
                                long routerId)

removeNaptPfibEntry

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

Throws:

ExecutionException

InterruptedException