From 08ba938c488a04dcb24d15a2048848f5f5be2430 Mon Sep 17 00:00:00 2001 From: Amitesh Soni Date: Thu, 25 Jul 2019 14:30:52 +0530 Subject: [PATCH] Removing redundant extra-route delete Removing redundant delete of extra-route from delAdjFromVpnInterface method since it is already being taken care by remove and update of FIB. Change-Id: I8ee6255c60557d4121dcc0de8c56352ba009a49e Signed-off-by: Amitesh Soni --- .../netvirt/vpnmanager/VpnInterfaceManager.java | 9 ++++----- .../opendaylight/netvirt/vpnmanager/VpnManagerImpl.java | 3 ++- .../org/opendaylight/netvirt/vpnmanager/VpnUtil.java | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnInterfaceManager.java b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnInterfaceManager.java index 07d172178b..b9e38a564c 100755 --- a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnInterfaceManager.java +++ b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnInterfaceManager.java @@ -2076,11 +2076,6 @@ public class VpnInterfaceManager extends AsyncDataTreeChangeListenerBase adjIdentifier = VpnUtil - .getVpnInterfaceOpDataEntryAdjacencyIdentifier(currVpnIntf.getName(), - currVpnIntf.getVpnInstanceName(), adj.getIpAddress()); - LOG.debug("delAdjFromVpnInterface: adjIdentifier {}", adjIdentifier); - writeOperTxn.delete(adjIdentifier); if (adj.getNextHopIpList() != null) { for (String nh : adj.getNextHopIpList()) { deleteExtraRouteFromCurrentAndImportingVpns( @@ -2114,11 +2109,15 @@ public class VpnInterfaceManager extends AsyncDataTreeChangeListenerBase writeConfigTxn, TypedWriteTransaction writeOperTx) { + LOG.info("removing extra-route {} for nexthop {} in VPN {} intfName {} rd {}", + destination, nextHop, vpnName, intfName, rd); vpnManager.delExtraRoute(vpnName, destination, nextHop, rd, vpnName, intfName, writeConfigTxn, writeOperTx); List vpnsToImportRoute = vpnUtil.getVpnsImportingMyRoute(vpnName); for (VpnInstanceOpDataEntry vpn : vpnsToImportRoute) { String vpnRd = vpn.getVrfId(); if (vpnRd != null) { + LOG.info("deleting extra-route {} for nexthop {} in VPN {} intfName {} vpnRd {}", + destination, nextHop, vpnName, intfName, vpnRd); vpnManager.delExtraRoute(vpnName, destination, nextHop, vpnRd, vpnName, intfName, writeConfigTxn, writeOperTx); } diff --git a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnManagerImpl.java b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnManagerImpl.java index 4519f19978..234997f15a 100644 --- a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnManagerImpl.java +++ b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnManagerImpl.java @@ -298,8 +298,9 @@ public class VpnManagerImpl implements IVpnManager { String vpnNamePrefixKey = VpnUtil.getVpnNamePrefixKey(vpnName, prefix); // FIXME: separate out to somehow? final ReentrantLock lock = JvmGlobalLocks.getLockForString(vpnNamePrefixKey); - lock.lock(); + LOG.info("removing prefix {} for nexthop {} in VPN {} rd {}", prefix, nextHop, vpnName, extraRouteRd); try { + lock.lock(); if (vpnUtil.removeOrUpdateDSForExtraRoute(vpnName, primaryRd, extraRouteRd, vpnInterfaceName, prefix, nextHop, nextHopTunnelIp, operTx)) { return; diff --git a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnUtil.java b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnUtil.java index 605f67d537..492218577b 100644 --- a/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnUtil.java +++ b/vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/VpnUtil.java @@ -705,7 +705,7 @@ public final class VpnUtil { MDSALUtil.syncDelete(dataBroker, LogicalDatastoreType.CONFIGURATION, VpnExtraRouteHelper.getUsedRdsIdentifier(getVpnId(vpnName), prefix, nextHop)); - LOG.debug("removeOrUpdateDSForExtraRoute: Removed vpn-to-extraroute with rd {} prefix {} nexthop {}", + LOG.info("removeOrUpdateDSForExtraRoute: Removed vpn-to-extraroute with rd {} prefix {} nexthop {}", extraRouteRd, prefix, nextHop); fibManager.refreshVrfEntry(primaryRd, prefix); operTx.delete(VpnUtil.getVpnInterfaceOpDataEntryAdjacencyIdentifier(vpnInterfaceName, vpnName, prefix)); -- 2.36.6