2 * Copyright (c) 2015 - 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.vpnmanager;
10 import static org.opendaylight.genius.infra.Datastore.OPERATIONAL;
12 import java.util.ArrayList;
13 import java.util.List;
14 import java.util.stream.Collectors;
15 import javax.annotation.PreDestroy;
16 import javax.inject.Inject;
17 import javax.inject.Singleton;
18 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
19 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
20 import org.opendaylight.infrautils.utils.concurrent.Executors;
21 import org.opendaylight.infrautils.utils.concurrent.LoggingFutures;
22 import org.opendaylight.mdsal.binding.api.DataBroker;
23 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
24 import org.opendaylight.serviceutils.tools.listener.AbstractAsyncDataTreeChangeListener;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.FibEntries;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.fibentries.VrfTables;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.fibentries.VrfTablesKey;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentries.VrfEntry;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentrybase.RoutePaths;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.op.data.VpnInstanceOpDataEntry;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.op.data.VpnInstanceOpDataEntryBuilder;
32 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
33 import org.opendaylight.yangtools.yang.common.Uint32;
34 import org.slf4j.Logger;
35 import org.slf4j.LoggerFactory;
38 public class FibEntriesListener extends AbstractAsyncDataTreeChangeListener<VrfEntry> {
39 private static final Logger LOG = LoggerFactory.getLogger(FibEntriesListener.class);
40 private final DataBroker dataBroker;
41 private final ManagedNewTransactionRunner txRunner;
42 private final VpnInstanceListener vpnInstanceListener;
45 public FibEntriesListener(final DataBroker dataBroker, final VpnInstanceListener vpnInstanceListener) {
46 super(dataBroker, LogicalDatastoreType.OPERATIONAL,
47 InstanceIdentifier.create(FibEntries.class).child(VrfTables.class).child(VrfEntry.class),
48 Executors.newListeningSingleThreadExecutor("FibEntriesListener", LOG));
49 this.dataBroker = dataBroker;
50 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
51 this.vpnInstanceListener = vpnInstanceListener;
55 LOG.info("{} start", getClass().getSimpleName());
62 Executors.shutdownAndAwaitTermination(getExecutorService());
67 public void remove(InstanceIdentifier<VrfEntry> identifier,
69 LOG.trace("Remove Fib event - Key : {}, value : {} ", identifier, del);
70 final VrfTablesKey key = identifier.firstKeyOf(VrfTables.class);
71 String rd = key.getRouteDistinguisher();
72 List<RoutePaths> routePaths = new ArrayList<RoutePaths>(del.nonnullRoutePaths().values());
73 removeLabelFromVpnInstance(rd, routePaths);
77 public void update(InstanceIdentifier<VrfEntry> identifier,
78 VrfEntry original, VrfEntry update) {
79 final VrfTablesKey key = identifier.firstKeyOf(VrfTables.class);
80 String rd = key.getRouteDistinguisher();
81 List<RoutePaths> originalRoutePaths = new ArrayList<RoutePaths>(original.nonnullRoutePaths().values());
82 List<RoutePaths> updateRoutePaths = new ArrayList<RoutePaths>(update.nonnullRoutePaths().values());
83 if (originalRoutePaths.size() < updateRoutePaths.size()) {
84 updateRoutePaths.removeAll(originalRoutePaths);
85 addLabelToVpnInstance(rd, updateRoutePaths);
86 } else if (originalRoutePaths.size() > updateRoutePaths.size()) {
87 originalRoutePaths.removeAll(updateRoutePaths);
88 removeLabelFromVpnInstance(rd, originalRoutePaths);
93 public void add(InstanceIdentifier<VrfEntry> identifier,
95 LOG.trace("Add Vrf Entry event - Key : {}, value : {}", identifier, add);
96 final VrfTablesKey key = identifier.firstKeyOf(VrfTables.class);
97 String rd = key.getRouteDistinguisher();
98 addLabelToVpnInstance(rd, new ArrayList<RoutePaths>(add.nonnullRoutePaths().values()));
101 private void addLabelToVpnInstance(String rd, List<RoutePaths> routePaths) {
102 List<Uint32> labels = routePaths.stream().map(RoutePaths::getLabel).distinct()
103 .collect(Collectors.toList());
104 VpnInstanceOpDataEntry vpnInstanceOpData = vpnInstanceListener.getVpnInstanceOpData(rd);
105 if (vpnInstanceOpData != null) {
106 List<Uint32> routeIds = vpnInstanceOpData.getRouteEntryId() == null ? new ArrayList<>()
107 : vpnInstanceOpData.getRouteEntryId();
108 labels.forEach(label -> {
109 LOG.debug("Adding label to vpn info - {}", label);
110 if (!routeIds.contains(label)) {
114 LoggingFutures.addErrorLogging(txRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL, tx ->
115 tx.put(VpnUtil.getVpnInstanceOpDataIdentifier(rd),
116 new VpnInstanceOpDataEntryBuilder(vpnInstanceOpData).setRouteEntryId(routeIds)
118 LOG, "Error adding label to VPN instance");
120 LOG.warn("No VPN Instance found for RD: {}", rd);
124 private void removeLabelFromVpnInstance(String rd, List<RoutePaths> routePaths) {
125 List<Uint32> labels = routePaths.stream().map(RoutePaths::getLabel).distinct()
126 .collect(Collectors.toList());
127 VpnInstanceOpDataEntry vpnInstanceOpData = vpnInstanceListener.getVpnInstanceOpData(rd);
128 if (vpnInstanceOpData != null) {
129 List<Uint32> routeIds = vpnInstanceOpData.getRouteEntryId();
130 if (routeIds == null) {
131 LOG.debug("Fib Route entry is empty.");
133 LOG.debug("Removing label from vpn info - {}", labels);
134 routeIds.removeAll(labels);
135 LoggingFutures.addErrorLogging(txRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL, tx ->
136 tx.put(VpnUtil.getVpnInstanceOpDataIdentifier(rd),
137 new VpnInstanceOpDataEntryBuilder(vpnInstanceOpData).setRouteEntryId(routeIds)
139 LOG, "Error removing label from VPN instance");
142 LOG.warn("No VPN Instance found for RD: {}", rd);