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.serviceutils.tools.mdsal.listener.ChainableDataTreeChangeListener<VpnInterface>

@Singleton
public class VpnInterfaceManager
extends org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<VpnInterface,VpnInterfaceManager>

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.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, ArpResponderHandler arpResponderHandler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, org.opendaylight.infrautils.caches.CacheProvider cacheProvider)

Method Summary

Modifier and Type	Method and Description
void	add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface vpnInterface)
protected void	addNewAdjToVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterfaceOpDataEntry> 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	close()
protected void	createFibEntryForRouterInterface(String primaryRd, VpnInterface vpnInterface, String interfaceName, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, String vpnName)
protected void	delAdjFromVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterfaceOpDataEntry> identifier, Adjacency adj, BigInteger dpnId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)
protected void	deleteFibEntryForRouterInterface(VpnInterface vpnInterface, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn, String vpnName)
protected VpnInterfaceManager	getDataTreeChangeListener()
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface>	getWildCardPath()
void	importSubnetRouteForNewVpn(String rd, String prefix, String nextHop, int label, SubnetRoute route, String parentVpnRd, 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, String gwMac, VpnInterfaceOpDataEntry 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, String vpnName)
void	remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface vpnInterface)
void	start()
protected void	update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterface> identifier, VpnInterface original, VpnInterface update)
void	updateVpnInterfaceOnTepAdd(VpnInterfaceOpDataEntry 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(VpnInterfaceOpDataEntry 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(String vpnName)
void	vpnInstanceFailed(String vpnInstanceName)
void	vpnInstanceIsReady(String vpnInstanceName)

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

addAfterListener, addBeforeListener, deregisterListener, init, onDataTreeChanged, registerListener

Methods inherited from class java.lang.Object

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

Constructor Detail

VpnInterfaceManager

@Inject
public VpnInterfaceManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                   IBgpManager bgpManager,
                                   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,
                                   ArpResponderHandler arpResponderHandler,
                                   org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                                   org.opendaylight.infrautils.caches.CacheProvider cacheProvider)

Method Detail

isNotifyTaskQueued

public Runnable isNotifyTaskQueued(String intfName)

start

@PostConstruct
public void start()

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

Overrides:

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

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,
                                     String vpnName)

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(VpnInterfaceOpDataEntry 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(VpnInterfaceOpDataEntry 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)

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,
                                       String gwMac,
                                       VpnInterfaceOpDataEntry 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>

importSubnetRouteForNewVpn

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

addNewAdjToVpnInterface

protected void addNewAdjToVpnInterface(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<VpnInterfaceOpDataEntry> 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<VpnInterfaceOpDataEntry> identifier,
                                      Adjacency adj,
                                      BigInteger dpnId,
                                      org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeConfigTxn)

createFibEntryForRouterInterface

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

deleteFibEntryForRouterInterface

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

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(String vpnName)