/* * Copyright © 2020 AT&T, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.transportpce.common.mapping; import com.google.common.util.concurrent.FluentFuture; import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Optional; import java.util.concurrent.ExecutionException; import java.util.stream.Collectors; import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.binding.api.WriteTransaction; import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.transportpce.common.StringConstants; import org.opendaylight.transportpce.common.Timeouts; import org.opendaylight.transportpce.common.device.DeviceTransactionManager; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.Network; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.NetworkBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.Nodes; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.NodesBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.NodesKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.CpToDegree; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.CpToDegreeBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.CpToDegreeKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.Mapping; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.MappingBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.MappingKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.McCapabilities; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.McCapabilitiesBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.McCapabilitiesKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.NodeInfo; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.NodeInfo.OpenroadmVersion; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.NodeInfoBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.SwitchingPoolLcp; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.SwitchingPoolLcpBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.SwitchingPoolLcpKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.switching.pool.lcp.NonBlockingList; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.switching.pool.lcp.NonBlockingListBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.nodes.switching.pool.lcp.NonBlockingListKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.alarm.pm.types.rev191129.Direction; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.optical.channel.types.rev200529.FrequencyGHz; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.CircuitPack; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.circuit.pack.Ports; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.circuit.pack.PortsKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.circuit.packs.CircuitPacks; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.circuit.packs.CircuitPacksKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.degree.ConnectionPorts; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.interfaces.grp.Interface; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.interfaces.grp.InterfaceKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.OrgOpenroadmDevice; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.ConnectionMap; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.Degree; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.DegreeKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.Info; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.McCapabilityProfile; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.McCapabilityProfileKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.OduSwitchingPools; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.Protocols; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.SharedRiskGroup; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.SharedRiskGroupKey; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.Xponder; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.connection.map.Destination; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org.openroadm.device.odu.switching.pools.non.blocking.list.PortList; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.port.Interfaces; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.xponder.XpdrPort; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.PortQual; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.XpdrNodeTypes; import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev191129.InterfaceType; import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev191129.OpenROADMOpticalMultiplex; import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev191129.OpticalTransport; import org.opendaylight.yang.gen.v1.http.org.openroadm.interfaces.rev191129.OtnOdu; import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev200529.Protocols1; import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev200529.lldp.container.Lldp; import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev200529.lldp.container.lldp.PortConfig; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.common.Uint16; import org.opendaylight.yangtools.yang.common.Uint32; import org.slf4j.Logger; import org.slf4j.LoggerFactory; // FIXME: many common pieces of code between PortMapping Versions 121 and 221 and 710 // some mutualization would be helpful public class PortMappingVersion710 { private static final Logger LOG = LoggerFactory.getLogger(PortMappingVersion710.class); private final DataBroker dataBroker; private final DeviceTransactionManager deviceTransactionManager; private final OpenRoadmInterfaces openRoadmInterfaces; public PortMappingVersion710(DataBroker dataBroker, DeviceTransactionManager deviceTransactionManager, OpenRoadmInterfaces openRoadmInterfaces) { this.dataBroker = dataBroker; this.deviceTransactionManager = deviceTransactionManager; this.openRoadmInterfaces = openRoadmInterfaces; } public boolean createMappingData(String nodeId) { LOG.info("Create Mapping Data for node 7.1.0 {}", nodeId); List portMapList = new ArrayList<>(); List mcCapabilitiesList = new ArrayList<>(); InstanceIdentifier infoIID = InstanceIdentifier.create(OrgOpenroadmDevice.class).child(Info.class); Optional deviceInfoOptional = this.deviceTransactionManager.getDataFromDevice( nodeId, LogicalDatastoreType.OPERATIONAL, infoIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (!deviceInfoOptional.isPresent()) { LOG.warn("Device info subtree is absent for {}", nodeId); return false; } Info deviceInfo = deviceInfoOptional.get(); NodeInfo nodeInfo = createNodeInfo(deviceInfo); if (nodeInfo == null) { return false; } postPortMapping(nodeId, nodeInfo, null, null, null, null); switch (deviceInfo.getNodeType()) { case Rdm: // Get TTP port mapping if (!createTtpPortMapping(nodeId, deviceInfo, portMapList)) { // return false if mapping creation for TTP's failed LOG.warn("Unable to create mapping for TTP's on node {}", nodeId); return false; } // Get PP port mapping if (!createPpPortMapping(nodeId, deviceInfo, portMapList)) { // return false if mapping creation for PP's failed LOG.warn("Unable to create mapping for PP's on node {}", nodeId); return false; } // Get MC capabilities if (!createMcCapabilitiesList(nodeId, deviceInfo, mcCapabilitiesList)) { // return false if MC capabilites failed LOG.warn("Unable to create MC capabilities on node {}", nodeId); return false; } break; case Xpdr: if (!createXpdrPortMapping(nodeId, portMapList)) { LOG.warn("Unable to create mapping for Xponder on node {}", nodeId); return false; } break; default: LOG.error("Unable to create mapping for node {} : unknown nodetype ", nodeId); break; } return postPortMapping(nodeId, nodeInfo, portMapList, null, null, mcCapabilitiesList); } public boolean updateMapping(String nodeId, Mapping oldMapping) { InstanceIdentifier portIId = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(oldMapping.getSupportingCircuitPackName())) .child(Ports.class, new PortsKey(oldMapping.getSupportingPort())); if ((oldMapping == null) || (nodeId == null)) { LOG.error("Impossible to update mapping"); return false; } try { Optional portObject = deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, portIId, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (!portObject.isPresent()) { return false; } Ports port = portObject.get(); Mapping newMapping = createMappingObject(nodeId, port, oldMapping.getSupportingCircuitPackName(), oldMapping.getLogicalConnectionPoint()); LOG.info("Updating old mapping Data {} for {} of {} by new mapping data {}", oldMapping, oldMapping.getLogicalConnectionPoint(), nodeId, newMapping); final WriteTransaction writeTransaction = this.dataBroker.newWriteOnlyTransaction(); InstanceIdentifier mapIID = InstanceIdentifier.create(Network.class) .child(Nodes.class, new NodesKey(nodeId)) .child(Mapping.class, new MappingKey(oldMapping.getLogicalConnectionPoint())); writeTransaction.merge(LogicalDatastoreType.CONFIGURATION, mapIID, newMapping); FluentFuture commit = writeTransaction.commit(); commit.get(); return true; } catch (InterruptedException | ExecutionException e) { LOG.error("Error updating Mapping {} for node {}", oldMapping.getLogicalConnectionPoint(), nodeId, e); return false; } } private boolean createXpdrPortMapping(String nodeId, List portMapList) { // Creating for Xponder Line and Client Ports InstanceIdentifier deviceIID = InstanceIdentifier.create(OrgOpenroadmDevice.class); Optional deviceObject = deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (!deviceObject.isPresent()) { LOG.error("Impossible to get device configuration for node {}", nodeId); return false; } OrgOpenroadmDevice device = deviceObject.get(); if (device.getCircuitPacks() == null) { LOG.warn("Circuit Packs are not present for {}", nodeId); return false; } // Variable to keep track of number of line ports int line = 1; // Variable to keep track of number of client ports int client = 1; Map lcpMap = new HashMap<>(); Map mappingMap = new HashMap<>(); List circuitPackList = new ArrayList<>(device.nonnullCircuitPacks().values()); circuitPackList.sort(Comparator.comparing(CircuitPack::getCircuitPackName)); if (device.getXponder() == null) { LOG.warn("{} configuration does not contain a list of xponders", nodeId); for (CircuitPacks cp : circuitPackList) { String circuitPackName = cp.getCircuitPackName(); if (cp.getPorts() == null) { LOG.warn("Ports were not found for circuit pack: {}", circuitPackName); continue; } List portList = new ArrayList<>(cp.nonnullPorts().values()); portList.sort(Comparator.comparing(Ports::getPortName)); for (Ports port : portList) { if (port.getPortQual() == null) { LOG.warn("PortQual was not found for port {} on circuit pack: {}", port.getPortName(), circuitPackName); continue; } if (PortQual.XpdrNetwork.getIntValue() == port.getPortQual().getIntValue() && port.getPortDirection().getIntValue() == Direction.Bidirectional.getIntValue()) { String lcp = "XPDR1-" + StringConstants.NETWORK_TOKEN + line; lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp); mappingMap.put(lcp, createXpdrMappingObject(nodeId, port, circuitPackName, lcp, null, null, null, null)); line++; } else if (PortQual.XpdrNetwork.getIntValue() == port.getPortQual().getIntValue() && port.getPortDirection().getIntValue() != Direction.Bidirectional.getIntValue() && port.getPartnerPort() != null && port.getPartnerPort().getCircuitPackName() != null && port.getPartnerPort().getPortName() != null) { if (lcpMap.containsKey(circuitPackName + '+' + port.getPortName())) { continue; } String lcp1 = "XPDR1-" + StringConstants.NETWORK_TOKEN + line; Optional cpOpt = circuitPackList.stream() .filter(cP -> cP.getCircuitPackName().equals(port.getPartnerPort().getCircuitPackName())) .findFirst(); if (cpOpt.isPresent()) { Optional poOpt = cpOpt.get().nonnullPorts().values().stream() .filter(p -> p.getPortName().equals(port.getPartnerPort().getPortName().toString())) .findFirst(); if (poOpt.isPresent()) { Ports port2 = poOpt.get(); if (checkPartnerPort(circuitPackName, port, port2)) { String lcp2 = new StringBuilder("XPDR1-").append(StringConstants.NETWORK_TOKEN) .append(line + 1).toString(); if (!lcpMap.containsKey(lcp1) && !lcpMap.containsKey(lcp2)) { lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp1); lcpMap.put(cpOpt.get().getCircuitPackName() + '+' + port2.getPortName(), lcp2); mappingMap.put(lcp1, createXpdrMappingObject(nodeId, port, circuitPackName, lcp1, lcp2, null, null, null)); mappingMap.put(lcp2, createXpdrMappingObject(nodeId, port2, cpOpt.get() .getCircuitPackName(), lcp2, lcp1, null, null, null)); } else { LOG.warn("mapping already exists for {} or {}", lcp1, lcp2); } line += 2; } else { LOG.error("port {} on {} is not a correct partner port of {} on {}", port2.getPortName(), cpOpt.get().getCircuitPackName(), port.getPortName(), circuitPackName); } } else { LOG.error("Error fetching port {} on {} for {}", port.getPartnerPort().getPortName(), port.getPartnerPort().getCircuitPackName(), nodeId); } } else { LOG.error("Error fetching circuit-pack {} for {}", port.getPartnerPort() .getCircuitPackName(), nodeId); } } else if (PortQual.XpdrClient.getIntValue() == port.getPortQual().getIntValue()) { String lcp = "XPDR1-" + StringConstants.CLIENT_TOKEN + client; lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp); mappingMap.put(lcp, createXpdrMappingObject(nodeId, port, circuitPackName, lcp, null, null, null, null)); client++; } else { LOG.warn("Error in the configuration of port {} of {} for {}", port.getPortName(), circuitPackName, nodeId); } } } } else { LOG.info("{} configuration contains a list of xponders", nodeId); for (Xponder xponder:deviceObject.get().nonnullXponder().values()) { line = 1; client = 1; Integer xponderNb = xponder.getXpdrNumber().toJava(); XpdrNodeTypes xponderType = xponder.getXpdrType(); for (XpdrPort xpdrPort : xponder.nonnullXpdrPort().values()) { String circuitPackName = xpdrPort.getCircuitPackName(); String portName = xpdrPort.getPortName().toString(); // If there xponder-subtree has missing circuit-packs or ports, // This gives a null-pointer expection, if (device.nonnullCircuitPacks().values().stream() .filter(cp -> cp.getCircuitPackName().equals(circuitPackName)) .findFirst().isEmpty()) { LOG.warn("Circuit-pack {} is missing in the device", circuitPackName); LOG.warn("Port-mapping will continue ignoring this circuit-pack {}", circuitPackName); continue; } if (device.nonnullCircuitPacks().values().stream() .filter(cp -> cp.getCircuitPackName().equals(circuitPackName)) .findFirst().get().nonnullPorts().values().stream() .filter(p -> p.getPortName().equals(portName)) .findFirst().isEmpty()) { LOG.warn("Port {} associated with CP {} is missing in the device", portName, circuitPackName); LOG.warn("Port-mapping will continue ignoring this port {}", portName); continue; } Ports port = device.nonnullCircuitPacks().values().stream() .filter(cp -> cp.getCircuitPackName().equals(circuitPackName)) .findFirst().get().nonnullPorts().values().stream() .filter(p -> p.getPortName().equals(portName)) .findFirst().get(); if (port.getPortQual() == null) { LOG.warn("PortQual was not found for port {} on circuit pack: {}", port.getPortName(), circuitPackName); continue; } if ((PortQual.XpdrNetwork.getIntValue() == port.getPortQual().getIntValue() || PortQual.SwitchNetwork.getIntValue() == port.getPortQual().getIntValue()) && port.getPortDirection().getIntValue() == Direction.Bidirectional.getIntValue()) { String lcp = "XPDR" + xponderNb + "-" + StringConstants.NETWORK_TOKEN + line; lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp); mappingMap.put(lcp, createXpdrMappingObject(nodeId, port, circuitPackName, lcp, null, null, null, xponderType)); line++; } else if ((PortQual.XpdrNetwork.getIntValue() == port.getPortQual().getIntValue() || PortQual.SwitchNetwork.getIntValue() == port.getPortQual().getIntValue()) && port.getPortDirection().getIntValue() != Direction.Bidirectional.getIntValue() && port.getPartnerPort() != null && port.getPartnerPort().getCircuitPackName() != null && port.getPartnerPort().getPortName() != null) { if (lcpMap.containsKey(circuitPackName + '+' + port.getPortName())) { continue; } String lcp1 = "XPDR" + xponderNb + "-" + StringConstants.NETWORK_TOKEN + line; Optional cpOpt = circuitPackList.stream() .filter(cP -> cP.getCircuitPackName().equals(port.getPartnerPort().getCircuitPackName())) .findFirst(); if (cpOpt.isPresent()) { Optional poOpt = cpOpt.get().nonnullPorts().values().stream() .filter(p -> p.getPortName().equals(port.getPartnerPort().getPortName().toString())) .findFirst(); if (poOpt.isPresent()) { Ports port2 = poOpt.get(); if (checkPartnerPort(circuitPackName, port, port2)) { String lcp2 = new StringBuilder("XPDR").append(xponderNb).append("-").append( StringConstants.NETWORK_TOKEN).append(line + 1).toString(); if (!lcpMap.containsKey(lcp1) && !lcpMap.containsKey(lcp2)) { lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp1); lcpMap.put(cpOpt.get().getCircuitPackName() + '+' + port2.getPortName(), lcp2); mappingMap.put(lcp1, createXpdrMappingObject(nodeId, port, circuitPackName, lcp1, lcp2, null, null, xponderType)); mappingMap.put(lcp2, createXpdrMappingObject(nodeId, port2, cpOpt.get() .getCircuitPackName(), lcp2, lcp1, null, null, xponderType)); } else { LOG.warn("mapping already exists for {} or {}", lcp1, lcp2); } line += 2; } else { LOG.error("port {} on {} is not a correct partner port of {} on {}", port2 .getPortName(), cpOpt.get().getCircuitPackName(), port.getPortName(), circuitPackName); } } else { LOG.error("Error fetching port {} on {} for {}", port.getPartnerPort().getPortName(), port.getPartnerPort().getCircuitPackName(), nodeId); } } else { LOG.error("Error fetching circuit-pack {} for {}", port.getPartnerPort() .getCircuitPackName(), nodeId); } } else if (PortQual.XpdrClient.getIntValue() == port.getPortQual().getIntValue() || PortQual.SwitchClient.getIntValue() == port.getPortQual().getIntValue()) { String lcp = "XPDR" + xponderNb + "-" + StringConstants.CLIENT_TOKEN + client; lcpMap.put(circuitPackName + '+' + port.getPortName(), lcp); mappingMap.put(lcp, createXpdrMappingObject(nodeId, port, circuitPackName, lcp, null, null, null, null)); client++; } else { LOG.warn("Error in the configuration of port {} of {} for {}", port.getPortName(), circuitPackName, nodeId); } } } } if (device.getConnectionMap() == null) { LOG.warn("No connection-map inside device configuration"); } else { Collection connectionMap = deviceObject.get().nonnullConnectionMap().values(); for (ConnectionMap cm : connectionMap) { String slcp = null; String dlcp = null; String skey = cm.getSource().getCircuitPackName() + "+" + cm.getSource().getPortName(); if (lcpMap.containsKey(skey)) { slcp = lcpMap.get(skey); } Destination destination0 = cm.nonnullDestination().values().iterator().next(); String dkey = destination0.getCircuitPackName() + "+" + destination0.getPortName(); if (slcp == null) { LOG.error("Error in connection-map analysis for source {} and destination (circuitpack+port) {}", skey, dkey); continue; } if (lcpMap.containsKey(dkey)) { dlcp = lcpMap.get(dkey); } Mapping mapping = mappingMap.get(slcp); mappingMap.remove(slcp); portMapList.add(createXpdrMappingObject(nodeId, null, null, null, null, mapping, dlcp, null)); } } if (device.getOduSwitchingPools() != null) { Collection oduSwithcingPools = device.nonnullOduSwitchingPools().values(); List switchingPoolList = new ArrayList<>(); for (OduSwitchingPools odp : oduSwithcingPools) { Map nbMap = new HashMap<>(); for (org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.org.openroadm.device.container.org .openroadm.device.odu.switching.pools.NonBlockingList nbl : odp.nonnullNonBlockingList().values()) { List lcpList = new ArrayList<>(); if (nbl.getPortList() != null) { for (PortList item : nbl.nonnullPortList().values()) { String key = item.getCircuitPackName() + "+" + item.getPortName(); if (lcpMap.containsKey(key)) { lcpList.add(lcpMap.get(key)); } else { LOG.error("error : port {} of {} is not associated to a logical connection point", item.getPortName(), item.getCircuitPackName()); } } NonBlockingList nonBlockingList = new NonBlockingListBuilder() .setNblNumber(nbl.getNblNumber()) .setInterconnectBandwidth(nbl.getInterconnectBandwidth()) .setInterconnectBandwidthUnit(nbl.getInterconnectBandwidthUnit()) .setLcpList(lcpList) .build(); nbMap.put(nonBlockingList.key(),nonBlockingList); } } SwitchingPoolLcp splBldr = new SwitchingPoolLcpBuilder() .setSwitchingPoolNumber(odp.getSwitchingPoolNumber()) .setSwitchingPoolType(odp.getSwitchingPoolType()) .setNonBlockingList(nbMap) .build(); switchingPoolList.add(splBldr); } postPortMapping(nodeId, null, null, null, switchingPoolList, null); } if (!mappingMap.isEmpty()) { mappingMap.forEach((k,v) -> portMapList.add(v)); } return true; } private boolean checkPartnerPort(String circuitPackName, Ports port1, Ports port2) { if ((Direction.Rx.getIntValue() == port1.getPortDirection().getIntValue() && Direction.Tx.getIntValue() == port2.getPortDirection().getIntValue() && port2.getPartnerPort() != null && port2.getPartnerPort().getCircuitPackName() != null && port2.getPartnerPort().getPortName() != null && port2.getPartnerPort().getCircuitPackName().equals(circuitPackName) && port2.getPartnerPort().getPortName().equals(port1.getPortName())) || (Direction.Tx.getIntValue() == port1.getPortDirection().getIntValue() && Direction.Rx.getIntValue() == port2.getPortDirection().getIntValue() && port2.getPartnerPort() != null && port2.getPartnerPort().getCircuitPackName() != null && port2.getPartnerPort().getPortName() != null && port2.getPartnerPort().getCircuitPackName().equals(circuitPackName) && port2.getPartnerPort().getPortName().equals(port1.getPortName()))) { return true; } else { return false; } } private HashMap> getSrgCps(String deviceId, Info ordmInfo) { HashMap> cpPerSrg = new HashMap<>(); Integer maxSrg; // Get value for max Srg from info subtree, required for iteration // if not present assume to be 20 (temporary) if (ordmInfo.getMaxSrgs() != null) { maxSrg = ordmInfo.getMaxSrgs().toJava(); } else { maxSrg = 20; } for (int srgCounter = 1; srgCounter <= maxSrg; srgCounter++) { List srgCps = new ArrayList<>(); LOG.info("Getting Circuitpacks for Srg Number {}", srgCounter); InstanceIdentifier srgIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(SharedRiskGroup.class, new SharedRiskGroupKey(Uint16.valueOf(srgCounter))); Optional ordmSrgObject = this.deviceTransactionManager.getDataFromDevice(deviceId, LogicalDatastoreType.OPERATIONAL, srgIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (ordmSrgObject.isPresent()) { srgCps.addAll(ordmSrgObject.get().nonnullCircuitPacks().values()); cpPerSrg.put(ordmSrgObject.get().getSrgNumber().toJava(), srgCps); } } LOG.info("Device {} has {} Srg", deviceId, cpPerSrg.size()); return cpPerSrg; } //last LOG info message in this method is too long @SuppressWarnings("checkstyle:linelength") private boolean createPpPortMapping(String nodeId, Info deviceInfo, List portMapList) { // Creating mapping data for SRG's PP HashMap> srgCps = getSrgCps(nodeId, deviceInfo); for (Entry> srgCpEntry : srgCps.entrySet()) { List cpList = srgCps.get(srgCpEntry.getKey()); List keys = new ArrayList<>(); for (org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.srg.CircuitPacks cp : cpList) { String circuitPackName = cp.getCircuitPackName(); InstanceIdentifier cpIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(circuitPackName)); Optional circuitPackObject = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, cpIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (!circuitPackObject.isPresent() || (circuitPackObject.get().getPorts() == null)) { LOG.warn("{} : Circuit pack {} not found or without ports.", nodeId, circuitPackName); continue; } List portList = new ArrayList<>(circuitPackObject.get().nonnullPorts().values()); Collections.sort(portList, new SortPort710ByName()); int portIndex = 1; for (Ports port : portList) { String currentKey = circuitPackName + "-" + port.getPortName(); if (port.getPortQual() == null) { continue; } else if (PortQual.RoadmExternal.getIntValue() == port.getPortQual().getIntValue() && Direction.Bidirectional.getIntValue() == port.getPortDirection().getIntValue() && !keys.contains(currentKey)) { String logicalConnectionPoint = createLogicalConnectionPort(port, srgCpEntry.getKey(), portIndex); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, circuitPackName, port.getPortName(), logicalConnectionPoint); portMapList.add(createMappingObject(nodeId, port, circuitPackName, logicalConnectionPoint)); portIndex++; keys.add(currentKey); } else if (PortQual.RoadmExternal.getIntValue() == port.getPortQual().getIntValue() && (Direction.Rx.getIntValue() == port.getPortDirection().getIntValue() || Direction.Tx.getIntValue() == port.getPortDirection().getIntValue()) && !keys.contains(currentKey) && port.getPartnerPort() != null) { String logicalConnectionPoint1 = createLogicalConnectionPort(port, srgCpEntry.getKey(), portIndex); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, circuitPackName, port.getPortName(), logicalConnectionPoint1); InstanceIdentifier port2ID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(port.getPartnerPort().getCircuitPackName())) .child(Ports.class, new PortsKey(port.getPartnerPort().getPortName().toString())); Optional port2Object = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, port2ID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (port2Object.isPresent() && port2Object.get().getPortQual().getIntValue() == PortQual.RoadmExternal.getIntValue()) { Ports port2 = port2Object.get(); if (checkPartnerPort(circuitPackName, port, port2)) { String logicalConnectionPoint2 = createLogicalConnectionPort(port2, srgCpEntry.getKey(), portIndex); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, circuitPackName, port2.getPortName(), logicalConnectionPoint2); portMapList.add(createMappingObject(nodeId, port, circuitPackName, logicalConnectionPoint1)); portMapList.add(createMappingObject(nodeId,port2, port.getPartnerPort().getCircuitPackName(), logicalConnectionPoint2)); portIndex++; keys.add(currentKey); keys.add(port.getPartnerPort().getCircuitPackName() + "-" + port2.getPortName()); } else { LOG.error("Error with partner port configuration for port {} of {} - {}", port.getPortName(), circuitPackName, nodeId); portIndex++; } } else { LOG.error("error getting partner port {} of {} - {}", port.getPartnerPort().getPortName().toString(), port.getPartnerPort().getCircuitPackName(), nodeId); continue; } } else { LOG.info("{} : port {} on {} is not roadm-external or has already been handled. No logicalConnectionPoint assignment for this port.", nodeId, port.getPortName(), circuitPackName); } } } } return true; } private String createLogicalConnectionPort(Ports port, int index, int portIndex) { String lcp = null; switch (port.getPortDirection()) { case Tx: lcp = "SRG" + index + "-PP" + portIndex + "-TX"; break; case Rx: lcp = "SRG" + index + "-PP" + portIndex + "-RX"; break; case Bidirectional: lcp = "SRG" + index + "-PP" + portIndex + "-TXRX"; break; default: LOG.error("Unsupported port direction for port {} : {}", port, port.getPortDirection()); } return lcp; } private Map getMcCapabilityProfiles(String deviceId, Info ordmInfo) { Map mcCapabilityProfiles = new HashMap<>(); InstanceIdentifier deviceIID = InstanceIdentifier.create(OrgOpenroadmDevice.class); Optional deviceObject = deviceTransactionManager.getDataFromDevice(deviceId, LogicalDatastoreType.OPERATIONAL, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); OrgOpenroadmDevice device = null; if (!deviceObject.isPresent()) { LOG.error("Impossible to get device configuration for node {}", deviceId); LOG.warn("MC-capabilities profile will be empty for node {}", deviceId); return mcCapabilityProfiles; } device = deviceObject.get(); mcCapabilityProfiles = device.getMcCapabilityProfile(); return mcCapabilityProfiles; } private List getDegrees(String deviceId, Info ordmInfo) { List degrees = new ArrayList<>(); Integer maxDegree; // Get value for max degree from info subtree, required for iteration // if not present assume to be 20 (temporary) if (ordmInfo.getMaxDegrees() != null) { maxDegree = ordmInfo.getMaxDegrees().toJava(); } else { maxDegree = 20; } for (int degreeCounter = 1; degreeCounter <= maxDegree; degreeCounter++) { LOG.info("Getting Connection ports for Degree Number {}", degreeCounter); InstanceIdentifier deviceIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(Degree.class, new DegreeKey(Uint16.valueOf(degreeCounter))); Optional ordmDegreeObject = this.deviceTransactionManager.getDataFromDevice(deviceId, LogicalDatastoreType.OPERATIONAL, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (ordmDegreeObject.isPresent()) { degrees.add(ordmDegreeObject.get()); } } LOG.info("Device {} has {} degree", deviceId, degrees.size()); return degrees; } private List getSrgs(String deviceId, Info ordmInfo) { List srgs = new ArrayList<>(); Integer maxSrg; // Get value for max Srg from info subtree, required for iteration // if not present assume to be 20 (temporary) if (ordmInfo.getMaxSrgs() != null) { maxSrg = ordmInfo.getMaxSrgs().toJava(); } else { maxSrg = 20; } for (int srgCounter = 1; srgCounter <= maxSrg; srgCounter++) { InstanceIdentifier srgIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(SharedRiskGroup.class, new SharedRiskGroupKey(Uint16.valueOf(srgCounter))); Optional ordmSrgObject = this.deviceTransactionManager.getDataFromDevice(deviceId, LogicalDatastoreType.OPERATIONAL, srgIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (ordmSrgObject.isPresent()) { srgs.add(ordmSrgObject.get()); } } return srgs; } private Map> getPerDegreePorts(String deviceId, Info ordmInfo) { Map> conPortMap = new HashMap<>(); Integer maxDegree; if (ordmInfo.getMaxDegrees() != null) { maxDegree = ordmInfo.getMaxDegrees().toJava(); } else { maxDegree = 20; } for (int degreeCounter = 1; degreeCounter <= maxDegree; degreeCounter++) { LOG.info("Getting Connection ports for Degree Number {}", degreeCounter); InstanceIdentifier deviceIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(Degree.class, new DegreeKey(Uint16.valueOf(degreeCounter))); Optional ordmDegreeObject = this.deviceTransactionManager.getDataFromDevice(deviceId, LogicalDatastoreType.OPERATIONAL, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (ordmDegreeObject.isPresent()) { conPortMap.put(degreeCounter, new ArrayList<>(ordmDegreeObject.get() .nonnullConnectionPorts().values())); } } LOG.info("Device {} has {} degree", deviceId, conPortMap.size()); return conPortMap; } private Map getEthInterfaceList(String nodeId) { LOG.info("It is calling get ethernet interface"); Map cpToInterfaceMap = new HashMap<>(); InstanceIdentifier protocoliid = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(Protocols.class); Optional protocolObject = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, protocoliid, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (protocolObject.isPresent() && protocolObject.get().augmentation(Protocols1.class).getLldp() != null) { Lldp lldp = protocolObject.get().augmentation(Protocols1.class).getLldp(); for (PortConfig portConfig : lldp.nonnullPortConfig().values()) { if (portConfig.getAdminStatus().equals(PortConfig.AdminStatus.Txandrx)) { InstanceIdentifier interfaceIID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(Interface.class, new InterfaceKey(portConfig.getIfName())); Optional interfaceObject = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, interfaceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (interfaceObject.isPresent() && (interfaceObject.get().getSupportingCircuitPackName() != null)) { String supportingCircuitPackName = interfaceObject.get().getSupportingCircuitPackName(); cpToInterfaceMap.put(supportingCircuitPackName, portConfig.getIfName()); InstanceIdentifier circuitPacksIID = InstanceIdentifier .create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(supportingCircuitPackName)); Optional circuitPackObject = this.deviceTransactionManager.getDataFromDevice( nodeId, LogicalDatastoreType.OPERATIONAL, circuitPacksIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (circuitPackObject.isPresent() && (circuitPackObject.get().getParentCircuitPack() != null)) { cpToInterfaceMap.put(circuitPackObject.get().getParentCircuitPack().getCircuitPackName(), portConfig.getIfName()); } } } } } else { LOG.warn("Couldnt find port config under LLDP for Node : {}", nodeId); } LOG.info("Processiong is done.. now returning.."); return cpToInterfaceMap; } private List getCpToDegreeList(List degrees, String nodeId, Map interfaceList) { List cpToDegreeList = new ArrayList<>(); for (Degree degree : degrees) { if (degree.getCircuitPacks() != null) { LOG.info("Inside CP to degree list"); cpToDegreeList.addAll(degree.nonnullCircuitPacks().values().stream() .map(cp -> createCpToDegreeObject(cp.getCircuitPackName(), degree.getDegreeNumber().toString(), nodeId, interfaceList)) .collect(Collectors.toList())); } } return cpToDegreeList; } private List getMcCapabilitiesList(List degrees, List srgs, Info deviceInfo, String nodeId) { LOG.info("Getting the MC capabilities for degrees of node {}", nodeId); //Get all the mc-capability profiles from the device Map mcCapabilityProfiles = getMcCapabilityProfiles(nodeId, deviceInfo); // Add the DEG mc-capabilities List mcCapabilitiesList = createMcCapDegreeObject(degrees, mcCapabilityProfiles, nodeId); // Add the SRG mc-capabilities LOG.info("Getting the MC capabilities for SRGs of node {}", nodeId); mcCapabilitiesList.addAll(createMcCapSrgObject(srgs, mcCapabilityProfiles, nodeId)); return mcCapabilitiesList; } private boolean postPortMapping(String nodeId, NodeInfo nodeInfo, List portMapList, List cp2DegreeList, List splList, List mcCapList) { NodesBuilder nodesBldr = new NodesBuilder().withKey(new NodesKey(nodeId)).setNodeId(nodeId); if (nodeInfo != null) { nodesBldr.setNodeInfo(nodeInfo); } if (portMapList != null) { Map mappingMap = new HashMap<>(); for (Mapping mapping: portMapList) { if (mapping != null) { mappingMap.put(mapping.key(), mapping); } } nodesBldr.setMapping(mappingMap); } if (cp2DegreeList != null) { Map cpToDegreeMap = new HashMap<>(); for (CpToDegree cp2Degree: cp2DegreeList) { if (cp2Degree != null) { cpToDegreeMap.put(cp2Degree.key(), cp2Degree); } } nodesBldr.setCpToDegree(cpToDegreeMap); } if (splList != null) { Map splMap = new HashMap<>(); for (SwitchingPoolLcp spl: splList) { if (spl != null) { splMap.put(spl.key(), spl); } } nodesBldr.setSwitchingPoolLcp(splMap); } if (mcCapList != null) { nodesBldr.setMcCapabilities(mcCapList); } Map nodesList = new HashMap<>(); Nodes nodes = nodesBldr.build(); nodesList.put(nodes.key(),nodes); Network network = new NetworkBuilder().setNodes(nodesList).build(); final WriteTransaction writeTransaction = dataBroker.newWriteOnlyTransaction(); InstanceIdentifier nodesIID = InstanceIdentifier.builder(Network.class).build(); writeTransaction.merge(LogicalDatastoreType.CONFIGURATION, nodesIID, network); FluentFuture commit = writeTransaction.commit(); try { commit.get(); return true; } catch (InterruptedException | ExecutionException e) { LOG.warn("Failed to post {}", network, e); return false; } } private CpToDegree createCpToDegreeObject(String circuitPackName, String degreeNumber, String nodeId, Map interfaceList) { String interfaceName = null; if (interfaceList.get(circuitPackName) != null) { interfaceName = interfaceList.get(circuitPackName); } return new CpToDegreeBuilder().withKey(new CpToDegreeKey(circuitPackName)).setCircuitPackName(circuitPackName) .setDegreeNumber(Uint32.valueOf(degreeNumber)).setInterfaceName(interfaceName).build(); } private List createMcCapDegreeObject(List degrees, Map mcCapabilityProfileMap, String nodeId) { List mcCapabilitiesList = new ArrayList<>(); for (Degree degree : degrees) { if ((degree.getMcCapabilityProfileName() == null) || (degree.getMcCapabilityProfileName().isEmpty())) { LOG.warn("No MC profiles are found for node {} on degree {}", nodeId, degree.getDegreeNumber()); LOG.warn("Assuming the fixed grid capabilities for degree {}", degree.getDegreeNumber()); LOG.warn("Assuming a default MC profile-name for degree {}", degree.getDegreeNumber()); String mcNodeName = "DEG" + degree.getDegreeNumber().toString() + "-TTP-" + "default-profile"; McCapabilitiesBuilder mcCapabilitiesBuilder = new McCapabilitiesBuilder() .withKey(new McCapabilitiesKey(mcNodeName)) .setMcNodeName(mcNodeName); mcCapabilitiesBuilder .setCenterFreqGranularity(FrequencyGHz.getDefaultInstance("50")) .setSlotWidthGranularity(FrequencyGHz.getDefaultInstance("50")); mcCapabilitiesList.add(mcCapabilitiesBuilder.build()); continue; } for (String mcCapabilityProfileName : degree.getMcCapabilityProfileName()) { McCapabilityProfileKey mcKey = new McCapabilityProfileKey(mcCapabilityProfileName); McCapabilityProfile mcCapabilityProfile = mcCapabilityProfileMap.get(mcKey); String mcNodeName = "DEG" + degree.getDegreeNumber().toString() + "-TTP-" + mcCapabilityProfile; McCapabilitiesBuilder mcCapabilitiesBuilder = new McCapabilitiesBuilder() .withKey(new McCapabilitiesKey(mcNodeName)) .setMcNodeName(mcNodeName); mcCapabilitiesBuilder .setCenterFreqGranularity(mcCapabilityProfile.getCenterFreqGranularity()) .setSlotWidthGranularity(mcCapabilityProfile.getSlotWidthGranularity()); mcCapabilitiesList.add(mcCapabilitiesBuilder.build()); } } return mcCapabilitiesList; } private List createMcCapSrgObject(List srgs, Map mcCapabilityProfileMap, String nodeId) { List mcCapabilitiesList = new ArrayList<>(); for (SharedRiskGroup srg : srgs) { if ((srg.getMcCapabilityProfileName() == null) || (srg.getMcCapabilityProfileName().isEmpty())) { LOG.warn("No MC profiles are found for node {} on SRG {}", nodeId, srg.getSrgNumber()); LOG.warn("Assuming the fixed grid capabilities for SRG {}", srg.getSrgNumber()); LOG.warn("Assuming a default MC profile-name for SRG {}", srg.getSrgNumber()); String mcNodeName = "SRG" + srg.getSrgNumber().toString() + "-PP-" + "default-profile"; McCapabilitiesBuilder mcCapabilitiesBuilder = new McCapabilitiesBuilder() .withKey(new McCapabilitiesKey(mcNodeName)) .setMcNodeName(mcNodeName); mcCapabilitiesBuilder .setCenterFreqGranularity(FrequencyGHz.getDefaultInstance("50")) .setSlotWidthGranularity(FrequencyGHz.getDefaultInstance("50")); mcCapabilitiesList.add(mcCapabilitiesBuilder.build()); continue; } for (String mcCapabilityProfileName : srg.getMcCapabilityProfileName()) { McCapabilityProfileKey mcKey = new McCapabilityProfileKey(mcCapabilityProfileName); McCapabilityProfile mcCapabilityProfile = mcCapabilityProfileMap.get(mcKey); String mcNodeName = "SRG" + srg.getSrgNumber().toString() + "-PP-" + mcCapabilityProfile; McCapabilitiesBuilder mcCapabilitiesBuilder = new McCapabilitiesBuilder() .withKey(new McCapabilitiesKey(mcNodeName)) .setMcNodeName(mcNodeName); mcCapabilitiesBuilder .setCenterFreqGranularity(mcCapabilityProfile.getCenterFreqGranularity()) .setSlotWidthGranularity(mcCapabilityProfile.getSlotWidthGranularity()); mcCapabilitiesList.add(mcCapabilitiesBuilder.build()); } } return mcCapabilitiesList; } private Mapping createMappingObject(String nodeId, Ports port, String circuitPackName, String logicalConnectionPoint) { MappingBuilder mpBldr = new MappingBuilder() .withKey(new MappingKey(logicalConnectionPoint)) .setLogicalConnectionPoint(logicalConnectionPoint) .setSupportingCircuitPackName(circuitPackName) .setSupportingPort(port.getPortName()) .setPortDirection(port.getPortDirection().getName()); // Get OMS and OTS interface provisioned on the TTP's if ((logicalConnectionPoint.contains(StringConstants.TTP_TOKEN) || logicalConnectionPoint.contains(StringConstants.NETWORK_TOKEN)) && (port.getInterfaces() != null)) { for (Interfaces interfaces : port.getInterfaces()) { try { Optional openRoadmInterface = this.openRoadmInterfaces.getInterface(nodeId, interfaces.getInterfaceName()); if (openRoadmInterface.isPresent()) { LOG.info("interface get from device is {} and of type {}", openRoadmInterface.get().getName(), openRoadmInterface.get().getType()); Class interfaceType = (Class) openRoadmInterface.get().getType(); // Check if interface type is OMS or OTS if (interfaceType.equals(OpenROADMOpticalMultiplex.class)) { mpBldr.setSupportingOms(interfaces.getInterfaceName()); } if (interfaceType.equals(OpticalTransport.class)) { mpBldr.setSupportingOts(interfaces.getInterfaceName()); } if (interfaceType.equals(OtnOdu.class)) { mpBldr.setSupportingOdu4(interfaces.getInterfaceName()); } } else { LOG.warn("Interface {} from node {} was null!", interfaces.getInterfaceName(), nodeId); } } catch (OpenRoadmInterfaceException ex) { LOG.warn("Error while getting interface {} from node {}!", interfaces.getInterfaceName(), nodeId, ex); } } } return mpBldr.build(); } private Mapping createXpdrMappingObject(String nodeId, Ports ports, String circuitPackName, String logicalConnectionPoint, String partnerLcp, Mapping mapping, String connectionMapLcp, XpdrNodeTypes xpdrNodeType) { if (mapping != null && connectionMapLcp != null) { // update existing mapping return new MappingBuilder(mapping).setConnectionMapLcp(connectionMapLcp).build(); } // create a new mapping String nodeIdLcp = nodeId + "-" + logicalConnectionPoint; MappingBuilder mpBldr = new MappingBuilder() .withKey(new MappingKey(logicalConnectionPoint)) .setLogicalConnectionPoint(logicalConnectionPoint) .setSupportingCircuitPackName(circuitPackName) .setSupportingPort(ports.getPortName()) .setPortDirection(ports.getPortDirection().getName()) .setLcpHashVal(FnvUtils.fnv1_64(nodeIdLcp)); if (ports.getPortQual() != null) { mpBldr.setPortQual(ports.getPortQual().getName()); } if (xpdrNodeType != null) { mpBldr.setXponderType(xpdrNodeType); } if (partnerLcp != null) { mpBldr.setPartnerLcp(partnerLcp); } return mpBldr.build(); } private boolean createMcCapabilitiesList(String nodeId, Info deviceInfo, List mcCapabilitiesList) { List degrees = getDegrees(nodeId, deviceInfo); List srgs = getSrgs(nodeId, deviceInfo); mcCapabilitiesList.addAll(getMcCapabilitiesList(degrees, srgs, deviceInfo, nodeId)); return true; } //some LOG messages are too long @SuppressWarnings("checkstyle:linelength") @SuppressFBWarnings("DM_CONVERT_CASE") private boolean createTtpPortMapping(String nodeId, Info deviceInfo, List portMapList) { // Creating mapping data for degree TTP's List degrees = getDegrees(nodeId, deviceInfo); Map interfaceList = getEthInterfaceList(nodeId); List cpToDegreeList = getCpToDegreeList(degrees, nodeId, interfaceList); LOG.info("Map looks like this {}", interfaceList); postPortMapping(nodeId, null, null, cpToDegreeList, null, null); Map> connectionPortMap = getPerDegreePorts(nodeId, deviceInfo); for (Entry> cpMapEntry : connectionPortMap.entrySet()) { switch (connectionPortMap.get(cpMapEntry.getKey()).size()) { case 1: // port is bidirectional InstanceIdentifier portID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(connectionPortMap.get(cpMapEntry.getKey()).get(0) .getCircuitPackName())) .child(Ports.class, new PortsKey(connectionPortMap.get(cpMapEntry.getKey()).get(0) .getPortName().toString())); LOG.info("Fetching connection-port {} at circuit pack {}", connectionPortMap.get(cpMapEntry.getKey()).get(0) .getPortName().toString(), connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName()); Optional portObject = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, portID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (portObject.isPresent()) { Ports port = portObject.get(); if (port.getPortQual() == null) { continue; } else if (PortQual.RoadmExternal.getIntValue() == port.getPortQual().getIntValue() && Direction.Bidirectional.getIntValue() == port.getPortDirection().getIntValue()) { String logicalConnectionPoint = new StringBuilder("DEG").append(cpMapEntry.getKey()).append("-TTP-TXRX") .toString(); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), port.getPortName(), logicalConnectionPoint); portMapList.add(createMappingObject(nodeId, port, connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), logicalConnectionPoint)); } else { LOG.error( "Impossible to create logical connection point for port {} of {} on node {}" + "- Error in configuration with port-qual or port-direction", port.getPortName(), connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), nodeId); } } else { LOG.error("No port {} on circuit pack {} for node {}", connectionPortMap.get(cpMapEntry.getKey()).get(0).getPortName().toString(), connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), nodeId); return false; } break; case 2: // ports are unidirectionals String cp1Name = connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(); String cp2Name = connectionPortMap.get(cpMapEntry.getKey()).get(1).getCircuitPackName(); InstanceIdentifier port1ID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(cp1Name)) .child(Ports.class, new PortsKey(connectionPortMap.get(cpMapEntry.getKey()).get(0).getPortName().toString())); LOG.info("Fetching connection-port {} at circuit pack {}", connectionPortMap.get(cpMapEntry.getKey()).get(0) .getPortName().toString(), cp1Name); Optional port1Object = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, port1ID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); InstanceIdentifier port2ID = InstanceIdentifier.create(OrgOpenroadmDevice.class) .child(CircuitPacks.class, new CircuitPacksKey(cp2Name)) .child(Ports.class, new PortsKey(connectionPortMap.get(cpMapEntry.getKey()).get(1).getPortName().toString())); LOG.info("Fetching connection-port {} at circuit pack {}", connectionPortMap.get(cpMapEntry.getKey()).get(1).getPortName().toString(), cp2Name); Optional port2Object = this.deviceTransactionManager.getDataFromDevice(nodeId, LogicalDatastoreType.OPERATIONAL, port2ID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT); if (port1Object.isPresent() && port2Object.isPresent()) { Ports port1 = port1Object.get(); Ports port2 = port2Object.get(); if (port1.getPortQual() == null || port2.getPortQual() == null) { continue; } else if ((PortQual.RoadmExternal.getIntValue() == port1.getPortQual().getIntValue() && PortQual.RoadmExternal.getIntValue() == port2.getPortQual().getIntValue() && Direction.Rx.getIntValue() == port1.getPortDirection().getIntValue() && Direction.Tx.getIntValue() == port2.getPortDirection().getIntValue() && port1.getPartnerPort() != null && port2.getPartnerPort() != null && port1.getPartnerPort().getCircuitPackName().equals(cp2Name) && port1.getPartnerPort().getPortName().equals(port2.getPortName()) && port2.getPartnerPort().getCircuitPackName().equals(cp1Name) && port2.getPartnerPort().getPortName().equals(port1.getPortName())) || (PortQual.RoadmExternal.getIntValue() == port1.getPortQual().getIntValue() && PortQual.RoadmExternal.getIntValue() == port2.getPortQual().getIntValue() && Direction.Rx.getIntValue() == port2.getPortDirection().getIntValue() && Direction.Tx.getIntValue() == port1.getPortDirection().getIntValue() && port1.getPartnerPort() != null && port2.getPartnerPort() != null && port1.getPartnerPort().getCircuitPackName().equals(cp2Name) && port1.getPartnerPort().getPortName().equals(port2.getPortName()) && port2.getPartnerPort().getCircuitPackName().equals(cp1Name) && port2.getPartnerPort().getPortName().equals(port1.getPortName()))) { String logicalConnectionPoint1 = new StringBuilder("DEG").append(cpMapEntry.getKey()).append("-TTP-") .append(port1.getPortDirection().getName().toUpperCase()).toString(); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), port1.getPortName(), logicalConnectionPoint1); portMapList.add(createMappingObject(nodeId, port1, connectionPortMap.get(cpMapEntry.getKey()).get(0) .getCircuitPackName(), logicalConnectionPoint1)); String logicalConnectionPoint2 = new StringBuilder("DEG").append(cpMapEntry.getKey()).append("-TTP-") .append(port2.getPortDirection().getName().toUpperCase()).toString(); LOG.info("{} : Logical Connection Point for {} {} is {}", nodeId, connectionPortMap.get(cpMapEntry.getKey()).get(1).getCircuitPackName(), port2.getPortName(), logicalConnectionPoint2); portMapList.add(createMappingObject(nodeId, port2, connectionPortMap.get(cpMapEntry.getKey()).get(1) .getCircuitPackName(), logicalConnectionPoint2)); } else { LOG.error( "impossible to create logical connection point for port {} or port {} on node {} - " + "Error in configuration with port-qual, port-direction or partner-port configuration", port1.getPortName(), port2.getPortName(), nodeId); } } else { LOG.error("No port {} on circuit pack {} for node {}", connectionPortMap.get(cpMapEntry.getKey()).get(0).getPortName().toString(), connectionPortMap.get(cpMapEntry.getKey()).get(0).getCircuitPackName(), nodeId); return false; } break; default: LOG.error("Number of connection port for DEG{} on {} is incorrect", cpMapEntry.getKey(), nodeId); continue; } } return true; } private NodeInfo createNodeInfo(Info deviceInfo) { if (deviceInfo.getNodeType() == null) { // TODO make mandatory in yang LOG.error("Node type field is missing"); return null; } NodeInfoBuilder nodeInfoBldr = new NodeInfoBuilder() .setOpenroadmVersion(OpenroadmVersion._710) .setNodeType(deviceInfo.getNodeType()); // TODO: 221 versions expects an int value - need to check whether it is bug or an evolution here if (deviceInfo.getClli() != null && !deviceInfo.getClli().isEmpty()) { nodeInfoBldr.setNodeClli(deviceInfo.getClli()); } else { nodeInfoBldr.setNodeClli("defaultCLLI"); } if (deviceInfo.getModel() != null) { nodeInfoBldr.setNodeModel(deviceInfo.getModel()); } if (deviceInfo.getVendor() != null) { nodeInfoBldr.setNodeVendor(deviceInfo.getVendor()); } if (deviceInfo.getIpAddress() != null) { nodeInfoBldr.setNodeIpAddress(deviceInfo.getIpAddress()); } return nodeInfoBldr.build(); } }