2 * Copyright © 2015, 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
9 package org.opendaylight.netvirt.bgpmanager;
13 import org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener;
14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
15 import org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService;
16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
17 import org.opendaylight.genius.datastoreutils.AsyncDataTreeChangeListenerBase;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.EvpnRdToNetworks;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.evpn.rd.to.networks.EvpnRdToNetwork;
20 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
26 public class EvpnRdNetworkListener extends AsyncDataTreeChangeListenerBase<EvpnRdToNetwork, EvpnRdNetworkListener>
27 implements AutoCloseable, ClusteredDataTreeChangeListener<EvpnRdToNetwork> {
28 private final DataBroker broker;
29 private final EntityOwnershipService entityOwnershipService;
30 private static final Logger LOG = LoggerFactory.getLogger(EvpnRdNetworkListener.class);
33 public EvpnRdNetworkListener(DataBroker dataBroker,
34 EntityOwnershipService entityOwnershipService) {
35 super(EvpnRdToNetwork.class, EvpnRdNetworkListener.class);
36 this.broker = dataBroker;
37 this.entityOwnershipService = entityOwnershipService;
41 registerListener(LogicalDatastoreType.CONFIGURATION, broker);
45 protected InstanceIdentifier<EvpnRdToNetwork> getWildCardPath() {
46 return InstanceIdentifier.create(EvpnRdToNetworks.class).child(EvpnRdToNetwork.class);
50 protected EvpnRdNetworkListener getDataTreeChangeListener() {
55 protected void add(InstanceIdentifier<EvpnRdToNetwork> instanceIdentifier, EvpnRdToNetwork rdToNetwork) {
56 if (BgpConfigurationManager.ignoreClusterDcnEventForFollower()) {
59 String rd = rdToNetwork.getRd();
60 String elanName = rdToNetwork.getNetworkId();
61 LOG.trace("Received EvpnRdToNetwork Add for RD {} Netwrok {}", rd, elanName);
62 addExternalTepstoElanInstance(rd);
66 protected void update(InstanceIdentifier<EvpnRdToNetwork> instanceIdentifier, EvpnRdToNetwork rdToNetwork,
67 EvpnRdToNetwork rdToNetworkOld) {
68 String rd = rdToNetwork.getRd();
69 String elanName = rdToNetwork.getNetworkId();
70 LOG.trace("Received EvpnRdToNetwork Update for RD {} Netwrok {}", rd, elanName);
71 LOG.trace("Update operation not supported");
76 protected void remove(InstanceIdentifier<EvpnRdToNetwork> instanceIdentifier, EvpnRdToNetwork rdToNetwork) {
77 if (BgpConfigurationManager.ignoreClusterDcnEventForFollower()) {
80 String rd = rdToNetwork.getRd();
81 String elanName = rdToNetwork.getNetworkId();
82 LOG.trace("Received EvpnRdToNetwork Delete for RD {} Netwrok {}", rd, elanName);
83 deleteExternalTepsfromElanInstance(rd);
86 public void addExternalTepstoElanInstance(String rd) {
87 Map<String, Map<String, Map<String, Long>>> rt2Map = BgpConfigurationManager.getRt2TepMap();
88 if (!rt2Map.isEmpty()) {
89 if (rt2Map.containsKey(rd)) {
90 rt2Map.get(rd).forEach((tepIp, mac) -> {
91 LOG.debug("Adding tep {} to Elan Corresponding to RD {}", tepIp, rd);
92 BgpUtil.addTepToElanInstance(broker, rd, tepIp);
95 LOG.debug("No entry for rd {}", rd);
100 public void deleteExternalTepsfromElanInstance(String rd) {
101 Map<String, Map<String, Map<String, Long>>> rt2Map = BgpConfigurationManager.getRt2TepMap();
102 if (!rt2Map.isEmpty()) {
103 if (rt2Map.containsKey(rd)) {
104 rt2Map.get(rd).forEach((tepIp, mac) -> {
105 LOG.debug("Deleting tep {} to Elan Corresponding to RD {}", tepIp, rd);
106 BgpUtil.deleteTepFromElanInstance(broker, rd, tepIp);
109 LOG.debug("No entry for rd {}", rd);