org.opendaylight.netvirt.elan.l2gw.utils

Class ElanL2GatewayMulticastUtils

java.lang.Object

org.opendaylight.netvirt.elan.l2gw.utils.ElanL2GatewayMulticastUtils

@Singleton
public class ElanL2GatewayMulticastUtils
extends Object

The utility class to handle ELAN L2 Gateway related to multicast.

Constructor Summary

Constructors

Constructor and Description
ElanL2GatewayMulticastUtils(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, ElanItmUtils elanItmUtils, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, ElanUtils elanUtils, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager)

Method Summary

Modifier and Type	Method and Description
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ExternalTeps>	buildExternalTepPath(String elan, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tepIp)
protected ExternalTeps	buildExternalTeps(L2GatewayDevice device)
DesignatedSwitchForTunnel	getDesignatedSwitchForExternalTunnel(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName) Gets the designated switch for external tunnel.
List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket>	getRemoteBCGroupBuckets(ElanInstance elanInfo, DpnInterfaces dpnInterfaces, BigInteger dpnId, int bucketId, long elanTag)
List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket>	getRemoteBCGroupBucketsOfElanExternalTeps(ElanInstance elanInfo, BigInteger dpnId, int bucketId)
List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket>	getRemoteBCGroupBucketsOfElanL2GwDevices(ElanInstance elanInfo, BigInteger dpnId, int bucketId)
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress	getTepIpOfDesignatedSwitchForExternalTunnel(L2GatewayDevice l2GwDevice, String elanInstanceName) Gets the tep ip of designated switch for external tunnel.
void	handleMcastForElanL2GwDeviceAdd(String elanName, L2GatewayDevice device) Handle mcast for elan l2 gw device add.
List<com.google.common.util.concurrent.ListenableFuture<Void>>	handleMcastForElanL2GwDeviceDelete(String elanName, L2GatewayDevice l2GatewayDevice) Handle mcast for elan l2 gw device delete.
void	prepareRemoteMcastMacUpdateOnDevice(String elanName, L2GatewayDevice device)
void	scheduleMcastMacUpdateJob(String elanName, L2GatewayDevice device)
void	setupElanBroadcastGroups(ElanInstance elanInfo, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	setupElanBroadcastGroups(ElanInstance elanInfo, DpnInterfaces dpnInterfaces, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	setupLeavesEtreeBroadcastGroups(ElanInstance elanInfo, DpnInterfaces dpnInterfaces, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	setupStandardElanBroadcastGroups(ElanInstance elanInfo, DpnInterfaces dpnInterfaces, BigInteger dpnId, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	updateRemoteBroadcastGroupForAllElanDpns(ElanInstance elanInfo, org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)
void	updateRemoteMcastMacOnElanL2GwDevice(String elanName, L2GatewayDevice device) Update remote mcast mac on elan l2 gw device.
void	updateRemoteMcastMacOnElanL2GwDevices(String elanName) Updates the remote mcast mac table for all the devices in this elan includes all the dpn tep ips and other devices tep ips in broadcast locator set.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElanL2GatewayMulticastUtils

@Inject
public ElanL2GatewayMulticastUtils(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                           ElanItmUtils elanItmUtils,
                                           org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                                           ElanUtils elanUtils,
                                           org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalManager,
                                           org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager)

Method Detail

handleMcastForElanL2GwDeviceAdd

public void handleMcastForElanL2GwDeviceAdd(String elanName,
                                            L2GatewayDevice device)

Handle mcast for elan l2 gw device add.

Parameters:

elanName - the elan name

device - the device

buildExternalTepPath

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<ExternalTeps> buildExternalTepPath(String elan,
                                                                                                            org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tepIp)

buildExternalTeps

protected ExternalTeps buildExternalTeps(L2GatewayDevice device)

updateRemoteMcastMacOnElanL2GwDevices

public void updateRemoteMcastMacOnElanL2GwDevices(String elanName)

Updates the remote mcast mac table for all the devices in this elan includes all the dpn tep ips and other devices tep ips in broadcast locator set.

Parameters:

elanName - the elan to be updated

scheduleMcastMacUpdateJob

public void scheduleMcastMacUpdateJob(String elanName,
                                      L2GatewayDevice device)

updateRemoteMcastMacOnElanL2GwDevice

public void updateRemoteMcastMacOnElanL2GwDevice(String elanName,
                                                 L2GatewayDevice device)

Update remote mcast mac on elan l2 gw device.

Parameters:

elanName - the elan name

device - the device

prepareRemoteMcastMacUpdateOnDevice

public void prepareRemoteMcastMacUpdateOnDevice(String elanName,
                                                L2GatewayDevice device)

updateRemoteBroadcastGroupForAllElanDpns

public void updateRemoteBroadcastGroupForAllElanDpns(ElanInstance elanInfo,
                                                     org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

setupElanBroadcastGroups

public void setupElanBroadcastGroups(ElanInstance elanInfo,
                                     BigInteger dpnId,
                                     org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

setupElanBroadcastGroups

public void setupElanBroadcastGroups(ElanInstance elanInfo,
                                     @Nullable
                                     DpnInterfaces dpnInterfaces,
                                     BigInteger dpnId,
                                     org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

setupStandardElanBroadcastGroups

public void setupStandardElanBroadcastGroups(ElanInstance elanInfo,
                                             @Nullable
                                             DpnInterfaces dpnInterfaces,
                                             BigInteger dpnId,
                                             org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

setupLeavesEtreeBroadcastGroups

public void setupLeavesEtreeBroadcastGroups(ElanInstance elanInfo,
                                            @Nullable
                                            DpnInterfaces dpnInterfaces,
                                            BigInteger dpnId,
                                            org.opendaylight.genius.infra.TypedWriteTransaction<org.opendaylight.genius.infra.Datastore.Configuration> confTx)

getRemoteBCGroupBuckets

@Nonnull
public List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket> getRemoteBCGroupBuckets(ElanInstance elanInfo,
                                                                                                                                       @Nullable
                                                                                                                                       DpnInterfaces dpnInterfaces,
                                                                                                                                       BigInteger dpnId,
                                                                                                                                       int bucketId,
                                                                                                                                       long elanTag)

getRemoteBCGroupBucketsOfElanL2GwDevices

public List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket> getRemoteBCGroupBucketsOfElanL2GwDevices(ElanInstance elanInfo,
                                                                                                                                               BigInteger dpnId,
                                                                                                                                               int bucketId)

getRemoteBCGroupBucketsOfElanExternalTeps

public List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket> getRemoteBCGroupBucketsOfElanExternalTeps(ElanInstance elanInfo,
                                                                                                                                                BigInteger dpnId,
                                                                                                                                                int bucketId)

handleMcastForElanL2GwDeviceDelete

public List<com.google.common.util.concurrent.ListenableFuture<Void>> handleMcastForElanL2GwDeviceDelete(String elanName,
                                                                                                         L2GatewayDevice l2GatewayDevice)

Handle mcast for elan l2 gw device delete.

Parameters:

elanName - the elan instance name

l2GatewayDevice - the l2 gateway device

Returns:

the listenable future

getTepIpOfDesignatedSwitchForExternalTunnel

public org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress getTepIpOfDesignatedSwitchForExternalTunnel(L2GatewayDevice l2GwDevice,
                                                                                                                                                String elanInstanceName)

Gets the tep ip of designated switch for external tunnel.

Parameters:

l2GwDevice - the l2 gw device

elanInstanceName - the elan instance name

Returns:

the tep ip of designated switch for external tunnel

getDesignatedSwitchForExternalTunnel

public DesignatedSwitchForTunnel getDesignatedSwitchForExternalTunnel(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                                      String elanInstanceName)

Gets the designated switch for external tunnel.

Parameters:

tunnelIp - the tunnel ip

elanInstanceName - the elan instance name

Returns:

the designated switch for external tunnel