X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=inventory%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Finventory%2Flistener%2FDeviceConfigListener.java;h=ad1c73b308bfb2ba1d2aa016d36d25cc363d1ba3;hb=b1b3bafd549bb501937cea5c976d5344608b6ed3;hp=e4b6636b08357d816b2b7f36b3b78aac7089a4dd;hpb=f67e3fd65d30dea6d5c608ccc1e829a61efb38ae;p=transportpce.git diff --git a/inventory/src/main/java/org/opendaylight/transportpce/inventory/listener/DeviceConfigListener.java b/inventory/src/main/java/org/opendaylight/transportpce/inventory/listener/DeviceConfigListener.java index e4b6636b0..ad1c73b30 100644 --- a/inventory/src/main/java/org/opendaylight/transportpce/inventory/listener/DeviceConfigListener.java +++ b/inventory/src/main/java/org/opendaylight/transportpce/inventory/listener/DeviceConfigListener.java @@ -17,8 +17,8 @@ import org.opendaylight.mdsal.binding.api.DataTreeChangeListener; import org.opendaylight.mdsal.binding.api.DataTreeModification; import org.opendaylight.transportpce.common.StringConstants; import org.opendaylight.transportpce.inventory.DeviceInventory; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev231024.ConnectionOper.ConnectionStatus; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev221225.NetconfNode; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev240120.ConnectionOper.ConnectionStatus; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev231121.NetconfNode; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -42,24 +42,24 @@ public class DeviceConfigListener implements DataTreeChangeListener { } @Override - public void onDataTreeChanged(Collection> changes) { + public void onDataTreeChanged(List> changes) { //LOG.debug("testing np1: {}", changes.toString()); String openROADMversion = ""; List> changesWithoutDefaultNetconfNode = getRealDevicesOnly(changes); for (DataTreeModification device : changesWithoutDefaultNetconfNode) { DataObjectModification rootNode = device.getRootNode(); - String nodeId = rootNode.getDataAfter().key().getNodeId().getValue(); + String nodeId = rootNode.dataAfter().key().getNodeId().getValue(); LOG.debug("nodeId {}", nodeId); - NetconfNode netconfNode = rootNode.getDataAfter().augmentation(NetconfNode.class); + NetconfNode netconfNode = rootNode.dataAfter().augmentation(NetconfNode.class); ConnectionStatus connectionStatus = netconfNode.getConnectionStatus(); long count = netconfNode.getAvailableCapabilities().getAvailableCapability().stream() .filter(cp -> cp.getCapability().contains(StringConstants.OPENROADM_DEVICE_MODEL_NAME)) .count(); - LOG.debug("DCL Modification Type {}", device.getRootNode().getModificationType().toString()); + LOG.debug("DCL Modification Type {}", device.getRootNode().modificationType().toString()); LOG.debug("DCL Capability Count {}", count); LOG.debug("DCL Connection Status {}", connectionStatus); if (isCreate(device) || isUpdate(device)) { @@ -111,14 +111,14 @@ public class DeviceConfigListener implements DataTreeChangeListener { */ private static List> getRealDevicesOnly(Collection> changes) { return changes.stream() - .filter(change -> (change.getRootNode().getDataAfter() != null + .filter(change -> (change.getRootNode().dataAfter() != null && !StringConstants.DEFAULT_NETCONF_NODEID - .equalsIgnoreCase(change.getRootNode().getDataAfter().key().getNodeId().getValue()) - && change.getRootNode().getDataAfter().augmentation(NetconfNode.class) != null) - || (change.getRootNode().getDataBefore() != null + .equalsIgnoreCase(change.getRootNode().dataAfter().key().getNodeId().getValue()) + && change.getRootNode().dataAfter().augmentation(NetconfNode.class) != null) + || (change.getRootNode().dataBefore() != null && !StringConstants.DEFAULT_NETCONF_NODEID.equalsIgnoreCase( - change.getRootNode().getDataBefore().key().getNodeId().getValue()) - && change.getRootNode().getDataBefore().augmentation(NetconfNode.class) != null + change.getRootNode().dataBefore().key().getNodeId().getValue()) + && change.getRootNode().dataBefore().augmentation(NetconfNode.class) != null )).collect(Collectors.toList()); } @@ -128,8 +128,8 @@ public class DeviceConfigListener implements DataTreeChangeListener { * */ private static boolean isCreate(DataTreeModification change) { - return change.getRootNode().getDataBefore() == null && change.getRootNode().getDataAfter() != null - && ModificationType.WRITE.equals(change.getRootNode().getModificationType()); + return change.getRootNode().dataBefore() == null && change.getRootNode().dataAfter() != null + && ModificationType.WRITE.equals(change.getRootNode().modificationType()); } /** @@ -137,7 +137,7 @@ public class DeviceConfigListener implements DataTreeChangeListener { * */ private static boolean isUpdate(DataTreeModification change) { - return ModificationType.SUBTREE_MODIFIED.equals(change.getRootNode().getModificationType()); + return ModificationType.SUBTREE_MODIFIED.equals(change.getRootNode().modificationType()); } /** @@ -145,7 +145,7 @@ public class DeviceConfigListener implements DataTreeChangeListener { * */ private static boolean isDelete(DataTreeModification change) { - return change.getRootNode().getDataBefore() != null && change.getRootNode().getDataAfter() == null - && ModificationType.DELETE.equals(change.getRootNode().getModificationType()); + return change.getRootNode().dataBefore() != null && change.getRootNode().dataAfter() == null + && ModificationType.DELETE.equals(change.getRootNode().modificationType()); } }