X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=itm%2Fitm-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fitm%2Flisteners%2FTransportZoneListener.java;fp=itm%2Fitm-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fitm%2Flisteners%2FTransportZoneListener.java;h=26c8f806b00f6253c939494106f7e3deb9200e19;hb=ad664a0c796d1b29f0f337a4ce0a26ce9b3c2238;hp=fae12dc6454223ca69eaa989c086c9446ceb6c9e;hpb=3e0f21d10b63d08737ce649b50c2412368147687;p=vpnservice.git diff --git a/itm/itm-impl/src/main/java/org/opendaylight/vpnservice/itm/listeners/TransportZoneListener.java b/itm/itm-impl/src/main/java/org/opendaylight/vpnservice/itm/listeners/TransportZoneListener.java index fae12dc6..26c8f806 100644 --- a/itm/itm-impl/src/main/java/org/opendaylight/vpnservice/itm/listeners/TransportZoneListener.java +++ b/itm/itm-impl/src/main/java/org/opendaylight/vpnservice/itm/listeners/TransportZoneListener.java @@ -110,7 +110,7 @@ public class TransportZoneListener extends AsyncDataTreeChangeListenerBase0 || hwVtepList.size()>0) { LOG.trace("Delete: Invoking ItmManager"); - LOG.trace("Add: Invoking ItmManager with hwVtep List {} " , hwVtepList); + LOG.trace("Delete: Invoking ItmManager with hwVtep List {} " , hwVtepList); // itmManager.deleteTunnels(opDpnList); DataStoreJobCoordinator coordinator = DataStoreJobCoordinator.getInstance(); ItmTepRemoveWorker removeWorker = new ItmTepRemoveWorker(opDpnList,hwVtepList, dataBroker, idManagerService, mdsalManager); @@ -220,12 +220,15 @@ public class TransportZoneListener extends AsyncDataTreeChangeListenerBase vtepsList = subnet.getVteps(); + if(vtepsList!=null && !vtepsList.isEmpty()) { for (Vteps vteps : vtepsList) { BigInteger dpnID = vteps.getDpnId(); String port = vteps.getPortname(); IpAddress ipAddress = vteps.getIpAddress(); LOG.trace("DpnID: {}, port: {}, ipAddress: {}", dpnID, port, ipAddress); - TunnelEndPoints tunnelEndPoints = ItmUtils.createTunnelEndPoints(dpnID, ipAddress, port, vlanID, ipPrefix, gatewayIP, zone_name, tunnel_type); + TunnelEndPoints tunnelEndPoints = + ItmUtils.createTunnelEndPoints(dpnID, ipAddress, port, vlanID, ipPrefix, + gatewayIP, zone_name, tunnel_type); List tunnelEndPointsList = mapDPNToTunnelEndpt.get(dpnID); if (tunnelEndPointsList != null) { LOG.trace("Existing DPN info list in the Map: {} ", dpnID); @@ -235,6 +238,7 @@ public class TransportZoneListener extends AsyncDataTreeChangeListenerBase(); tunnelEndPointsList.add(tunnelEndPoints); mapDPNToTunnelEndpt.put(dpnID, tunnelEndPointsList); + } } } }