2 * Copyright (c) 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.genius.itm.confighelpers;
10 import static org.opendaylight.genius.infra.Datastore.CONFIGURATION;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import java.util.ArrayList;
14 import java.util.Collection;
15 import java.util.List;
17 import java.util.Optional;
18 import java.util.concurrent.Callable;
19 import org.eclipse.jdt.annotation.Nullable;
20 import org.opendaylight.genius.infra.Datastore;
21 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
22 import org.opendaylight.genius.infra.TypedReadWriteTransaction;
23 import org.opendaylight.genius.itm.cache.DPNTEPsInfoCache;
24 import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfig;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPoints;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.dc.gateway.ip.list.DcGatewayIp;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.dc.gateway.ip.list.DcGatewayIpKey;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
32 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
33 import org.slf4j.Logger;
34 import org.slf4j.LoggerFactory;
36 public class ItmTepRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
38 private static final Logger LOG = LoggerFactory.getLogger(ItmTepRemoveWorker.class);
40 private final List<DPNTEPsInfo> delDpnList ;
41 private final IMdsalApiManager mdsalManager;
42 private final List<HwVtep> cfgdHwVteps;
43 private final TransportZone originalTZone;
44 private final ItmInternalTunnelDeleteWorker itmInternalTunnelDeleteWorker;
45 private final DPNTEPsInfoCache dpnTEPsInfoCache;
46 private final ManagedNewTransactionRunner txRunner;
47 private final ItmConfig itmConfig;
49 private Collection<DPNTEPsInfo> meshedDpnList ;
51 public ItmTepRemoveWorker(List<DPNTEPsInfo> delDpnList, List<HwVtep> delHwList, TransportZone originalTZone,
52 IMdsalApiManager mdsalManager,
53 ItmInternalTunnelDeleteWorker itmInternalTunnelDeleteWorker,
54 DPNTEPsInfoCache dpnTEPsInfoCache, ManagedNewTransactionRunner txRunner,
55 ItmConfig itmConfig) {
56 this.delDpnList = delDpnList;
57 this.mdsalManager = mdsalManager;
58 this.cfgdHwVteps = delHwList;
59 this.originalTZone = originalTZone;
60 this.itmInternalTunnelDeleteWorker = itmInternalTunnelDeleteWorker;
61 this.dpnTEPsInfoCache = dpnTEPsInfoCache;
62 this.txRunner = txRunner;
63 this.itmConfig = itmConfig;
64 LOG.trace("ItmTepRemoveWorker initialized with DpnList {}", delDpnList);
65 LOG.trace("ItmTepRemoveWorker initialized with cfgdHwTeps {}", delHwList);
69 public List<ListenableFuture<Void>> call() {
70 List<ListenableFuture<Void>> futures = new ArrayList<>() ;
71 this.meshedDpnList = dpnTEPsInfoCache.getAllPresent();
72 futures.addAll(itmInternalTunnelDeleteWorker.deleteTunnels(mdsalManager, delDpnList, meshedDpnList));
73 LOG.debug("Invoking Internal Tunnel delete method with DpnList to be deleted {} ; Meshed DpnList {} ",
74 delDpnList, meshedDpnList);
75 // IF EXTERNAL TUNNELS NEEDS TO BE DELETED, DO IT HERE, IT COULD BE TO DC GATEWAY OR TOR SWITCH
76 futures.add(txRunner.callWithNewReadWriteTransactionAndSubmit(CONFIGURATION,
78 Optional<DcGatewayIpList> optional = tx.read(InstanceIdentifier.builder(DcGatewayIpList.class)
80 if (optional.isPresent()) {
81 @Nullable Map<DcGatewayIpKey, DcGatewayIp> dcGatewayIpList = optional.get().getDcGatewayIp();
82 if (dcGatewayIpList != null && !dcGatewayIpList.isEmpty()) {
83 processExternalTunnelTepDelete(dcGatewayIpList.values(), tx);
88 futures.add(txRunner.callWithNewReadWriteTransactionAndSubmit(CONFIGURATION,
89 tx -> ItmExternalTunnelDeleteWorker.deleteHwVtepsTunnels(delDpnList, cfgdHwVteps, this.originalTZone, tx,
95 public String toString() {
96 return "ItmTepRemoveWorker { Delete Dpn List : " + delDpnList + " }" ;
99 private void processExternalTunnelTepDelete(Collection<DcGatewayIp> dcGatewayIpList,
100 TypedReadWriteTransaction<Datastore.Configuration> tx) {
101 List<DPNTEPsInfo> dpnDeleteList = new ArrayList<>();
102 for (DPNTEPsInfo dpnTEPInfo : delDpnList) {
103 List<TunnelEndPoints> tunnelEndPointsList = dpnTEPInfo.nonnullTunnelEndPoints();
104 if (tunnelEndPointsList.size() == 1) {
105 dpnDeleteList.add(dpnTEPInfo);
107 LOG.error("DPNTEPInfo not available in data store for dpnId {}. Unable to delete external tunnel "
108 + "for dpn ", dpnTEPInfo.getDPNID());
111 dcGatewayIpList.forEach(dcGatewayIp -> ItmExternalTunnelDeleteWorker.deleteTunnels(dpnDeleteList,
112 meshedDpnList, dcGatewayIp.getIpAddress(), dcGatewayIp.getTunnnelType(), tx));