org.opendaylight.netvirt.natservice.internal

Class NaptSwitchHA

java.lang.Object

org.opendaylight.netvirt.natservice.internal.NaptSwitchHA

@Singleton
public class NaptSwitchHA
extends Object

Constructor Summary

Constructors

Constructor and Description

NaptSwitchHA(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, ExternalRoutersListener externalRouterListener, 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, IFibManager fibManager, EvpnNaptSwitchHA evpnNaptSwitchHA, IElanService elanManager, SnatServiceManager natServiceManager, NatserviceConfig config, NaptEventHandler naptEventHandler, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, NatOverVxlanUtil natOverVxlanUtil)

Method Summary

Modifier and Type	Method and Description
protected void	bestEffortDeletion(long routerId, String routerName, Map<String,Long> externalIpLabel, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
org.opendaylight.genius.mdsalutil.FlowEntity	buildSnatFlowEntity(BigInteger dpId, String routerName, long groupId, long routerVpnId, int addordel)
org.opendaylight.genius.mdsalutil.FlowEntity	buildSnatFlowEntityForNaptSwitch(BigInteger dpId, String routerName, long routerVpnId, int addordel)
protected String	getTunnelInterfaceName(BigInteger srcDpId, BigInteger dstDpId)
List<org.opendaylight.genius.mdsalutil.BucketInfo>	handleGroupInNeighborSwitches(BigInteger dpnId, String routerName, long routerId, BigInteger naptSwitch)
List<org.opendaylight.genius.mdsalutil.BucketInfo>	handleGroupInPrimarySwitch()
protected void	installSnatFlows(String routerName, Long routerId, BigInteger naptSwitch, Long routerVpnId, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
protected void	installSnatGroupEntry(BigInteger dpnId, List<org.opendaylight.genius.mdsalutil.BucketInfo> bucketInfo, String routerName)
boolean	isNaptSwitchDown(String routerName, Long routerId, BigInteger dpnId, BigInteger naptSwitch, Long routerVpnId, Collection<String> externalIpCache, boolean isClearBgpRts, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
boolean	isNaptSwitchDown(String routerName, Long routerId, BigInteger dpnId, BigInteger naptSwitch, Long routerVpnId, Collection<String> externalIpCache, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
protected void	removeSnatFlowsInOldNaptSwitch(String routerName, Long routerId, BigInteger naptSwitch, Map<String,Long> externalIpmap, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
protected void	subnetRegisterMapping(Routers routerEntry, Long segmentId)
boolean	updateNaptSwitch(String routerName, BigInteger naptSwitchId)
void	updateNaptSwitchBucketStatus(String routerName, long routerId, BigInteger naptSwitch)

Methods inherited from class java.lang.Object

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

Constructor Detail

NaptSwitchHA

@Inject
public NaptSwitchHA(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                            org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                            ExternalRoutersListener externalRouterListener,
                            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,
                            IFibManager fibManager,
                            EvpnNaptSwitchHA evpnNaptSwitchHA,
                            IElanService elanManager,
                            SnatServiceManager natServiceManager,
                            NatserviceConfig config,
                            NaptEventHandler naptEventHandler,
                            org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                            NatOverVxlanUtil natOverVxlanUtil)

Method Detail

removeSnatFlowsInOldNaptSwitch

protected void removeSnatFlowsInOldNaptSwitch(String routerName,
                                              Long routerId,
                                              BigInteger naptSwitch,
                                              @Nullable
                                              Map<String,Long> externalIpmap,
                                              org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                                       throws ExecutionException,
                                              InterruptedException

Throws:

ExecutionException

InterruptedException

isNaptSwitchDown

public boolean isNaptSwitchDown(String routerName,
                                Long routerId,
                                BigInteger dpnId,
                                BigInteger naptSwitch,
                                Long routerVpnId,
                                Collection<String> externalIpCache,
                                org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                         throws ExecutionException,
                                InterruptedException

Throws:

ExecutionException

InterruptedException

isNaptSwitchDown

public boolean isNaptSwitchDown(String routerName,
                                Long routerId,
                                BigInteger dpnId,
                                BigInteger naptSwitch,
                                Long routerVpnId,
                                Collection<String> externalIpCache,
                                boolean isClearBgpRts,
                                org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                         throws ExecutionException,
                                InterruptedException

Throws:

ExecutionException

InterruptedException

updateNaptSwitchBucketStatus

public void updateNaptSwitchBucketStatus(String routerName,
                                         long routerId,
                                         BigInteger naptSwitch)

handleGroupInPrimarySwitch

public List<org.opendaylight.genius.mdsalutil.BucketInfo> handleGroupInPrimarySwitch()

handleGroupInNeighborSwitches

@Nonnull
public List<org.opendaylight.genius.mdsalutil.BucketInfo> handleGroupInNeighborSwitches(BigInteger dpnId,
                                                                                                 String routerName,
                                                                                                 long routerId,
                                                                                                 BigInteger naptSwitch)

installSnatGroupEntry

protected void installSnatGroupEntry(BigInteger dpnId,
                                     List<org.opendaylight.genius.mdsalutil.BucketInfo> bucketInfo,
                                     String routerName)

getTunnelInterfaceName

@Nullable
protected String getTunnelInterfaceName(BigInteger srcDpId,
                                                  BigInteger dstDpId)

updateNaptSwitch

public boolean updateNaptSwitch(String routerName,
                                BigInteger naptSwitchId)

buildSnatFlowEntity

public org.opendaylight.genius.mdsalutil.FlowEntity buildSnatFlowEntity(BigInteger dpId,
                                                                        String routerName,
                                                                        long groupId,
                                                                        long routerVpnId,
                                                                        int addordel)

buildSnatFlowEntityForNaptSwitch

public org.opendaylight.genius.mdsalutil.FlowEntity buildSnatFlowEntityForNaptSwitch(BigInteger dpId,
                                                                                     String routerName,
                                                                                     long routerVpnId,
                                                                                     int addordel)

installSnatFlows

protected void installSnatFlows(String routerName,
                                Long routerId,
                                BigInteger naptSwitch,
                                Long routerVpnId,
                                org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

bestEffortDeletion

protected void bestEffortDeletion(long routerId,
                                  String routerName,
                                  Map<String,Long> externalIpLabel,
                                  org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                           throws ExecutionException,
                                  InterruptedException

Throws:

ExecutionException

InterruptedException

subnetRegisterMapping

protected void subnetRegisterMapping(Routers routerEntry,
                                     Long segmentId)