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 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.genius.mdsalutil.interfaces.IMdsalApiManager	mdsalManager
protected org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService	odlInterfaceRpcService
protected org.opendaylight.genius.infra.ManagedNewTransactionRunner	txRunner

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.
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 abstract void	addSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected abstract void	addSnatSpecificEntriesForNonNaptSwitch()
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)
boolean	handleRouterUpdate(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers origRouter, Routers updatedRouter) Handles changes to external router.
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.
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 abstract void	removeSnatSpecificEntriesForNaptSwitch(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, Routers routers, BigInteger dpnId)
protected abstract void	removeSnatSpecificEntriesForNonNaptSwitch()

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

txRunner

protected final org.opendaylight.genius.infra.ManagedNewTransactionRunner txRunner

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

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

fibManager

protected final IFibManager fibManager

Method Detail

getDataBroker

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

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

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

Parameters:

confTx - The transaction to use.

routers - the router.

primarySwitchId - the primaryswitchId

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

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

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

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

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

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

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

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

handleRouterUpdate

public boolean handleRouterUpdate(org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                  Routers origRouter,
                                  Routers updatedRouter)
                           throws ExecutionException,
                                  InterruptedException

Description copied from interface: SnatServiceListener

Handles changes to external router.

Specified by:

handleRouterUpdate in interface SnatServiceListener

origRouter - the Orignal router.

updatedRouter - the Updated router.

Returns:

returns success/failure.

Throws:

ExecutionException

InterruptedException

addSnatSpecificEntriesForNaptSwitch

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

removeSnatSpecificEntriesForNaptSwitch

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

Throws:

ExecutionException

InterruptedException

addSnatSpecificEntriesForNonNaptSwitch

protected abstract void addSnatSpecificEntriesForNonNaptSwitch()

removeSnatSpecificEntriesForNonNaptSwitch

protected abstract void removeSnatSpecificEntriesForNonNaptSwitch()

addSnatMissEntry

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

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

Throws:

ExecutionException

InterruptedException

getFlowRef

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

createGroupId

protected long createGroupId(String groupIdKey)

getGroupIdKey

protected String getGroupIdKey(String routerName)