2 * Copyright © 2016, 2017 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.vpnmanager;
10 import com.google.common.base.Optional;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.util.ArrayList;
13 import java.util.List;
14 import java.util.concurrent.Callable;
16 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
17 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
18 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
19 import org.opendaylight.genius.arputil.api.ArpConstants;
20 import org.opendaylight.genius.datastoreutils.SingleTransactionDataBroker;
21 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.interfaces.VpnInterface;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.alivenessmonitor.rev160411.AlivenessMonitorService;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.Adjacencies;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.adjacency.list.Adjacency;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.adjacency.list.AdjacencyKey;
26 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
27 import org.slf4j.Logger;
28 import org.slf4j.LoggerFactory;
30 public class ArpMonitorStopTask implements Callable<List<ListenableFuture<Void>>> {
31 private MacEntry macEntry;
32 private AlivenessMonitorService alivenessManager;
33 private DataBroker dataBroker;
34 private static final Logger LOG = LoggerFactory.getLogger(ArpMonitorStopTask.class);
36 public ArpMonitorStopTask(MacEntry macEntry, DataBroker dataBroker,
37 AlivenessMonitorService alivenessManager) {
38 this.macEntry = macEntry;
39 this.dataBroker = dataBroker;
40 this.alivenessManager = alivenessManager;
44 public List<ListenableFuture<Void>> call() throws Exception {
45 final List<ListenableFuture<Void>> futures = new ArrayList<>();
46 java.util.Optional<Long> monitorIdOptional = AlivenessMonitorUtils.getMonitorIdFromInterface(macEntry);
47 monitorIdOptional.ifPresent(monitorId -> {
48 AlivenessMonitorUtils.stopArpMonitoring(alivenessManager, monitorId);
49 removeMipAdjacency(macEntry.getIpAddress().getHostAddress(),
50 macEntry.getVpnName(), macEntry.getInterfaceName());
51 VpnUtil.removeLearntVpnVipToPort(dataBroker, macEntry.getVpnName(),
52 macEntry.getIpAddress().getHostAddress());
57 private void removeMipAdjacency(String fixedip, String vpnName, String interfaceName) {
58 synchronized (interfaceName.intern()) {
59 InstanceIdentifier<VpnInterface> vpnIfId = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
60 InstanceIdentifier<Adjacencies> path = vpnIfId.augmentation(Adjacencies.class);
61 Optional<Adjacencies> adjacencies = VpnUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, path);
62 if (adjacencies.isPresent()) {
63 InstanceIdentifier<Adjacency> adid = vpnIfId.augmentation(Adjacencies.class).child(Adjacency.class,
64 new AdjacencyKey(ipToPrefix(fixedip)));
66 SingleTransactionDataBroker.syncDelete(dataBroker, LogicalDatastoreType.CONFIGURATION, adid);
67 } catch (TransactionCommitFailedException e) {
68 LOG.error("Failed to delete the learned-ip-adjacency for vpn {} interface {} prefix {}",
69 vpnName, interfaceName, ipToPrefix(fixedip), e);
72 LOG.info("Successfully deleted the learned-ip-adjacency prefix {} on vpn {} for interface {}",
73 ipToPrefix(fixedip), vpnName, interfaceName);
78 private String ipToPrefix(String ip) {
79 return new StringBuilder(ip).append(ArpConstants.PREFIX).toString();