2 * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.netvirt.dhcpservice.jobs;
10 import com.google.common.base.Optional;
11 import com.google.common.util.concurrent.FutureCallback;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import java.math.BigInteger;
14 import java.util.ArrayList;
15 import java.util.Collections;
16 import java.util.List;
17 import java.util.concurrent.Callable;
18 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
20 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
21 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
22 import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
23 import org.opendaylight.genius.mdsalutil.MDSALDataStoreUtils;
24 import org.opendaylight.genius.mdsalutil.MDSALUtil;
25 import org.opendaylight.netvirt.dhcpservice.DhcpExternalTunnelManager;
26 import org.opendaylight.netvirt.dhcpservice.DhcpManager;
27 import org.opendaylight.netvirt.dhcpservice.DhcpServiceUtils;
28 import org.opendaylight.netvirt.elan.arp.responder.ArpResponderInput;
29 import org.opendaylight.netvirt.elanmanager.api.IElanService;
30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dhcpservice.api.rev150710.InterfaceNameMacAddresses;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dhcpservice.api.rev150710._interface.name.mac.addresses.InterfaceNameMacAddress;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dhcpservice.api.rev150710._interface.name.mac.addresses.InterfaceNameMacAddressKey;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dhcpservice.api.rev150710.subnet.dhcp.port.data.SubnetToDhcpPort;
38 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
39 import org.slf4j.Logger;
40 import org.slf4j.LoggerFactory;
42 public class DhcpInterfaceRemoveJob implements Callable<List<ListenableFuture<Void>>> {
44 private static final Logger LOG = LoggerFactory.getLogger(DhcpInterfaceRemoveJob.class);
46 private static final FutureCallback<Void> DEFAULT_CALLBACK = new FutureCallback<Void>() {
48 public void onSuccess(Void result) {
49 LOG.debug("Success in Datastore write operation");
53 public void onFailure(Throwable error) {
54 LOG.error("Error in Datastore write operation", error);
58 private final DhcpManager dhcpManager;
59 private final DhcpExternalTunnelManager dhcpExternalTunnelManager;
60 private final DataBroker dataBroker;
61 private final ManagedNewTransactionRunner txRunner;
62 private final Interface interfaceDel;
63 private final BigInteger dpnId;
64 private final IInterfaceManager interfaceManager;
65 private final IElanService elanService;
66 private final Port port;
68 public DhcpInterfaceRemoveJob(DhcpManager dhcpManager, DhcpExternalTunnelManager dhcpExternalTunnelManager,
69 DataBroker dataBroker,
70 Interface interfaceDel, BigInteger dpnId, IInterfaceManager interfaceManager,
71 IElanService elanService, Port port) {
72 this.dhcpManager = dhcpManager;
73 this.dhcpExternalTunnelManager = dhcpExternalTunnelManager;
74 this.dataBroker = dataBroker;
75 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
76 this.interfaceDel = interfaceDel;
78 this.interfaceManager = interfaceManager;
79 this.elanService = elanService;
84 public List<ListenableFuture<Void>> call() {
85 String interfaceName = interfaceDel.getName();
86 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface =
87 interfaceManager.getInterfaceInfoFromConfigDataStore(interfaceName);
89 IfTunnel tunnelInterface = iface.getAugmentation(IfTunnel.class);
90 if (tunnelInterface != null && !tunnelInterface.isInternal()) {
91 IpAddress tunnelIp = tunnelInterface.getTunnelDestination();
92 List<BigInteger> dpns = DhcpServiceUtils.getListOfDpns(dataBroker);
93 if (dpns.contains(dpnId)) {
94 return dhcpExternalTunnelManager.handleTunnelStateDown(tunnelIp, dpnId);
96 return Collections.emptyList();
99 List<ListenableFuture<Void>> futures = new ArrayList<>();
100 // Support for VM migration use cases.
101 futures.add(txRunner.callWithNewWriteOnlyTransactionAndSubmit(
102 tx -> DhcpServiceUtils.unbindDhcpService(interfaceName, tx)));
103 java.util.Optional<String> subnetId = DhcpServiceUtils.getNeutronSubnetId(port);
104 if (subnetId.isPresent()) {
105 java.util.Optional<SubnetToDhcpPort> subnetToDhcp = DhcpServiceUtils.getSubnetDhcpPortData(dataBroker,
107 if (subnetToDhcp.isPresent()) {
108 LOG.trace("Removing ArpResponder flow for last interface {} on DPN {}", interfaceName, dpnId);
109 ArpResponderInput arpInput = new ArpResponderInput.ArpReponderInputBuilder().setDpId(dpnId)
110 .setInterfaceName(interfaceName).setSpa(subnetToDhcp.get().getPortFixedip())
111 .setLportTag(interfaceDel.getIfIndex()).buildForRemoveFlow();
112 elanService.removeArpResponderFlow(arpInput);
115 futures.addAll(unInstallDhcpEntries(interfaceDel.getName(), dpnId));
119 private List<ListenableFuture<Void>> unInstallDhcpEntries(String interfaceName, BigInteger dpId) {
120 String vmMacAddress = getAndRemoveVmMacAddress(interfaceName);
121 return Collections.singletonList(txRunner.callWithNewWriteOnlyTransactionAndSubmit(
122 tx -> dhcpManager.unInstallDhcpEntries(dpId, vmMacAddress, tx)));
125 private String getAndRemoveVmMacAddress(String interfaceName) {
126 InstanceIdentifier<InterfaceNameMacAddress> instanceIdentifier =
127 InstanceIdentifier.builder(InterfaceNameMacAddresses.class)
128 .child(InterfaceNameMacAddress.class, new InterfaceNameMacAddressKey(interfaceName)).build();
129 Optional<InterfaceNameMacAddress> existingEntry =
130 MDSALUtil.read(dataBroker, LogicalDatastoreType.OPERATIONAL, instanceIdentifier);
131 if (existingEntry.isPresent()) {
132 String vmMacAddress = existingEntry.get().getMacAddress();
133 LOG.trace("Entry for interface found in InterfaceNameVmMacAddress map {}, {}", interfaceName, vmMacAddress);
134 MDSALDataStoreUtils.asyncRemove(dataBroker, LogicalDatastoreType.OPERATIONAL,
135 instanceIdentifier, DEFAULT_CALLBACK);
138 LOG.trace("Entry for interface {} missing in InterfaceNameVmMacAddress map", interfaceName);