org.opendaylight.netvirt.vpnmanager

Class VpnInterfaceManager

java.lang.Object

org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

org.opendaylight.netvirt.vpnmanager.VpnInterfaceManager

All Implemented Interfaces:

AutoCloseable, EventListener, org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<VpnInterface>, org.opendaylight.genius.datastoreutils.ChainableDataTreeChangeListener<VpnInterface>

public class VpnInterfaceManager
extends org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>
implements AutoCloseable

Nested Class Summary

Nested classes/interfaces inherited from class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase

org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase.DataTreeChangeHandler

Field Summary

Fields inherited from class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase

clazz

Constructor Summary

Constructors

Constructor and Description

VpnInterfaceManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, IBgpManager bgpManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.arputil.rev160406.OdlArputilService arpManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, IFibManager fibManager, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService ifaceMgrRpcService, VpnFootprintService vpnFootprintService, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, IVpnManager vpnManager, IVpnLinkService ivpnLnkSrvce, ArpResponderHandler arpResponderHandler)

Method Summary

Modifier and Type	Method and Description
void	add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface vpnInterface)
protected void	addExtraRoute(String vpnName, String destination, String nextHop, String rd, String routerID, int label, Long l3vni, RouteOrigin origin, String intfName, Adjacency operationalAdj, VrfEntryBase.EncapType encapType, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
protected void	addNewAdjToVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, String primaryRd, Adjacency adj, BigInteger dpnId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
void	addToLabelMapper(Long label, BigInteger dpnId, String prefix, List<String> nextHopIpList, Long vpnId, String vpnInterfaceName, Long elanTag, boolean isSubnetRoute, String rd)
protected void	addToNeutronRouterDpnsMap(String routerName, String vpnInterfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)
protected void	createFibEntryForRouterInterface(String primaryRd, VpnInterface vpnInterface, String interfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
protected void	delAdjFromVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, Adjacency adj, BigInteger dpnId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
protected void	deleteFibEntryForRouterInterface(VpnInterface vpnInterface, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
void	deleteSubnetRouteFibEntryFromDS(String rd, String prefix, String vpnName)
protected void	delExtraRoute(String vpnName, String destination, String nextHop, String rd, String routerID, String intfName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
protected VpnInterfaceManager	getDataTreeChangeListener()
List<VpnInstanceOpDataEntry>	getVpnsImportingMyRoute(String vpnName)
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface>	getWildCardPath()
void	importSubnetRouteForNewVpn(String rd, String prefix, String nextHop, int label, SubnetRoute route, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
Runnable	isNotifyTaskQueued(String intfName)
boolean	isVpnInstanceReady(String vpnInstanceName)
void	processSavedInterfaces(String vpnInstanceName, boolean hasVpnInstanceCreatedSuccessfully)
protected void	processVpnInterfaceAdjacencies(BigInteger dpnId, int lportTag, String vpnName, String primaryRd, String interfaceName, long vpnId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState)
protected void	processVpnInterfaceDown(BigInteger dpId, String interfaceName, int lportTag, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState, VpnInterface vpnOpInterface, boolean isInterfaceStateDown, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn)
protected void	processVpnInterfaceUp(BigInteger dpId, VpnInterface vpnInterface, String primaryRd, int lportTag, boolean isInterfaceUp, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState)
void	remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface vpnInterface)
protected void	removeFromNeutronRouterDpnsMap(String routerName, String vpnInterfaceName, BigInteger dpId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)
protected void	removeFromNeutronRouterDpnsMap(String routerName, String vpnInterfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)
void	start()
protected void	update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface original, VpnInterface update)
void	updateVpnInterfaceOnTepAdd(VpnInterface vpnInterface, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList stateTunnelList, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)
void	updateVpnInterfaceOnTepDelete(VpnInterface vpnInterface, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList stateTunnelList, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)
void	updateVpnInterfacesForUnProcessAdjancencies(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, String vpnName)
void	vpnInstanceFailed(String vpnInstanceName)
void	vpnInstanceIsReady(String vpnInstanceName)

Methods inherited from class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase

addAfterListener, addBeforeListener, close, init, onDataTreeChanged, registerListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

VpnInterfaceManager

public VpnInterfaceManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                           IBgpManager bgpManager,
                           org.opendaylight.yang.gen.v1.urn.opendaylight.genius.arputil.rev160406.OdlArputilService arpManager,
                           org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService idManager,
                           org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                           IFibManager fibManager,
                           org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService ifaceMgrRpcService,
                           VpnFootprintService vpnFootprintService,
                           org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                           IVpnManager vpnManager,
                           IVpnLinkService ivpnLnkSrvce,
                           ArpResponderHandler arpResponderHandler)

Method Detail

isNotifyTaskQueued

public Runnable isNotifyTaskQueued(String intfName)

start

public void start()

getWildCardPath

protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> getWildCardPath()

Specified by:

getWildCardPath in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

getDataTreeChangeListener

protected VpnInterfaceManager getDataTreeChangeListener()

Specified by:

getDataTreeChangeListener in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

add

public void add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier,
                VpnInterface vpnInterface)

Specified by:

add in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

processVpnInterfaceUp

protected void processVpnInterfaceUp(BigInteger dpId,
                                     VpnInterface vpnInterface,
                                     String primaryRd,
                                     int lportTag,
                                     boolean isInterfaceUp,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn,
                                     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState)

processVpnInterfaceAdjacencies

protected void processVpnInterfaceAdjacencies(BigInteger dpnId,
                                              int lportTag,
                                              String vpnName,
                                              String primaryRd,
                                              String interfaceName,
                                              long vpnId,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn,
                                              org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState)

updateVpnInterfaceOnTepAdd

public void updateVpnInterfaceOnTepAdd(VpnInterface vpnInterface,
                                       org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList stateTunnelList,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)

updateVpnInterfaceOnTepDelete

public void updateVpnInterfaceOnTepDelete(VpnInterface vpnInterface,
                                          org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList stateTunnelList,
                                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)

getVpnsImportingMyRoute

public List<VpnInstanceOpDataEntry> getVpnsImportingMyRoute(String vpnName)

remove

public void remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier,
                   VpnInterface vpnInterface)

Specified by:

remove in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

processVpnInterfaceDown

protected void processVpnInterfaceDown(BigInteger dpId,
                                       String interfaceName,
                                       int lportTag,
                                       org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState,
                                       VpnInterface vpnOpInterface,
                                       boolean isInterfaceStateDown,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeInvTxn)

update

protected void update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier,
                      VpnInterface original,
                      VpnInterface update)

Specified by:

update in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

addToLabelMapper

public void addToLabelMapper(Long label,
                             BigInteger dpnId,
                             String prefix,
                             List<String> nextHopIpList,
                             Long vpnId,
                             String vpnInterfaceName,
                             Long elanTag,
                             boolean isSubnetRoute,
                             String rd)

importSubnetRouteForNewVpn

public void importSubnetRouteForNewVpn(String rd,
                                       String prefix,
                                       String nextHop,
                                       int label,
                                       SubnetRoute route,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

deleteSubnetRouteFibEntryFromDS

public void deleteSubnetRouteFibEntryFromDS(String rd,
                                            String prefix,
                                            String vpnName)

addNewAdjToVpnInterface

protected void addNewAdjToVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier,
                                       String primaryRd,
                                       Adjacency adj,
                                       BigInteger dpnId,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

delAdjFromVpnInterface

protected void delAdjFromVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier,
                                      Adjacency adj,
                                      BigInteger dpnId,
                                      org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn,
                                      org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

addExtraRoute

protected void addExtraRoute(String vpnName,
                             String destination,
                             String nextHop,
                             String rd,
                             String routerID,
                             int label,
                             Long l3vni,
                             RouteOrigin origin,
                             String intfName,
                             Adjacency operationalAdj,
                             VrfEntryBase.EncapType encapType,
                             org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

delExtraRoute

protected void delExtraRoute(String vpnName,
                             String destination,
                             String nextHop,
                             String rd,
                             String routerID,
                             String intfName,
                             org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

addToNeutronRouterDpnsMap

protected void addToNeutronRouterDpnsMap(String routerName,
                                         String vpnInterfaceName,
                                         org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)

removeFromNeutronRouterDpnsMap

protected void removeFromNeutronRouterDpnsMap(String routerName,
                                              String vpnInterfaceName,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)

removeFromNeutronRouterDpnsMap

protected void removeFromNeutronRouterDpnsMap(String routerName,
                                              String vpnInterfaceName,
                                              BigInteger dpId,
                                              org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeOperTxn)

createFibEntryForRouterInterface

protected void createFibEntryForRouterInterface(String primaryRd,
                                                VpnInterface vpnInterface,
                                                String interfaceName,
                                                org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

deleteFibEntryForRouterInterface

protected void deleteFibEntryForRouterInterface(VpnInterface vpnInterface,
                                                org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

isVpnInstanceReady

public boolean isVpnInstanceReady(String vpnInstanceName)

processSavedInterfaces

public void processSavedInterfaces(String vpnInstanceName,
                                   boolean hasVpnInstanceCreatedSuccessfully)

vpnInstanceIsReady

public void vpnInstanceIsReady(String vpnInstanceName)

vpnInstanceFailed

public void vpnInstanceFailed(String vpnInstanceName)

updateVpnInterfacesForUnProcessAdjancencies

public void updateVpnInterfacesForUnProcessAdjancencies(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                                        String vpnName)