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	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	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.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> 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.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> flowTx)
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.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> deleteFlowGroupTx)
void	setupFilterEqualsTable(ElanInstance elanInfo, org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)
void	setupTerminateServiceTable(ElanInstance elanInfo, BigInteger dpId, long elanTag, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)
void	setupTerminateServiceTable(ElanInstance elanInfo, BigInteger dpId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)
void	setupUnknownDMacTable(ElanInstance elanInfo, BigInteger dpId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)
protected void	unbindService(String interfaceName, org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> tx)
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)

setupFilterEqualsTable

public void setupFilterEqualsTable(ElanInstance elanInfo,
                                   org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                   org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)

removeFilterEqualsTable

public void removeFilterEqualsTable(ElanInstance elanInfo,
                                    org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                    org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> flowTx)
                             throws ExecutionException,
                                    InterruptedException

Throws:

ExecutionException

InterruptedException

installDMacAddressTables

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

removeLocalBroadcastGroup

public void removeLocalBroadcastGroup(ElanInstance elanInfo,
                                      org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                      org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> deleteFlowGroupTx)
                               throws ExecutionException,
                                      InterruptedException

Throws:

ExecutionException

InterruptedException

removeElanBroadcastGroup

public void removeElanBroadcastGroup(ElanInstance elanInfo,
                                     org.opendaylight.genius.interfacemanager.globals.InterfaceInfo interfaceInfo,
                                     org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> deleteFlowGroupTx)
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException

setupTerminateServiceTable

public void setupTerminateServiceTable(ElanInstance elanInfo,
                                       BigInteger dpId,
                                       org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)

setupTerminateServiceTable

public void setupTerminateServiceTable(ElanInstance elanInfo,
                                       BigInteger dpId,
                                       long elanTag,
                                       org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)

setupUnknownDMacTable

public void setupUnknownDMacTable(ElanInstance elanInfo,
                                  BigInteger dpId,
                                  org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> writeFlowGroupTx)

unbindService

protected void unbindService(String interfaceName,
                             org.opendaylight.genius.infra.TypedReadWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> tx)
                      throws ExecutionException,
                             InterruptedException

Throws:

ExecutionException

InterruptedException

handleInternalTunnelStateEvent

public void handleInternalTunnelStateEvent(BigInteger srcDpId,
                                           BigInteger dstDpId)

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)