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.CheckedFuture;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import java.util.ArrayList;
14 import java.util.List;
15 import java.util.concurrent.Callable;
16 import java.util.concurrent.ExecutionException;
17 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
18 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
20 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
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) {
39 this.macEntry = macEntry;
40 this.dataBroker = dataBroker;
41 this.alivenessManager = alivenessManager;
45 public List<ListenableFuture<Void>> call() throws Exception {
46 final List<ListenableFuture<Void>> futures = new ArrayList<>();
47 WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
48 java.util.Optional<Long> monitorIdOptional = AlivenessMonitorUtils.getMonitorIdFromInterface(macEntry);
49 monitorIdOptional.ifPresent(aLong -> AlivenessMonitorUtils.stopArpMonitoring(alivenessManager, aLong));
50 removeMipAdjacency(macEntry.getIpAddress().getHostAddress(),
51 macEntry.getVpnName(), macEntry.getInterfaceName(), tx);
52 VpnUtil.removeLearntVpnVipToPort(dataBroker, macEntry.getVpnName(),
53 macEntry.getIpAddress().getHostAddress());
54 CheckedFuture<Void, TransactionCommitFailedException> txFutures = tx.submit();
57 } catch (InterruptedException | ExecutionException e) {
58 LOG.error("Error writing to datastore {}", e);
60 futures.add(txFutures);
64 private void removeMipAdjacency(String fixedip, String vpnName, String interfaceName, WriteTransaction tx) {
65 synchronized (interfaceName.intern()) {
66 InstanceIdentifier<VpnInterface> vpnIfId = VpnUtil.getVpnInterfaceIdentifier(interfaceName);
67 InstanceIdentifier<Adjacencies> path = vpnIfId.augmentation(Adjacencies.class);
68 Optional<Adjacencies> adjacencies = VpnUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, path);
69 if (adjacencies.isPresent()) {
70 InstanceIdentifier<Adjacency> adid = vpnIfId.augmentation(Adjacencies.class).child(Adjacency.class,
71 new AdjacencyKey(ipToPrefix(fixedip)));
72 tx.delete(LogicalDatastoreType.CONFIGURATION, adid);
73 LOG.info("deleting the adjacencies for vpn {} interface {}", vpnName, interfaceName);
78 private String ipToPrefix(String ip) {
79 return new StringBuilder(ip).append(ArpConstants.PREFIX).toString();