org.opendaylight.netvirt.elan.evpn.utils

Class EvpnUtils

java.lang.Object

org.opendaylight.netvirt.elan.evpn.utils.EvpnUtils

@Singleton
public class EvpnUtils
extends Object

Constructor Summary

Constructors

Constructor and Description

EvpnUtils(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, ElanUtils elanUtils, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService, IVpnManager vpnManager, IBgpManager bgpManager, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, ElanInstanceCache elanInstanceCache)

Method Summary

Modifier and Type	Method and Description
void	advertiseEvpnRT2Routes(EvpnAugmentation evpnAugmentation, String elanName)
void	advertisePrefix(ElanInstance elanInfo, MacEntry macEntry)
void	advertisePrefix(ElanInstance elanInfo, String macAddress, String prefix, String interfaceName, BigInteger dpnId)
void	advertisePrefix(ElanInstance elanInfo, String rd, String macAddress, String prefix, String interfaceName, BigInteger dpnId)
<T extends org.opendaylight.yangtools.yang.binding.DataObject> void	asyncReadAndExecute(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid, String jobKey, Function<com.google.common.base.Optional<T>,Void> function)
void	bindElanServiceToExternalTunnel(String elanName, String interfaceName)
com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList>	getDcGatewayIpList()
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList>	getDcGatewayIpListIdentifier()
List<String>	getDcGatewayTunnelInterfaceNameList()
String	getEndpointIpAddressForDPN(BigInteger dpnId)
static String	getEvpnNameFromElan(ElanInstance elanInfo)
String	getEvpnRd(ElanInstance elanInfo)
com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList>	getExternalTunnelList()
static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList>	getExternaTunnelListIdentifier()
com.google.common.base.Optional<String>	getGatewayMacAddressForInterface(String vpnName, String ifName, String ipAddress)
String	getL3vpnNameFromElan(ElanInstance elanInfo)
boolean	isAdvertiseEvpnRT2Routes(ElanInstance original, ElanInstance update)
boolean	isWithdrawEvpnRT2Routes(ElanInstance original, ElanInstance update)
void	programEvpnL2vniDemuxTable(String elanName, BiConsumer<String,String> serviceHandler, BiConsumer<BigInteger,org.opendaylight.genius.mdsalutil.FlowEntity> flowHandler)
void	unbindElanServiceFromExternalTunnel(String elanName, String interfaceName)
void	withdrawEvpnRT2Routes(EvpnAugmentation evpnAugmentation, String elanName)
void	withdrawPrefix(ElanInstance elanInfo, MacEntry macEntry)
void	withdrawPrefix(ElanInstance elanInfo, String prefix)

Methods inherited from class java.lang.Object

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

Constructor Detail

EvpnUtils

@Inject
public EvpnUtils(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                         org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                         ElanUtils elanUtils,
                         org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService,
                         IVpnManager vpnManager,
                         IBgpManager bgpManager,
                         org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                         ElanInstanceCache elanInstanceCache)

Method Detail

isWithdrawEvpnRT2Routes

public boolean isWithdrawEvpnRT2Routes(ElanInstance original,
                                       ElanInstance update)

isAdvertiseEvpnRT2Routes

public boolean isAdvertiseEvpnRT2Routes(ElanInstance original,
                                        ElanInstance update)

advertiseEvpnRT2Routes

public void advertiseEvpnRT2Routes(EvpnAugmentation evpnAugmentation,
                                   String elanName)

getEndpointIpAddressForDPN

public String getEndpointIpAddressForDPN(BigInteger dpnId)

getGatewayMacAddressForInterface

public com.google.common.base.Optional<String> getGatewayMacAddressForInterface(String vpnName,
                                                                                String ifName,
                                                                                String ipAddress)

getL3vpnNameFromElan

public String getL3vpnNameFromElan(ElanInstance elanInfo)

getEvpnNameFromElan

public static String getEvpnNameFromElan(ElanInstance elanInfo)

getEvpnRd

public String getEvpnRd(ElanInstance elanInfo)

advertisePrefix

public void advertisePrefix(ElanInstance elanInfo,
                            String macAddress,
                            String prefix,
                            String interfaceName,
                            BigInteger dpnId)

advertisePrefix

public void advertisePrefix(ElanInstance elanInfo,
                            String rd,
                            String macAddress,
                            String prefix,
                            String interfaceName,
                            BigInteger dpnId)

advertisePrefix

public void advertisePrefix(ElanInstance elanInfo,
                            MacEntry macEntry)

withdrawEvpnRT2Routes

public void withdrawEvpnRT2Routes(EvpnAugmentation evpnAugmentation,
                                  String elanName)

withdrawPrefix

public void withdrawPrefix(ElanInstance elanInfo,
                           String prefix)

withdrawPrefix

public void withdrawPrefix(ElanInstance elanInfo,
                           MacEntry macEntry)

getExternaTunnelListIdentifier

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList> getExternaTunnelListIdentifier()

getExternalTunnelList

public com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList> getExternalTunnelList()

getDcGatewayIpListIdentifier

public static org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList> getDcGatewayIpListIdentifier()

getDcGatewayIpList

public com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList> getDcGatewayIpList()

getDcGatewayTunnelInterfaceNameList

public List<String> getDcGatewayTunnelInterfaceNameList()

bindElanServiceToExternalTunnel

public void bindElanServiceToExternalTunnel(String elanName,
                                            String interfaceName)

unbindElanServiceFromExternalTunnel

public void unbindElanServiceFromExternalTunnel(String elanName,
                                                String interfaceName)

programEvpnL2vniDemuxTable

public void programEvpnL2vniDemuxTable(String elanName,
                                       BiConsumer<String,String> serviceHandler,
                                       BiConsumer<BigInteger,org.opendaylight.genius.mdsalutil.FlowEntity> flowHandler)

asyncReadAndExecute

public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void asyncReadAndExecute(org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType,
                                                                                               org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid,
                                                                                               String jobKey,
                                                                                               Function<com.google.common.base.Optional<T>,Void> function)