X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=renderer%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Frenderer%2Fprovisiondevice%2FOtnDeviceRendererServiceImpl.java;h=c5b1039ead85285235f18305749c13f1c8fa3d23;hb=e3438cad213946cd76a73219876487c30024dfae;hp=3328dc124f69b4863e9ea16ac900b7157902b796;hpb=56cd986bbad50cd053fdf57004a419ae98c595af;p=transportpce.git diff --git a/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/OtnDeviceRendererServiceImpl.java b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/OtnDeviceRendererServiceImpl.java index 3328dc124..c5b1039ea 100644 --- a/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/OtnDeviceRendererServiceImpl.java +++ b/renderer/src/main/java/org/opendaylight/transportpce/renderer/provisiondevice/OtnDeviceRendererServiceImpl.java @@ -8,8 +8,10 @@ package org.opendaylight.transportpce.renderer.provisiondevice; import java.util.ArrayList; +import java.util.HashMap; import java.util.LinkedList; import java.util.List; +import java.util.Map; import java.util.Optional; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.CopyOnWriteArrayList; @@ -60,7 +62,7 @@ public class OtnDeviceRendererServiceImpl implements OtnDeviceRendererService { @Override public OtnServicePathOutput setupOtnServicePath(OtnServicePathInput input) { - LOG.info("Calling setup service path"); + LOG.info("Calling setup otn-service path"); boolean success = true; List nodeInterfaces = new ArrayList<>(); List results = new ArrayList<>(); @@ -131,14 +133,25 @@ public class OtnDeviceRendererServiceImpl implements OtnDeviceRendererService { results.add("Otn Service path was set up successfully for node :" + nodeInterface.getNodeId()); } } + Map nodeInterfacesMap = new HashMap<>(); + for (NodeInterface nodeInterface : nodeInterfaces) { + if (nodeInterface != null) { + nodeInterfacesMap.put(nodeInterface.key(), nodeInterface); + } + } OtnServicePathOutputBuilder otnServicePathOutputBuilder = new OtnServicePathOutputBuilder() .setSuccess(success) - .setNodeInterface(nodeInterfaces) + .setNodeInterface(nodeInterfacesMap) .setResult(String.join("\n", results)); return otnServicePathOutputBuilder.build(); } public OtnServicePathOutput deleteOtnServicePath(OtnServicePathInput input) { + if (input == null) { + LOG.error("Unable to delete otn service path. input = null"); + return new OtnServicePathOutputBuilder().setResult("Unable to delete otn service path. input = null") + .setSuccess(false).build(); + } List nodes = input.getNodes(); AtomicBoolean success = new AtomicBoolean(true); ConcurrentLinkedQueue results = new ConcurrentLinkedQueue<>();