org.opendaylight.netvirt.dhcpservice

Class DhcpExternalTunnelManager

java.lang.Object

org.opendaylight.netvirt.dhcpservice.DhcpExternalTunnelManager

@Singleton
public class DhcpExternalTunnelManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	UNKNOWN_DMAC

Constructor Summary

Constructors

Constructor and Description

DhcpExternalTunnelManager(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalUtil, org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService, org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService, org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, L2GatewayCache l2GatewayCache, IElanService ielanService)

Method Summary

Modifier and Type	Method and Description
void	addOrRemoveDhcpArpFlowforElan(String elanInstanceName, boolean addFlow, String dhcpIpAddress, String dhcpMacAddress)
void	configureDhcpArpRequestResponseFlow(BigInteger dpnId, String elanInstanceName, boolean addFlow, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String dhcpIpAddress, String dhcpMacAddress)
org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.RemoteMcastMacs	createRemoteMcastMac(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node dstDevice, String logicalSwitchName, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress internalTunnelIp)
BigInteger	designateDpnId(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName, List<BigInteger> dpns)
String	getExternalTunnelInterfaceName(String sourceNode, String dstNode)
static com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>	getNode(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, String physicalSwitchNodeId)
Optional<SubnetToDhcpPort>	getSubnetDhcpPortData(String elanInstanceName)
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress	getTunnelIpBasedOnElan(String elanInstanceName, String vmMacAddress)
void	handleDesignatedDpnDown(BigInteger dpnId, List<BigInteger> listOfDpns)
List<com.google.common.util.concurrent.ListenableFuture<Void>>	handleTunnelStateDown(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, BigInteger interfaceDpn)
List<com.google.common.util.concurrent.ListenableFuture<Void>>	handleTunnelStateUp(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, BigInteger interfaceDpn)
void	init()
void	installDhcpDropActionOnDpn(BigInteger dpId)
void	installDhcpFlowsForVms(BigInteger designatedDpnId, Set<String> listVmMacAddress, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	installDhcpFlowsForVms(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName, List<BigInteger> dpns, BigInteger designatedDpnId, String vmMacAddress)
void	installRemoteMcastMac(BigInteger designatedDpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)
BigInteger	readDesignatedSwitchesForExternalTunnel(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)
org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port	readVniMacToPortCache(BigInteger vni, String macAddress)
void	removeDesignatedSwitchForExternalTunnel(BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)
void	removeFromAvailableCache(org.apache.commons.lang3.tuple.Pair<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress,String> tunnelIpElanName)
void	removeFromLocalCache(BigInteger designatedDpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)
void	removeVniMacToPortCache(BigInteger vni, String macAddress)
void	unInstallDhcpEntries(BigInteger dpnId, String vmMacAddress, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	unInstallDhcpFlowsForVms(String elanInstanceName, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, List<BigInteger> dpns)
void	unInstallDhcpFlowsForVms(String elanInstanceName, List<BigInteger> dpns, String vmMacAddress)
void	updateCacheAndInstallNewFlows(List<BigInteger> listOfDpns, org.apache.commons.lang3.tuple.Pair<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress,String> pair, org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)
void	updateExistingVMTunnelIPCache(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName, String vmMacAddress)
void	updateLocalCache(BigInteger designatedDpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)
void	updateLocalCache(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName, String vmMacAddress)
void	updateVniMacToPortCache(BigInteger vni, String macAddress, org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port port)
void	writeDesignatedSwitchForExternalTunnel(BigInteger dpnId, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp, String elanInstanceName)

Methods inherited from class java.lang.Object

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

Field Detail

UNKNOWN_DMAC

public static final String UNKNOWN_DMAC

See Also:

Constant Field Values

Constructor Detail

DhcpExternalTunnelManager

@Inject
public DhcpExternalTunnelManager(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                         org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalUtil,
                                         org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService itmRpcService,
                                         org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService,
                                         org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager interfaceManager,
                                         org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                                         L2GatewayCache l2GatewayCache,
                                         @Named(value="elanService")
                                         IElanService ielanService)

Method Detail

init

@PostConstruct
public void init()

designateDpnId

public BigInteger designateDpnId(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                 String elanInstanceName,
                                 List<BigInteger> dpns)

installDhcpFlowsForVms

public void installDhcpFlowsForVms(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                   String elanInstanceName,
                                   List<BigInteger> dpns,
                                   BigInteger designatedDpnId,
                                   String vmMacAddress)

installDhcpFlowsForVms

public void installDhcpFlowsForVms(BigInteger designatedDpnId,
                                   Set<String> listVmMacAddress,
                                   org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

unInstallDhcpFlowsForVms

public void unInstallDhcpFlowsForVms(String elanInstanceName,
                                     List<BigInteger> dpns,
                                     String vmMacAddress)

unInstallDhcpFlowsForVms

public void unInstallDhcpFlowsForVms(String elanInstanceName,
                                     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                     List<BigInteger> dpns)

readDesignatedSwitchesForExternalTunnel

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

writeDesignatedSwitchForExternalTunnel

public void writeDesignatedSwitchForExternalTunnel(BigInteger dpnId,
                                                   org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                   String elanInstanceName)

removeDesignatedSwitchForExternalTunnel

public void removeDesignatedSwitchForExternalTunnel(BigInteger dpnId,
                                                    org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                    String elanInstanceName)

installDhcpDropActionOnDpn

public void installDhcpDropActionOnDpn(BigInteger dpId)

updateLocalCache

public void updateLocalCache(BigInteger designatedDpnId,
                             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                             String elanInstanceName)

updateLocalCache

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

updateExistingVMTunnelIPCache

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

handleDesignatedDpnDown

public void handleDesignatedDpnDown(BigInteger dpnId,
                                    List<BigInteger> listOfDpns)

updateCacheAndInstallNewFlows

public void updateCacheAndInstallNewFlows(List<BigInteger> listOfDpns,
                                          org.apache.commons.lang3.tuple.Pair<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress,String> pair,
                                          org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

addOrRemoveDhcpArpFlowforElan

public void addOrRemoveDhcpArpFlowforElan(String elanInstanceName,
                                          boolean addFlow,
                                          String dhcpIpAddress,
                                          String dhcpMacAddress)

configureDhcpArpRequestResponseFlow

public void configureDhcpArpRequestResponseFlow(BigInteger dpnId,
                                                String elanInstanceName,
                                                boolean addFlow,
                                                org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                String dhcpIpAddress,
                                                String dhcpMacAddress)

getSubnetDhcpPortData

public Optional<SubnetToDhcpPort> getSubnetDhcpPortData(String elanInstanceName)

unInstallDhcpEntries

public void unInstallDhcpEntries(BigInteger dpnId,
                                 String vmMacAddress,
                                 org.opendaylight.controller.md.sal.binding.api.WriteTransaction tx)

handleTunnelStateDown

public List<com.google.common.util.concurrent.ListenableFuture<Void>> handleTunnelStateDown(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                                                            BigInteger interfaceDpn)

removeFromLocalCache

public void removeFromLocalCache(BigInteger designatedDpnId,
                                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                 String elanInstanceName)

updateVniMacToPortCache

public void updateVniMacToPortCache(BigInteger vni,
                                    String macAddress,
                                    org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port port)

removeVniMacToPortCache

public void removeVniMacToPortCache(BigInteger vni,
                                    String macAddress)

readVniMacToPortCache

public org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port readVniMacToPortCache(BigInteger vni,
                                                                                                                               String macAddress)

getExternalTunnelInterfaceName

public String getExternalTunnelInterfaceName(String sourceNode,
                                             String dstNode)

getNode

public static com.google.common.base.Optional<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> getNode(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                                                                                                                                                                         String physicalSwitchNodeId)

createRemoteMcastMac

public org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.RemoteMcastMacs createRemoteMcastMac(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node dstDevice,
                                                                                                                                                             String logicalSwitchName,
                                                                                                                                                             org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress internalTunnelIp)

installRemoteMcastMac

public void installRemoteMcastMac(BigInteger designatedDpnId,
                                  org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                  String elanInstanceName)

handleTunnelStateUp

public List<com.google.common.util.concurrent.ListenableFuture<Void>> handleTunnelStateUp(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress tunnelIp,
                                                                                          BigInteger interfaceDpn)

removeFromAvailableCache

public void removeFromAvailableCache(org.apache.commons.lang3.tuple.Pair<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress,String> tunnelIpElanName)

getTunnelIpBasedOnElan

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