org.opendaylight.netvirt.vpnmanager

Class VpnManagerImpl

java.lang.Object

org.opendaylight.netvirt.vpnmanager.VpnManagerImpl

All Implemented Interfaces:

IVpnManager

@Singleton
public class VpnManagerImpl
extends Object
implements IVpnManager

Constructor Summary

Constructors

Constructor and Description

VpnManagerImpl(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManagerService, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, IElanService elanService, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, VpnSubnetRouteHandler vpnSubnetRouteHandler, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService ifaceMgrRpcService, IVpnLinkService ivpnLinkService, IFibManager fibManager, IBgpManager bgpManager, InterVpnLinkCache interVpnLinkCache, org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar dataTreeEventCallbackRegistrar, org.opendaylight.serviceutils.upgrade.UpgradeState upgradeState, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService, VpnUtil vpnUtil)

Method Summary

Modifier and Type	Method and Description
void	addArpResponderFlowsToExternalNetworkIps(String id, Collection<String> fixedIps, String macAddress, BigInteger dpnId, String extInterfaceName, int lportTag)
void	addArpResponderFlowsToExternalNetworkIps(String id, Collection<String> fixedIps, String macAddress, BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId)
void	addExtraRoute(String vpnName, String destination, String nextHop, String rd, String routerID, Long l3vni, RouteOrigin origin, String intfName, Adjacency operationalAdj, VrfEntryBase.EncapType encapType, Set<String> prefixListForRefreshFib, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	addRouterGwMacFlow(String routerName, String routerGwMac, BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId, String subnetVpnName, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	addSubnetMacIntoVpnInstance(String vpnName, String subnetVpnName, String srcMacAddress, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
boolean	checkForOverlappingSubnets(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid network, List<Subnetmap> subnetmapList, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid vpn, Set<VpnTarget> routeTargets, List<String> failedNwList)
void	delExtraRoute(String vpnName, String destination, String nextHop, String rd, String routerID, String intfName, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx)
VpnPortipToPort	getNeutronPortFromVpnPortFixedIp(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String vpnName, String fixedIp)
VpnPortipToPort	getNeutronPortFromVpnPortFixedIp(org.opendaylight.genius.infra.TypedReadTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, String vpnName, String fixedIp)
String	getPrimaryRdFromVpnInstance(VpnInstance vpnInstance)
Set<VpnTarget>	getRtListForVpn(String vpnName)
VpnInstance	getVpnInstance(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String vpnInstanceName)
String	getVpnRd(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, String vpnName)
String	getVpnRd(org.opendaylight.genius.infra.TypedReadTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, String vpnName)
boolean	isVPNConfigured()
void	onSubnetAddedToVpn(Subnetmap subnetmap, boolean isBgpVpn, Long elanTag)
void	onSubnetDeletedFromVpn(Subnetmap subnetmap, boolean isBgpVpn)
void	removeArpResponderFlowsToExternalNetworkIps(String id, Collection<String> fixedIps, BigInteger dpnId, String extInterfaceName, int lportTag)
void	removeArpResponderFlowsToExternalNetworkIps(String id, Collection<String> fixedIps, String macAddress, BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId)
void	removePrefixFromBGP(String vpnName, String primaryRd, String extraRouteRd, String vpnInterfaceName, String prefix, String nextHop, String nextHopTunnelIp, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx)
void	removeRouterGwMacFlow(String routerName, String routerGwMac, BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId, String subnetVpnName, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	removeRouteTargetsToSubnetAssociation(Set<VpnTarget> routeTargets, String cidr, String vpnName)
void	removeSubnetMacFromVpnInstance(String vpnName, String subnetVpnName, String srcMacAddress, BigInteger dpnId, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	start()
void	updateRouteTargetsToSubnetAssociation(Set<VpnTarget> routeTargets, String cidr, String vpnName)

Methods inherited from class java.lang.Object

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

Constructor Detail

VpnManagerImpl

@Inject
public VpnManagerImpl(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManagerService,
                              org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                              IElanService elanService,
                              org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                              VpnSubnetRouteHandler vpnSubnetRouteHandler,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService ifaceMgrRpcService,
                              IVpnLinkService ivpnLinkService,
                              IFibManager fibManager,
                              IBgpManager bgpManager,
                              InterVpnLinkCache interVpnLinkCache,
                              org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar dataTreeEventCallbackRegistrar,
                              org.opendaylight.serviceutils.upgrade.UpgradeState upgradeState,
                              org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService,
                              VpnUtil vpnUtil)

Method Detail

start

@PostConstruct
public void start()

addExtraRoute

public void addExtraRoute(String vpnName,
                          String destination,
                          String nextHop,
                          String rd,
                          @Nullable
                          String routerID,
                          Long l3vni,
                          RouteOrigin origin,
                          @Nullable
                          String intfName,
                          @Nullable
                          Adjacency operationalAdj,
                          VrfEntryBase.EncapType encapType,
                          Set<String> prefixListForRefreshFib,
                          @Nonnull
                          org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

Specified by:

addExtraRoute in interface IVpnManager

delExtraRoute

public void delExtraRoute(String vpnName,
                          String destination,
                          String nextHop,
                          String rd,
                          @Nullable
                          String routerID,
                          @Nullable
                          String intfName,
                          @Nonnull
                          org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                          @Nonnull
                          org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx)

Specified by:

delExtraRoute in interface IVpnManager

removePrefixFromBGP

public void removePrefixFromBGP(String vpnName,
                                String primaryRd,
                                String extraRouteRd,
                                String vpnInterfaceName,
                                String prefix,
                                String nextHop,
                                String nextHopTunnelIp,
                                BigInteger dpnId,
                                org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Operational> operTx)

Specified by:

removePrefixFromBGP in interface IVpnManager

isVPNConfigured

public boolean isVPNConfigured()

Specified by:

isVPNConfigured in interface IVpnManager

addSubnetMacIntoVpnInstance

public void addSubnetMacIntoVpnInstance(String vpnName,
                                        String subnetVpnName,
                                        String srcMacAddress,
                                        BigInteger dpnId,
                                        org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                                 throws ExecutionException,
                                        InterruptedException

Specified by:

addSubnetMacIntoVpnInstance in interface IVpnManager

Throws:

ExecutionException

InterruptedException

removeSubnetMacFromVpnInstance

public void removeSubnetMacFromVpnInstance(String vpnName,
                                           String subnetVpnName,
                                           String srcMacAddress,
                                           BigInteger dpnId,
                                           org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                                    throws ExecutionException,
                                           InterruptedException

Specified by:

removeSubnetMacFromVpnInstance in interface IVpnManager

Throws:

ExecutionException

InterruptedException

addRouterGwMacFlow

public void addRouterGwMacFlow(String routerName,
                               String routerGwMac,
                               BigInteger dpnId,
                               org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId,
                               String subnetVpnName,
                               org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                        throws ExecutionException,
                               InterruptedException

Specified by:

addRouterGwMacFlow in interface IVpnManager

Throws:

ExecutionException

InterruptedException

removeRouterGwMacFlow

public void removeRouterGwMacFlow(String routerName,
                                  String routerGwMac,
                                  BigInteger dpnId,
                                  org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId,
                                  String subnetVpnName,
                                  org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
                           throws ExecutionException,
                                  InterruptedException

Specified by:

removeRouterGwMacFlow in interface IVpnManager

Throws:

ExecutionException

InterruptedException

addArpResponderFlowsToExternalNetworkIps

public void addArpResponderFlowsToExternalNetworkIps(String id,
                                                     Collection<String> fixedIps,
                                                     String macAddress,
                                                     BigInteger dpnId,
                                                     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId)

Specified by:

addArpResponderFlowsToExternalNetworkIps in interface IVpnManager

addArpResponderFlowsToExternalNetworkIps

public void addArpResponderFlowsToExternalNetworkIps(String id,
                                                     Collection<String> fixedIps,
                                                     String macAddress,
                                                     BigInteger dpnId,
                                                     String extInterfaceName,
                                                     int lportTag)

Specified by:

addArpResponderFlowsToExternalNetworkIps in interface IVpnManager

removeArpResponderFlowsToExternalNetworkIps

public void removeArpResponderFlowsToExternalNetworkIps(String id,
                                                        Collection<String> fixedIps,
                                                        String macAddress,
                                                        BigInteger dpnId,
                                                        org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid extNetworkId)

Specified by:

removeArpResponderFlowsToExternalNetworkIps in interface IVpnManager

removeArpResponderFlowsToExternalNetworkIps

public void removeArpResponderFlowsToExternalNetworkIps(String id,
                                                        Collection<String> fixedIps,
                                                        BigInteger dpnId,
                                                        String extInterfaceName,
                                                        int lportTag)

Specified by:

removeArpResponderFlowsToExternalNetworkIps in interface IVpnManager

getPrimaryRdFromVpnInstance

public String getPrimaryRdFromVpnInstance(VpnInstance vpnInstance)

Specified by:

getPrimaryRdFromVpnInstance in interface IVpnManager

onSubnetAddedToVpn

public void onSubnetAddedToVpn(Subnetmap subnetmap,
                               boolean isBgpVpn,
                               Long elanTag)

Specified by:

onSubnetAddedToVpn in interface IVpnManager

onSubnetDeletedFromVpn

public void onSubnetDeletedFromVpn(Subnetmap subnetmap,
                                   boolean isBgpVpn)

Specified by:

onSubnetDeletedFromVpn in interface IVpnManager

getVpnInstance

@Nullable
public VpnInstance getVpnInstance(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                            String vpnInstanceName)

Specified by:

getVpnInstance in interface IVpnManager

getVpnRd

public String getVpnRd(org.opendaylight.genius.infra.TypedReadTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                       String vpnName)

Specified by:

getVpnRd in interface IVpnManager

getVpnRd

public String getVpnRd(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                       String vpnName)

Specified by:

getVpnRd in interface IVpnManager

getNeutronPortFromVpnPortFixedIp

public VpnPortipToPort getNeutronPortFromVpnPortFixedIp(org.opendaylight.genius.infra.TypedReadTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx,
                                                        String vpnName,
                                                        String fixedIp)

Specified by:

getNeutronPortFromVpnPortFixedIp in interface IVpnManager

getNeutronPortFromVpnPortFixedIp

@Nullable
public VpnPortipToPort getNeutronPortFromVpnPortFixedIp(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                                                  String vpnName,
                                                                  String fixedIp)

Specified by:

getNeutronPortFromVpnPortFixedIp in interface IVpnManager

getRtListForVpn

public Set<VpnTarget> getRtListForVpn(String vpnName)

Specified by:

getRtListForVpn in interface IVpnManager

updateRouteTargetsToSubnetAssociation

public void updateRouteTargetsToSubnetAssociation(Set<VpnTarget> routeTargets,
                                                  String cidr,
                                                  String vpnName)

Specified by:

updateRouteTargetsToSubnetAssociation in interface IVpnManager

removeRouteTargetsToSubnetAssociation

public void removeRouteTargetsToSubnetAssociation(Set<VpnTarget> routeTargets,
                                                  String cidr,
                                                  String vpnName)

Specified by:

removeRouteTargetsToSubnetAssociation in interface IVpnManager

checkForOverlappingSubnets

public boolean checkForOverlappingSubnets(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid network,
                                          List<Subnetmap> subnetmapList,
                                          org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid vpn,
                                          Set<VpnTarget> routeTargets,
                                          List<String> failedNwList)

Specified by:

checkForOverlappingSubnets in interface IVpnManager