/* * Copyright © 2019 Orange, 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.pce.networkanalyzer; import java.math.BigDecimal; import java.util.ArrayList; import java.util.BitSet; import java.util.Comparator; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.TreeMap; import java.util.stream.Collectors; import org.opendaylight.transportpce.common.StringConstants; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State; import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates; import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPools; import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList; import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmNodeType; import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmTpType; import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapability; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTU4TsAllocated; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTUCnTs; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPools; import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.XpdrTpPortConnectionAttributes; import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If100GEODU4; import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GEODU2e; import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If1GEODU0; import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCHOTU4ODU4; import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOtsiOtsigroup; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint; import org.opendaylight.yangtools.yang.common.Uint16; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class PceOtnNode implements PceNode { /* Logging. */ private static final Logger LOG = LoggerFactory.getLogger(PceOtnNode.class); ////////////////////////// OTN NODES /////////////////////////// /* * For This Class the node passed shall be at the otn-openroadm Layer */ private static List serviceTypeOduList = List.of( StringConstants.SERVICE_TYPE_ODU4, StringConstants.SERVICE_TYPE_ODUC4, StringConstants.SERVICE_TYPE_ODUC3, StringConstants.SERVICE_TYPE_ODUC2); private static Map> serviceTypeEthClassMap = Map.of( StringConstants.SERVICE_TYPE_1GE, If1GEODU0.class, StringConstants.SERVICE_TYPE_10GE, If10GEODU2e.class, StringConstants.SERVICE_TYPE_100GE_T, If100GEODU4.class, StringConstants.SERVICE_TYPE_100GE_M, If100GEODU4.class, StringConstants.SERVICE_TYPE_100GE_S, If100GEODU4.class); private static Map serviceTypeEthTsNbMap = Map.of( StringConstants.SERVICE_TYPE_1GE, 1, StringConstants.SERVICE_TYPE_10GE, 10, StringConstants.SERVICE_TYPE_100GE_M, 20); private static Map serviceTypeEthOduStringMap = Map.of( StringConstants.SERVICE_TYPE_1GE, "ODU0", StringConstants.SERVICE_TYPE_10GE, "ODU2e", StringConstants.SERVICE_TYPE_100GE_M, "ODU4"); private boolean valid = true; private final Node node; private final NodeId nodeId; private final OpenroadmNodeType nodeType; private final String pceNodeType; private final String otnServiceType; private String modeType; // TODO: not adding state check in this class as otn topology has not been modified private final AdminStates adminStates; private final State state; private Map> tpAvailableTribPort = new TreeMap<>(); private Map> tpAvailableTribSlot = new TreeMap<>(); private Map availableXponderTp = new TreeMap<>(); private List usedXpdrNWTps = new ArrayList<>(); private List availableXpdrNWTps; private List usableXpdrNWTps; private List usedXpdrClientTps = new ArrayList<>(); private List availableXpdrClientTps; private List usableXpdrClientTps; private List outgoingLinks = new ArrayList<>(); private Map clientPerNwTp = new HashMap<>(); private String clientPort; public PceOtnNode(Node node, OpenroadmNodeType nodeType, NodeId nodeId, String pceNodeType, String serviceType, String clientPort) { this.node = node; this.nodeId = nodeId; this.nodeType = nodeType; this.pceNodeType = pceNodeType; this.otnServiceType = serviceType; this.tpAvailableTribSlot.clear(); this.usedXpdrNWTps.clear(); this.availableXpdrNWTps = new ArrayList<>(); this.usableXpdrNWTps = new ArrayList<>(); this.usedXpdrClientTps.clear(); this.availableXpdrClientTps = new ArrayList<>(); this.usableXpdrClientTps = new ArrayList<>(); this.adminStates = node .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1.class) .getAdministrativeState(); this.state = node .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1.class) .getOperationalState(); this.tpAvailableTribPort.clear(); checkAvailableTribPort(); this.tpAvailableTribSlot.clear(); checkAvailableTribSlot(); this.clientPort = clientPort; if (node == null || nodeId == null || nodeType != OpenroadmNodeType.MUXPDR && nodeType != OpenroadmNodeType.SWITCH && nodeType != OpenroadmNodeType.TPDR) { LOG.error("PceOtnNode: one of parameters is not populated : nodeId, node type"); this.valid = false; } } public void initXndrTps(String mode) { LOG.info("PceOtnNode: initXndrTps for node {}", this.nodeId.getValue()); this.availableXponderTp.clear(); this.modeType = mode; List allTps = new ArrayList<>( this.node.augmentation( org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226 .Node1.class) .nonnullTerminationPoint() .values()); this.valid = false; if (allTps.isEmpty()) { LOG.error("PceOtnNode: initXndrTps: XPONDER TerminationPoint list is empty for node {}", this); return; } for (TerminationPoint tp : allTps) { org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1 ocnTp1 = tp.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529 .TerminationPoint1.class); if (ocnTp1 == null) { LOG.warn("null ocn TP {}", tp); continue; } //TODO many nested structures below, this needs to be reworked switch (ocnTp1.getTpType()) { case XPONDERNETWORK: if (tp.augmentation(TerminationPoint1.class) == null) { continue; } TerminationPoint1 ontTp1 = tp.augmentation(TerminationPoint1.class); if (serviceTypeOduList.contains(this.otnServiceType) || StringConstants.SERVICE_TYPE_100GE_S.equals(this.otnServiceType)) { // TODO verify the capability of network port to support ODU4 CTP interface creation if (!checkTpForOdtuTermination(ontTp1)) { LOG.error("TP {} of {} does not allow ODU4 termination creation", tp.getTpId().getValue(), node.getNodeId().getValue()); continue; } } else if (serviceTypeEthTsNbMap.containsKey(this.otnServiceType)) { if (!checkOdtuTTPforLoOduCreation(ontTp1, serviceTypeEthTsNbMap.get(this.otnServiceType))) { LOG.error("TP {} of {} does not allow {} termination creation", tp.getTpId().getValue(), serviceTypeEthOduStringMap.get(this.otnServiceType), node.getNodeId().getValue()); continue; } // TODO what about SERVICE_TYPE_100GE_T ? } else { LOG.error("TP {} of {} does not allow any termination creation", tp.getTpId().getValue(), node.getNodeId().getValue()); continue; } LOG.info("TP {} of XPONDER {} is validated", tp.getTpId(), node.getNodeId().getValue()); this.availableXpdrNWTps.add(tp.getTpId()); break; case XPONDERCLIENT: if (serviceTypeEthClassMap.containsKey(otnServiceType) && !StringConstants.SERVICE_TYPE_100GE_T.equals(this.otnServiceType)) { // TODO should we really exclude SERVICE_TYPE_100GE_T ? if (tp.augmentation(TerminationPoint1.class) == null) { continue; } if (checkClientTp(tp.augmentation(TerminationPoint1.class))) { LOG.info("TP {} of XPONDER {} is validated", tp.getTpId(), node.getNodeId().getValue()); this.availableXpdrClientTps.add(tp.getTpId()); } else { LOG.error("TP {} of {} does not allow lo-ODU (ODU2e or ODU0) termination creation", tp.getTpId().getValue(), node.getNodeId().getValue()); } } break; default: LOG.debug("unsupported ocn TP type {}", ocnTp1.getTpType()); } } this.valid = serviceTypeOduList.contains(this.otnServiceType) || (serviceTypeEthTsNbMap.containsKey(this.otnServiceType) && ((mode.equals("AZ") && checkSwPool(availableXpdrClientTps, availableXpdrNWTps, 1, 1)) || (mode.equals("intermediate") && checkSwPool(null, availableXpdrNWTps, 0, 2))) ) || (StringConstants.SERVICE_TYPE_100GE_S.equals(this.otnServiceType) && ((mode.equals("AZ") && checkSwPool(availableXpdrClientTps, availableXpdrNWTps, 1, 1))) || (mode.equals("intermediate") && checkSwPool(availableXpdrClientTps, availableXpdrNWTps, 0, 2)) ); //TODO checks very similar to isIntermediate and isAz methods - they should be mutualized // perhaps even with isOtnServiceTypeValid method } private boolean checkSwPool(List clientTps, List netwTps, int nbClient, int nbNetw) { if (clientTps != null && netwTps != null && nbClient == 1 && nbNetw == 1) { clientTps.sort(Comparator.comparing(TpId::getValue)); netwTps.sort(Comparator.comparing(TpId::getValue)); for (TpId nwTp : netwTps) { for (TpId clTp : clientTps) { for (NonBlockingList nbl : new ArrayList<>(node.augmentation(Node1.class).getSwitchingPools() .nonnullOduSwitchingPools().values().stream().findFirst().get() .getNonBlockingList().values())) { if (nbl.getTpList().contains(clTp) && nbl.getTpList().contains(nwTp)) { usableXpdrClientTps.add(clTp); usableXpdrNWTps.add(nwTp); } if (usableXpdrClientTps.size() >= nbClient && usableXpdrNWTps.size() >= nbNetw) { if (this.clientPort == null || this.clientPort.equals(clTp.getValue())) { clientPerNwTp.put(nwTp.getValue(), clTp.getValue()); return true; } } } } } } if (netwTps != null && nbClient == 0 && nbNetw == 2) { netwTps.sort(Comparator.comparing(TpId::getValue)); for (NonBlockingList nbl : new ArrayList<>(node.augmentation(Node1.class).getSwitchingPools() .nonnullOduSwitchingPools().values().stream().findFirst().get() .getNonBlockingList().values())) { for (TpId nwTp : netwTps) { if (nbl.getTpList().contains(nwTp)) { usableXpdrNWTps.add(nwTp); } if (usableXpdrNWTps.size() >= nbNetw) { return true; } } } } return false; } private boolean checkTpForOdtuTermination(TerminationPoint1 ontTp1) { for (SupportedInterfaceCapability sic : ontTp1.getTpSupportedInterfaces().getSupportedInterfaceCapability() .values()) { LOG.info("in checkTpForOduTermination - sic = {}", sic.getIfCapType()); if ((sic.getIfCapType().equals(IfOCHOTU4ODU4.class) || sic.getIfCapType().equals(IfOtsiOtsigroup.class)) && (ontTp1.getXpdrTpPortConnectionAttributes() == null || ontTp1.getXpdrTpPortConnectionAttributes().getTsPool() == null)) { return true; } } return false; } private boolean checkOdtuTTPforLoOduCreation(TerminationPoint1 ontTp1, int tsNb) { XpdrTpPortConnectionAttributes portConAttr = ontTp1.getXpdrTpPortConnectionAttributes(); return portConAttr != null && portConAttr.getTsPool() != null && portConAttr.getTsPool().size() >= tsNb && portConAttr.getOdtuTpnPool() != null && (portConAttr.getOdtuTpnPool().values() .stream().findFirst().get().getOdtuType() .equals(ODTU4TsAllocated.class) || portConAttr.getOdtuTpnPool().values() .stream().findFirst().get().getOdtuType() .equals(ODTUCnTs.class)) && !portConAttr.getOdtuTpnPool().values() .stream().findFirst().get().getTpnPool() .isEmpty(); //TODO a dedicated method for OdtuTpnPool first value would probably be welcome } private boolean checkClientTp(TerminationPoint1 ontTp1) { for (SupportedInterfaceCapability sic : ontTp1.getTpSupportedInterfaces().getSupportedInterfaceCapability() .values()) { LOG.debug("in checkTpForOduTermination - sic = {}", sic.getIfCapType()); // we could also check the administrative status of the tp if (serviceTypeEthClassMap.containsKey(otnServiceType) && sic.getIfCapType().equals(serviceTypeEthClassMap.get(otnServiceType))) { return true; } } return false; } public void validateXponder(String anodeId, String znodeId) { if (!isValid()) { return; } if (this.nodeId.getValue().equals(anodeId) || (this.nodeId.getValue().equals(znodeId))) { initXndrTps("AZ"); } else if (OpenroadmNodeType.SWITCH.equals(this.nodeType)) { initXndrTps("intermediate"); } else { LOG.info("validateAZxponder: XPONDER is ignored == {}", nodeId.getValue()); valid = false; } } public boolean validateSwitchingPoolBandwidth(TerminationPoint tp1, TerminationPoint tp2, Long neededBW) { if (this.nodeType != OpenroadmNodeType.TPDR) { return true; } Node1 node1 = node.augmentation(Node1.class); SwitchingPools sp = node1.getSwitchingPools(); List osp = new ArrayList<>(sp.nonnullOduSwitchingPools().values()); for (OduSwitchingPools ospx : osp) { List nbl = new ArrayList<>(ospx.nonnullNonBlockingList().values()); for (NonBlockingList nbll : nbl) { if (nbll.getAvailableInterconnectBandwidth().toJava() >= neededBW && nbll.getTpList() != null && nbll.getTpList().contains(tp1.getTpId()) && nbll.getTpList().contains(tp2.getTpId())) { LOG.debug("validateSwitchingPoolBandwidth: couple of tp {} x {} valid for crossconnection", tp1.getTpId(), tp2.getTpId()); return true; } } } LOG.debug("validateSwitchingPoolBandwidth: No valid Switching pool for crossconnecting tp {} and {}", tp1.getTpId(), tp2.getTpId()); return false; } public void validateIntermediateSwitch() { if (!isValid()) { return; } if (this.nodeType != OpenroadmNodeType.SWITCH) { return; } // Validate switch for use as an intermediate XPONDER on the path initXndrTps("intermediate"); if (this.valid) { LOG.info("validateIntermediateSwitch: Switch usable for transit == {}", nodeId.getValue()); } else { LOG.debug("validateIntermediateSwitch: Switch unusable for transit == {}", nodeId.getValue()); } } public void checkAvailableTribPort() { for (TerminationPoint tp : node.augmentation( org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226 .Node1.class) .getTerminationPoint().values().stream() .filter(type -> type .augmentation( org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529 .TerminationPoint1.class) .getTpType() .equals(OpenroadmTpType.XPONDERNETWORK)) .collect(Collectors.toList())) { XpdrTpPortConnectionAttributes portConAttr = tp.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes(); if (portConAttr != null && portConAttr.getOdtuTpnPool() != null && (portConAttr.getOdtuTpnPool().values().stream().findFirst().get().getOdtuType() .equals(ODTU4TsAllocated.class) || portConAttr.getOdtuTpnPool().values().stream().findFirst().get().getOdtuType() .equals(ODTUCnTs.class))) { //TODO a dedicated method for OdtuTpnPool first value would probably be welcome List tpnPool = portConAttr.getOdtuTpnPool().values().stream().findFirst().get().getTpnPool(); if (tpnPool != null) { tpAvailableTribPort.put(tp.getTpId().getValue(), tpnPool); } } } } public void checkAvailableTribSlot() { for (TerminationPoint tp : node.augmentation( org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class) .getTerminationPoint().values().stream() .filter(type -> type .augmentation( org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1.class) .getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) .collect(Collectors.toList()) ) { XpdrTpPortConnectionAttributes portConAttr = tp.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes(); if (portConAttr != null && portConAttr.getTsPool() != null) { tpAvailableTribSlot.put(tp.getTpId().getValue(), portConAttr.getTsPool()); } } } public boolean isValid() { if (node == null || nodeId == null || nodeType == null || this.getSupNetworkNodeId() == null || this.getSupClliNodeId() == null) { LOG.error("PceNode: one of parameters is not populated : nodeId, node type, supporting nodeId"); valid = false; } return valid; } public boolean isPceOtnNodeValid(final PceOtnNode pceOtnNode) { if (pceOtnNode == null || pceOtnNode.node == null || pceOtnNode.getNodeId() == null || pceOtnNode.nodeType == null || pceOtnNode.getSupNetworkNodeId() == null || pceOtnNode.getSupClliNodeId() == null || pceOtnNode.otnServiceType == null) { LOG.error( "PceOtnNode: one of parameters is not populated : nodeId, node type, supporting nodeId, otnServiceType" ); return false; } if (isNodeTypeValid(pceOtnNode)) { return isOtnServiceTypeValid(pceOtnNode); } LOG.error("PceOtnNode node type: node type is not one of MUXPDR or SWITCH or TPDR"); return false; } private boolean isOtnServiceTypeValid(PceOtnNode pceOtnNode) { if (pceOtnNode.modeType == null) { return false; } //Todo refactor Strings (mode and otnServiceType ) to enums if (pceOtnNode.otnServiceType.equals(StringConstants.SERVICE_TYPE_ODU4) && pceOtnNode.modeType.equals("AZ")) { return true; } return (pceOtnNode.otnServiceType.equals(StringConstants.SERVICE_TYPE_10GE) || pceOtnNode.otnServiceType.equals(StringConstants.SERVICE_TYPE_1GE) || pceOtnNode.otnServiceType.equals(StringConstants.SERVICE_TYPE_100GE_S)) && (isAz(pceOtnNode) || isIntermediate(pceOtnNode)); //TODO serviceTypeEthTsNbMap.containsKey(this.otnServiceType) might be more appropriate here // but only SERVICE_TYPE_100GE_S is managed and not SERVICE_TYPE_100GE_M and _T } private boolean isIntermediate(PceOtnNode pceOtnNode) { return pceOtnNode.modeType.equals("intermediate") && checkSwPool(null, pceOtnNode.availableXpdrNWTps, 0, 2); } private boolean isAz(PceOtnNode pceOtnNode) { return pceOtnNode.modeType.equals("AZ") && checkSwPool(pceOtnNode.availableXpdrClientTps, pceOtnNode.availableXpdrNWTps, 1, 1); } private boolean isNodeTypeValid(final PceOtnNode pceOtnNode) { return pceOtnNode.nodeType == OpenroadmNodeType.MUXPDR || pceOtnNode.nodeType == OpenroadmNodeType.SWITCH || pceOtnNode.nodeType == OpenroadmNodeType.TPDR; } @Override public void addOutgoingLink(PceLink outLink) { this.outgoingLinks.add(outLink); } @Override public List getOutgoingLinks() { return outgoingLinks; } @Override public AdminStates getAdminStates() { return adminStates; } @Override public State getState() { return state; } @Override public String getXpdrClient(String tp) { return this.clientPerNwTp.get(tp); } @Override public String toString() { return "PceNode type=" + nodeType + " ID=" + nodeId.getValue() + " CLLI=" + this.getSupClliNodeId(); } public void printLinksOfNode() { LOG.info(" outgoing links of node {} : {} ", nodeId.getValue(), this.getOutgoingLinks()); } @Override public Map> getAvailableTribPorts() { return tpAvailableTribPort; } @Override public Map> getAvailableTribSlots() { return tpAvailableTribSlot; } public List getUsableXpdrNWTps() { return usableXpdrNWTps; } public List getUsableXpdrClientTps() { return usableXpdrClientTps; } @Override public String getPceNodeType() { return this.pceNodeType; } @Override public String getSupNetworkNodeId() { return MapUtils.getSupNetworkNode(this.node); } @Override public String getSupClliNodeId() { return MapUtils.getSupClliNode(this.node); } @Override public String getRdmSrgClient(String tp, String direction) { return null; } @Override public NodeId getNodeId() { return nodeId; } @Override public boolean checkTP(String tp) { return false; } /* * (non-Javadoc) * * @see org.opendaylight.transportpce.pce.networkanalyzer.PceNode#getVersion() */ @Override public String getVersion() { // TODO Auto-generated method stub return null; } @Override public BitSet getBitSetData() { // TODO Auto-generated method stub return null; } /* * (non-Javadoc) * * @see org.opendaylight.transportpce.pce.networkanalyzer.PceNode#getSlotWidthGranularity() */ @Override public BigDecimal getSlotWidthGranularity() { return null; } /* * (non-Javadoc) * * @see org.opendaylight.transportpce.pce.networkanalyzer.PceNode#getCentralFreqGranularity() */ @Override public BigDecimal getCentralFreqGranularity() { return null; } }