org.opendaylight.netvirt.elan.internal

Class ElanInterfaceManager

java.lang.Object

org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

org.opendaylight.netvirt.elan.internal.ElanInterfaceManager

All Implemented Interfaces:

AutoCloseable, EventListener, org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener<ElanInterface>, org.opendaylight.serviceutils.srm.RecoverableListener, org.opendaylight.serviceutils.tools.mdsal.listener.ChainableDataTreeChangeListener<ElanInterface>

@Singleton
public class ElanInterfaceManager
extends org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>
implements org.opendaylight.serviceutils.srm.RecoverableListener

Class in charge of handling creations, modifications and removals of ElanInterfaces.

See Also:

ElanInterface

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

ElanInterfaceManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService managerService, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, ElanForwardingEntriesHandler elanForwardingEntriesHandler, INeutronVpnManager neutronVpnManager, ElanItmUtils elanItmUtils, ElanEtreeUtils elanEtreeUtils, ElanL2GatewayUtils elanL2GatewayUtils, ElanUtils elanUtils, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils, ElanInstanceCache elanInstanceCache, ElanInterfaceCache elanInterfaceCache, ElanServiceRecoveryHandler elanServiceRecoveryHandler, org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry serviceRecoveryRegistry)

Method Summary

Modifier and Type	Method and Description
protected void	add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface> identifier, ElanInterface elanInterfaceAdded)
protected ElanInterfaceManager	getDataTreeChangeListener()
protected org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface>	getWildCardPath()
void	handleExternalInterfaceEvent(ElanInstance elanInstance, DpnInterfaces dpnInterfaces, BigInteger dpId)
void	handleExternalTunnelStateEvent(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel externalTunnel, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface intrf) Handle external tunnel state event.
void	handleInternalTunnelStateEvent(BigInteger srcDpId, BigInteger dstDpId)
void	init()
List<com.google.common.util.concurrent.ListenableFuture<Void>>	installDMacAddressTables(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, BigInteger dstDpId)
void	installEntriesForFirstInterfaceonDpn(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, DpnInterfaces dpnInterfaces, boolean isFirstInterfaceInDpn)
void	registerListener()
protected void	remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface> identifier, ElanInterface del)
void	removeElanBroadcastGroup(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)
List<com.google.common.util.concurrent.ListenableFuture<Void>>	removeElanInterface(ElanInstance elanInfo, String interfaceName, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)
void	removeFilterEqualsTable(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)
protected void	removeInterfaceStaticMacEntries(String elanInstanceName, String interfaceName, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.PhysAddress physAddress)
void	removeLocalBroadcastGroup(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)
void	setExternalTunnelTable(BigInteger dpnId, ElanInstance elanInfo) Installs a flow in the External Tunnel table consisting in translating the VNI retrieved from the packet that came over a tunnel with a TOR into elanTag that will be used later in the ELANs pipeline.
void	setupFilterEqualsTable(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)
void	setupLocalBroadcastGroups(ElanInstance elanInfo, DpnInterfaces newDpnInterface, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)
void	setupStandardLocalBroadcastGroups(ElanInstance elanInfo, DpnInterfaces newDpnInterface, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)
void	setupTerminateServiceTable(ElanInstance elanInfo, BigInteger dpId, long elanTag, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)
void	setupTerminateServiceTable(ElanInstance elanInfo, BigInteger dpId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)
void	setupUnknownDMacTable(ElanInstance elanInfo, BigInteger dpId, org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)
protected void	unbindService(String interfaceName, org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction tx)
void	unsetExternalTunnelTable(BigInteger dpnId, ElanInstance elanInfo) Removes, from External Tunnel table, the flow that translates from VNI to elanTag.
protected void	update(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface> identifier, ElanInterface original, ElanInterface update)

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

addAfterListener, addBeforeListener, close, deregisterListener, onDataTreeChanged, registerListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opendaylight.serviceutils.srm.RecoverableListener

deregisterListener

Constructor Detail

ElanInterfaceManager

@Inject
public ElanInterfaceManager(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                    org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService managerService,
                                    org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager,
                                    org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                                    ElanForwardingEntriesHandler elanForwardingEntriesHandler,
                                    INeutronVpnManager neutronVpnManager,
                                    ElanItmUtils elanItmUtils,
                                    ElanEtreeUtils elanEtreeUtils,
                                    ElanL2GatewayUtils elanL2GatewayUtils,
                                    ElanUtils elanUtils,
                                    org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                                    ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils,
                                    ElanInstanceCache elanInstanceCache,
                                    ElanInterfaceCache elanInterfaceCache,
                                    ElanServiceRecoveryHandler elanServiceRecoveryHandler,
                                    org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry serviceRecoveryRegistry)

Method Detail

init

@PostConstruct
public void init()

Overrides:

init in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

registerListener

public void registerListener()

Specified by:

registerListener in interface org.opendaylight.serviceutils.srm.RecoverableListener

getWildCardPath

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

Specified by:

getWildCardPath in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

remove

protected void remove(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface> identifier,
                      ElanInterface del)

Specified by:

remove in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

removeElanInterface

public List<com.google.common.util.concurrent.ListenableFuture<Void>> removeElanInterface(ElanInstance elanInfo,
                                                                                          String interfaceName,
                                                                                          org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)

update

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

Specified by:

update in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

add

protected void add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ElanInterface> identifier,
                   ElanInterface elanInterfaceAdded)

Specified by:

add in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

removeInterfaceStaticMacEntries

protected void removeInterfaceStaticMacEntries(String elanInstanceName,
                                               String interfaceName,
                                               org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.PhysAddress physAddress)

installEntriesForFirstInterfaceonDpn

public void installEntriesForFirstInterfaceonDpn(ElanInstance elanInfo,
                                                 org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                                 DpnInterfaces dpnInterfaces,
                                                 boolean isFirstInterfaceInDpn)

setupFilterEqualsTable

public void setupFilterEqualsTable(ElanInstance elanInfo,
                                   org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                   org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)

removeFilterEqualsTable

public void removeFilterEqualsTable(ElanInstance elanInfo,
                                    org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                    org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)

installDMacAddressTables

public List<com.google.common.util.concurrent.ListenableFuture<Void>> installDMacAddressTables(ElanInstance elanInfo,
                                                                                               org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                                                                               BigInteger dstDpId)
                                                                                        throws ElanException

Throws:

ElanException

setupLocalBroadcastGroups

public void setupLocalBroadcastGroups(ElanInstance elanInfo,
                                      DpnInterfaces newDpnInterface,
                                      org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)

setupStandardLocalBroadcastGroups

public void setupStandardLocalBroadcastGroups(ElanInstance elanInfo,
                                              DpnInterfaces newDpnInterface,
                                              org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo)

removeLocalBroadcastGroup

public void removeLocalBroadcastGroup(ElanInstance elanInfo,
                                      org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                      org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)

removeElanBroadcastGroup

public void removeElanBroadcastGroup(ElanInstance elanInfo,
                                     org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                     org.opendaylight.controller.md.sal.binding.api.WriteTransaction deleteFlowGroupTx)

setExternalTunnelTable

public void setExternalTunnelTable(BigInteger dpnId,
                                   ElanInstance elanInfo)

Installs a flow in the External Tunnel table consisting in translating the VNI retrieved from the packet that came over a tunnel with a TOR into elanTag that will be used later in the ELANs pipeline.

Parameters:

dpnId - the dpn id

elanInfo - the elan info

unsetExternalTunnelTable

public void unsetExternalTunnelTable(BigInteger dpnId,
                                     ElanInstance elanInfo)

Removes, from External Tunnel table, the flow that translates from VNI to elanTag. Important: ensure this method is only called whenever there is no other ElanInterface in the specified DPN

Parameters:

dpnId - DPN whose Ext Tunnel table is going to be modified

elanInfo - holds the elanTag needed for selecting the flow to be removed

setupTerminateServiceTable

public void setupTerminateServiceTable(ElanInstance elanInfo,
                                       BigInteger dpId,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)

setupTerminateServiceTable

public void setupTerminateServiceTable(ElanInstance elanInfo,
                                       BigInteger dpId,
                                       long elanTag,
                                       org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)

setupUnknownDMacTable

public void setupUnknownDMacTable(ElanInstance elanInfo,
                                  BigInteger dpId,
                                  org.opendaylight.controller.md.sal.binding.api.WriteTransaction writeFlowGroupTx)

unbindService

protected void unbindService(String interfaceName,
                             org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction tx)
                      throws org.opendaylight.controller.md.sal.common.api.data.ReadFailedException

Throws:

org.opendaylight.controller.md.sal.common.api.data.ReadFailedException

handleInternalTunnelStateEvent

public void handleInternalTunnelStateEvent(BigInteger srcDpId,
                                           BigInteger dstDpId)

handleExternalTunnelStateEvent

public void handleExternalTunnelStateEvent(org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel externalTunnel,
                                           org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface intrf)
                                    throws ElanException

Handle external tunnel state event.

Parameters:

externalTunnel - the external tunnel

intrf - the interface

Throws:

ElanException - in case of issues creating the flow objects

getDataTreeChangeListener

protected ElanInterfaceManager getDataTreeChangeListener()

Specified by:

getDataTreeChangeListener in class org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase<ElanInterface,ElanInterfaceManager>

handleExternalInterfaceEvent

public void handleExternalInterfaceEvent(ElanInstance elanInstance,
                                         DpnInterfaces dpnInterfaces,
                                         BigInteger dpId)