import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
import org.jgrapht.GraphPath;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.transportpce.common.InstanceIdentifiers;
import org.opendaylight.transportpce.common.ResponseCodes;
import org.opendaylight.transportpce.common.StringConstants;
+import org.opendaylight.transportpce.common.catalog.CatalogConstant;
+import org.opendaylight.transportpce.common.catalog.CatalogConstant.CatalogNodeType;
+import org.opendaylight.transportpce.common.catalog.CatalogUtils;
import org.opendaylight.transportpce.common.fixedflex.GridConstant;
import org.opendaylight.transportpce.common.fixedflex.GridUtils;
+import org.opendaylight.transportpce.common.network.NetworkTransactionService;
import org.opendaylight.transportpce.pce.constraints.PceConstraints;
import org.opendaylight.transportpce.pce.constraints.PceConstraints.ResourcePair;
+import org.opendaylight.transportpce.pce.networkanalyzer.PceLink;
import org.opendaylight.transportpce.pce.networkanalyzer.PceNode;
import org.opendaylight.transportpce.pce.networkanalyzer.PceResult;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.SpectrumAssignment;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.SpectrumAssignmentBuilder;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.TerminationPoint1;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.networks.network.node.termination.point.XpdrNetworkAttributes;
import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmLinkType;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmNodeType;
import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OpucnTribSlotDef;
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.topology.rev180226.LinkId;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.common.Uint16;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/* Logging. */
private static final Logger LOG = LoggerFactory.getLogger(PostAlgoPathValidator.class);
- private static final double MIN_OSNR_W100G = 17;
- private static final double TRX_OSNR = 33;
- private static final double ADD_OSNR = 30;
public static final Long CONST_OSNR = 1L;
public static final double SYS_MARGIN = 0;
+ private Double tpceCalculatedMargin = 0.0;
+ private final NetworkTransactionService networkTransactionService;
+
+ public PostAlgoPathValidator(NetworkTransactionService networkTransactionService) {
+ this.networkTransactionService = networkTransactionService;
+ }
@SuppressWarnings("fallthrough")
@SuppressFBWarnings(
value = "SF_SWITCH_FALLTHROUGH",
justification = "intentional fallthrough")
- public PceResult checkPath(GraphPath<String, PceGraphEdge> path, Map<NodeId, PceNode> allPceNodes,
- PceResult pceResult, PceConstraints pceHardConstraints, String serviceType) {
+ public PceResult checkPath(GraphPath<String, PceGraphEdge> path, Map<NodeId, PceNode> allPceNodes,
+ Map<LinkId, PceLink> allPceLinks, PceResult pceResult, PceConstraints pceHardConstraints,
+ String serviceType) {
+ LOG.info("path = {}", path);
// check if the path is empty
if (path.getEdgeList().isEmpty()) {
pceResult.setRC(ResponseCodes.RESPONSE_FAILED);
LOG.debug("In PostAlgoPathValidator: spectrum assignment found {} {}", spectrumAssignment, path);
// Check the OSNR
- if (!checkOSNR(path)) {
- pceResult.setRC(ResponseCodes.RESPONSE_FAILED);
- pceResult.setLocalCause(PceResult.LocalCause.OUT_OF_SPEC_OSNR);
- return pceResult;
+ CatalogUtils cu = new CatalogUtils(networkTransactionService);
+ if (cu.isCatalogFilled()) {
+ double margin1 = checkOSNR(path, allPceNodes, allPceLinks, serviceType,
+ StringConstants.SERVICE_DIRECTION_AZ, cu);
+ double margin2 = checkOSNR(path, allPceNodes, allPceLinks, serviceType,
+ StringConstants.SERVICE_DIRECTION_ZA, cu);
+ if (margin1 < 0 || margin2 < 0 || margin1 == Double.NEGATIVE_INFINITY
+ || margin2 == Double.NEGATIVE_INFINITY) {
+ pceResult.setRC(ResponseCodes.RESPONSE_FAILED);
+ pceResult.setLocalCause(PceResult.LocalCause.OUT_OF_SPEC_OSNR);
+ return pceResult;
+ }
+ this.tpceCalculatedMargin = Math.min(margin1, margin2);
+ LOG.info(
+ "In PostAlgoPathValidator: Minimum margin estimated by tpce on AtoZ and ZtoA path is of {} dB",
+ this.tpceCalculatedMargin);
+ } else {
+ this.tpceCalculatedMargin = 0.0;
+ LOG.info("In PostAlgoPathValidator: Operational mode Catalog not filled, delegate OSNR calculation"
+ + " to GNPy and margin set to 0");
}
// Check if MaxLatency is defined in the hard constraints
return minmaxTpTsList;
}
- // Check the path OSNR
- private boolean checkOSNR(GraphPath<String, PceGraphEdge> path) {
- double linkOsnrDb;
- double osnrDb = 0;
- LOG.info("- In checkOSNR: OSNR of the transmitter = {} dB", TRX_OSNR);
- LOG.info("- In checkOSNR: add-path incremental OSNR = {} dB", ADD_OSNR);
- double inverseLocalOsnr = getInverseOsnrLinkLu(TRX_OSNR) + getInverseOsnrLinkLu(ADD_OSNR);
- for (PceGraphEdge edge : path.getEdgeList()) {
- if (edge.link().getlinkType() == OpenroadmLinkType.ROADMTOROADM) {
- // link OSNR in dB
- linkOsnrDb = edge.link().getosnr();
- LOG.info("- In checkOSNR: OSNR of {} = {} dB", edge.link().getLinkId().getValue(), linkOsnrDb);
- // 1 over the local OSNR, in linear units
- inverseLocalOsnr += getInverseOsnrLinkLu(linkOsnrDb);
+ /**
+ * Calculates the OSNR of a path, according to the direction (AtoZ/ZtoA), using the operational-modes Catalog.
+ *
+ * @param path the AtoZ path provided by the PCE.
+ * @param allPceNode The map of chosen/relevant PceNodes build from topology pruning.
+ * @param allPceLinks The map of PceLinks build corresponding to the whole topology.
+ * @param serviceType The service Type used to extrapolate Operational mode when it is not provided.
+ * @param direction The direction used to scan provided path in a direct or reverse way.
+ * @param cu CatalogUtils instance.
+ * @return the calculated margin according to the Transponder performances and path impairments.
+ */
+ @SuppressWarnings("deprecation")
+ @edu.umd.cs.findbugs.annotations.SuppressWarnings("DLS_DEAD_LOCAL_STORE")
+ private double checkOSNR(GraphPath<String, PceGraphEdge> path, Map<NodeId, PceNode> allPceNodes,
+ Map<LinkId, PceLink> allPceLinks, String serviceType, String direction, CatalogUtils cu) {
+ double spacing = 50.0;
+ double calcPdl2 = 0;
+ double calcOsnrdB = 0;
+ double calcCd = 0;
+ double calcPmd2 = 0;
+ double calcOnsrLin = 0.0001;
+ double margin = 0;
+ double pwrIn = -60.0;
+ double pwrOut = -60.0;
+ int pathElement = 0;
+ int increment = 1;
+ int offsetLink = 0;
+ boolean transponderPresent = false;
+ if ((StringConstants.SERVICE_DIRECTION_ZA).equals(direction)) {
+ increment = - 1;
+ offsetLink = -1;
+ }
+ CatalogNodeType cnt;
+ List<String> vertices = path.getVertexList();
+ List<PceGraphEdge> edges = path.getEdgeList();
+ String opMode = "";
+ // LOOP that scans the different Nodes/Links of the path and calculates
+ // associated degradations
+ // using CatalogUtils primitives to retrieve physical parameters and make a
+ // first level calculation
+ Map<String, Double> impairments = new HashMap<>();
+ for (int n = 0; n < vertices.size(); n++) {
+ InstanceIdentifier<TerminationPoint1> nwTpIid;
+ PceNode nextNode = null;
+ if ((StringConstants.SERVICE_DIRECTION_AZ).equals(direction)) {
+ pathElement = n ;
+ } else {
+ pathElement = vertices.size() - n - 1;
+ }
+ PceNode currentNode = allPceNodes.get(new NodeId(vertices.get(pathElement)));
+ if (((pathElement != vertices.size() - 1) && (StringConstants.SERVICE_DIRECTION_AZ).equals(direction))
+ || ((pathElement != 0) && (StringConstants.SERVICE_DIRECTION_ZA).equals(direction))) {
+ nextNode = allPceNodes.get(new NodeId(vertices.get(pathElement + increment)));
+ }
+ LOG.debug("loop of check OSNR, n = {} Path Element = {}", n, pathElement);
+ switch (currentNode.getORNodeType()) {
+ case XPONDER:
+ transponderPresent = true;
+ String nwTpId = "";
+ if (((pathElement == 0) && (StringConstants.SERVICE_DIRECTION_AZ).equals(direction))
+ || ((pathElement == (vertices.size() - 1)) && (StringConstants.SERVICE_DIRECTION_ZA)
+ .equals(direction))) {
+ //First Xponder of the path TX side
+ nwTpId = getAppropriatePceLink((pathElement + offsetLink), edges, allPceLinks, direction)
+ .getSourceTP().getValue();
+ } else {
+ // last Xponder of the path (RX side)
+ nwTpId = getAppropriatePceLink((pathElement - offsetLink - 1), edges, allPceLinks, direction)
+ .getDestTP().getValue();
+ }
+ nwTpIid = InstanceIdentifiers.createNetworkTerminationPoint1IIDBuilder(
+ vertices.get(pathElement), nwTpId);
+ LOG.debug("loop of check OSNR : XPDR, n = {} Path Element = {}", n, pathElement);
+ try {
+ if (networkTransactionService.read(LogicalDatastoreType.CONFIGURATION, nwTpIid)
+ .get().isPresent()) {
+ XpdrNetworkAttributes xna = networkTransactionService
+ .read(LogicalDatastoreType.CONFIGURATION, nwTpIid)
+ .get().get().getXpdrNetworkAttributes();
+ // If the operational mode of the Xponder is not consistent or
+ // if the operational mode of the Xponder is not declared in the topology
+ // (Network TP)
+ if (currentNode.getXponderOperationalMode(xna).contentEquals(StringConstants.UNKNOWN_MODE)
+ || currentNode.getXponderOperationalMode(xna) == null
+ || currentNode.getXponderOperationalMode(xna).isEmpty()) {
+ // Operational mode is retrieved from the service Type assuming it is supported
+ // by the Xponder
+ opMode = cu.getPceOperationalModeFromServiceType(
+ CatalogConstant.CatalogNodeType.TSP, serviceType);
+ } else {
+ // Operational mode is found as an attribute of the network TP
+ opMode = currentNode.getXponderOperationalMode(xna);
+ }
+ LOG.debug("Transponder {} corresponding to path Element {} in the path has {} operational "
+ + "mode", currentNode.getNodeId().getValue(), pathElement, opMode);
+ } else {
+ LOG.error("Issue accessing the XponderNetworkAttributes of {} for Transponder {}"
+ + " corresponding to path Element {} in the path ",
+ nwTpId, currentNode.getNodeId().getValue(), pathElement);
+ opMode = cu.getPceOperationalModeFromServiceType(
+ CatalogConstant.CatalogNodeType.TSP, serviceType);
+ LOG.info("Did not succeed finding network TP {} in Configuration Datastore. Retrieve"
+ + " default Operational Mode {} from serviceType {}", nwTpId, opMode, serviceType);
+ }
+ } catch (InterruptedException | ExecutionException e1) {
+ opMode = cu.getPceOperationalModeFromServiceType(CatalogConstant.CatalogNodeType.TSP,
+ serviceType);
+ LOG.info("Did not succeed finding network TP {} in Configuration Datastore. Retrieve"
+ + " default Operational Mode {} from serviceType {}", nwTpId, opMode, serviceType);
+ }
+ // If TSP is the last of the path
+ if (((pathElement == (vertices.size() - 1))
+ && (StringConstants.SERVICE_DIRECTION_AZ).equals(direction))
+ || ((pathElement == 0) && (StringConstants.SERVICE_DIRECTION_ZA).equals(direction))) {
+ LOG.debug("Loop n = {}, Step5.1, XPDR, tries calculating Margin, just before call", n);
+ // Check that accumulated degradations are compatible with TSP performances
+ // According to OpenROADM spec :
+ // margin = cu.getPceRxTspParameters(opMode, calcCd, Math.sqrt(calcPmd2), Math.sqrt(calcPdl2),
+ // getOsnrDbfromOnsrLin(calcOnsrLin));
+ // Calculation modified for pdl according to calculation in Julia's Tool
+ margin = cu.getPceRxTspParameters(opMode, calcCd, Math.sqrt(calcPmd2),
+ (Math.sqrt(calcPdl2)), getOsnrDbfromOnsrLin(calcOnsrLin));
+ LOG.info("Loop n = {}, XPDR, calcosnrdB= {}", n, getOsnrDbfromOnsrLin(calcOnsrLin));
+ } else {
+ // TSP is first element of the path . To correctly evaluate the TX OOB OSNR from
+ // its operational mode, we need to know the type of ADD/DROP Mux it is
+ // connected to
+ String adnMode = "";
+ // If the operational mode of the ADD/DROP MUX is not consistent or
+ // if the operational mode of the ADD/DROP MUX is not declared in the topology
+ // (Network TP)
+ if (StringConstants.UNKNOWN_MODE.equals(nextNode.getOperationalMode())
+ || nextNode.getOperationalMode() == null
+ || nextNode.getOperationalMode().isEmpty()) {
+ // Operational mode is set by default to standard opMode for ADD SRGs
+ adnMode = CatalogConstant.MWWRCORE;
+ } else {
+ // Operational mode is found in SRG attributes of the Node
+ adnMode = nextNode.getOperationalMode();
+ }
+ LOG.debug("Transponder {} corresponding to path Element {} in the path is connected to SRG "
+ + "which has {} operational mode", currentNode.getNodeId().getValue(), pathElement,
+ adnMode);
+ // Retrieve the Tx ONSR of the Xponder which results from IB and OOB OSNR
+ // contributions
+ calcOnsrLin = cu.getPceTxTspParameters(opMode, adnMode);
+ // Retrieve the spacing associated with Xponder operational mode that is needed
+ // to calculate OSNR
+ spacing = cu.getPceTxTspChannelSpacing(opMode);
+ LOG.info("Transponder {} corresponding to path Element {} in the path has a TX OSNR of {} dB",
+ currentNode.getNodeId().getValue(), pathElement, getOsnrDbfromOnsrLin(calcOnsrLin));
+ }
+ break;
+ case SRG:
+ String srgMode = "";
+ // If the operational mode of the ADD/DROP MUX is not consistent or
+ // if the operational mode of the ADD/DROP MUX is not declared in the topology
+ // (Network TP)
+ if (StringConstants.UNKNOWN_MODE.equals(currentNode.getOperationalMode())
+ || currentNode.getOperationalMode() == null
+ || currentNode.getOperationalMode().isEmpty()) {
+ // Operational mode is set by default to standard opMode for ADD/DROP SRGs
+ srgMode = CatalogConstant.MWWRCORE;
+ } else {
+ // Operational mode is found in SRG attributes of the Node
+ srgMode = currentNode.getOperationalMode();
+ }
+ cnt = CatalogConstant.CatalogNodeType.DROP;
+ LOG.debug("loop of check OSNR : SRG, n = {} Path Element = {}", n, pathElement);
+ if ((pathElement <= 1) && (StringConstants.SERVICE_DIRECTION_AZ).equals(direction)
+ || (pathElement >= vertices.size() - 2)
+ && (StringConstants.SERVICE_DIRECTION_ZA).equals(direction)) {
+ // This is ADD case : First (optical-tunnel) or 2nd (Regular E2E service from
+ // Xponder to Xponder) node element of the path is the ADD SRG.
+ if (!(getAppropriatePceLink((pathElement + offsetLink), edges, allPceLinks, direction)
+ .getlinkType() == OpenroadmLinkType.ADDLINK)) {
+ LOG.error("Error processing Node {} for which output link {} is not an ADDLINK Type",
+ currentNode.getNodeId().toString(), pathElement + offsetLink);
+ }
+ cnt = CatalogConstant.CatalogNodeType.ADD;
+ pwrIn = 0.0;
+ pwrOut = cu.getPceRoadmAmpOutputPower(cnt, srgMode,
+ getAppropriatePceLink((pathElement + 1 + offsetLink * 3), edges, allPceLinks, direction)
+ .getspanLoss(), spacing,
+ getAppropriatePceLink((pathElement + 1 + offsetLink * 3), edges, allPceLinks, direction)
+ .getpowerCorrection());
+ LOG.debug("loop of check OSNR : SRG, n = {} link {} Pout = {}",
+ pathElement, pathElement + 1 + offsetLink * 3, pwrOut);
+ } else {
+ // Other case is DROP, for which cnt is unchanged (.DROP)
+ if (!(getAppropriatePceLink((pathElement - 1 - offsetLink), edges, allPceLinks, direction)
+ .getlinkType() == OpenroadmLinkType.DROPLINK)) {
+ LOG.error("Error processing Node {} for which input link {} is not a DROPLINK Type",
+ currentNode.getNodeId().toString(), pathElement - 1 - offsetLink);
+ }
+ pwrIn = pwrOut - getAppropriatePceLink((pathElement - offsetLink * 3 - 2), edges, allPceLinks,
+ direction).getspanLoss();
+ // Calculate degradation accumulated across incoming Link and add them to
+ // accumulated impairments
+ calcCd += getAppropriatePceLink((pathElement - offsetLink * 3 - 2), edges, allPceLinks,
+ direction).getcd();
+ LOG.info("loop of check OSNR : SRG, n = {} CD on preceeding link {} = {} ps", pathElement,
+ pathElement - offsetLink * 3 - 2, getAppropriatePceLink((pathElement - offsetLink * 3 - 2),
+ edges, allPceLinks, direction).getcd());
+ calcPmd2 += getAppropriatePceLink((pathElement - offsetLink * 3 - 2), edges, allPceLinks,
+ direction).getpmd2();
+ // This also includes Non Linear Contribution from the path
+ calcOnsrLin += cu.calculateNLonsrContribution(pwrOut, getAppropriatePceLink((pathElement
+ - offsetLink * 3 - 2), edges, allPceLinks, direction).getLength(), spacing);
+ }
+ //calculation of the SRG contribution either for Add and Drop
+ impairments = cu.getPceRoadmAmpParameters(cnt, srgMode,
+ pwrIn, calcCd, calcPmd2, calcPdl2, calcOnsrLin, spacing);
+ calcCd = impairments.get("CD").doubleValue();
+ calcPmd2 = impairments.get("DGD2").doubleValue();
+ calcPdl2 = impairments.get("PDL2").doubleValue();
+ calcOnsrLin = impairments.get("ONSRLIN").doubleValue();
+ if (calcOnsrLin == Double.NEGATIVE_INFINITY || calcOnsrLin == Double.POSITIVE_INFINITY) {
+ return -1.0;
+ }
+ if (pathElement > 1) {
+ // If SRG is not the first or the second element of the Path, it is the DROP
+ // side.
+ // After accumulated degradations are calculated, we also need to calculate
+ // resulting OSNR in dB to pass it to the method that verifies end Xponder
+ // performances are compatible with degradations experienced on the path
+ try {
+ calcOsnrdB = getOsnrDbfromOnsrLin(calcOnsrLin);
+ LOG.info("checkOSNR loop, last SRG osnr is {} dB", calcOsnrdB);
+ LOG.info("Loop n = {}, DROP, calcOsnrdB= {}", n, calcOsnrdB);
+ } catch (ArithmeticException e) {
+ LOG.debug("In checkOSNR: OSNR is equal to 0 and the number of links is: {}",
+ path.getEdgeList().size());
+ return -1.0;
+ }
+ }
+ if (CatalogConstant.CatalogNodeType.ADD.equals(cnt)) {
+ // For the ADD, degradation brought by the node are calculated from the MW-WR spec.
+ // The Degree is not considered. This means we must bypass the add-link (ADD)
+ // and the next node (Degree) which are not considered in the impairments.
+ n++;
+ }
+ impairments.clear();
+ break;
+ case DEGREE:
+ if (nextNode.getORNodeType() != OpenroadmNodeType.DEGREE) {
+ //This is the case of DROP, ROADM degree is not considered
+ break;
+ }
+ LOG.info("loop of check OSNR : DEGREE, n = {} Path Element = {}", n, pathElement);
+ cnt = CatalogConstant.CatalogNodeType.EXPRESS;
+ String degree1Mode = "";
+ String degree2Mode = "";
+ // If the operational mode of the Degree is not consistent or if the operational
+ // mode is not declared in the topology
+ if (StringConstants.UNKNOWN_MODE.equals(currentNode.getOperationalMode())
+ || currentNode.getOperationalMode() == null
+ || currentNode.getOperationalMode().isEmpty()) {
+ // Operational mode is set by default to standard opMode for Degree
+ degree1Mode = CatalogConstant.MWMWCORE;
+ } else {
+ // Operational mode is found in degree-attributes of the Node
+ degree1Mode = currentNode.getOperationalMode();
+ }
+ // Same for next node which is the second degree of a ROADM node
+ if (StringConstants.UNKNOWN_MODE.equals(nextNode.getOperationalMode())
+ || nextNode.getOperationalMode() == null
+ || nextNode.getOperationalMode().isEmpty()) {
+ degree2Mode = CatalogConstant.MWMWCORE;
+ } else {
+ degree2Mode = currentNode.getOperationalMode();
+ }
+ // At that time OpenROADM provides only one spec for the ROADM nodes
+ if (!degree1Mode.equals(degree2Mode)) {
+ LOG.info("Unsupported Hybrid ROADM configuration with Degree1 {} of {} operational mode"
+ + "and Degree2 {} of {} operational mode. Will by default use operational mode"
+ + "of Degree2", currentNode.getNodeId().toString(),
+ degree1Mode, nextNode.getNodeId().toString(), degree2Mode);
+ }
+ pwrIn = pwrOut - getAppropriatePceLink((pathElement - offsetLink - 1), edges, allPceLinks,
+ direction).getspanLoss();
+ // Calculate degradation accumulated across incoming Link and add them to
+ // accumulated impairments
+ calcCd += getAppropriatePceLink((pathElement - offsetLink - 1), edges, allPceLinks, direction)
+ .getcd();
+ calcPmd2 += getAppropriatePceLink((pathElement - offsetLink - 1), edges, allPceLinks, direction)
+ .getpmd2();
+ // This also includes Non Linear Contribution from the path
+ calcOnsrLin += cu.calculateNLonsrContribution(pwrOut, getAppropriatePceLink((pathElement
+ - offsetLink - 1), edges, allPceLinks, direction).getLength(), spacing);
+ // Calculate output power for next span (Output of degree 2)
+ pwrOut = cu.getPceRoadmAmpOutputPower(cnt, degree2Mode, getAppropriatePceLink((pathElement
+ + 3 * offsetLink + 1), edges, allPceLinks, direction).getspanLoss(), spacing,
+ getAppropriatePceLink((pathElement + 3 * offsetLink + 1), edges, allPceLinks, direction)
+ .getpowerCorrection());
+ // Adds to accumulated impairments the degradation associated with the Express
+ // path of ROADM : Degree1, express link, Degree2
+ impairments = cu.getPceRoadmAmpParameters(cnt, degree2Mode,
+ pwrIn, calcCd, calcPmd2, calcPdl2, calcOnsrLin, spacing);
+ calcCd = impairments.get("CD").doubleValue();
+ calcPmd2 = impairments.get("DGD2").doubleValue();
+ calcPdl2 = impairments.get("PDL2").doubleValue();
+ calcOnsrLin = impairments.get("ONSRLIN").doubleValue();
+ LOG.debug("Loop n = {}, DEGREE, calcOsnrdB= {}", n, getOsnrDbfromOnsrLin(calcOnsrLin));
+ if (calcOnsrLin == Double.NEGATIVE_INFINITY || calcOnsrLin == Double.POSITIVE_INFINITY) {
+ return -1.0;
+ }
+ // increment pathElement so that in next step we will not point to Degree2 but
+ // next node
+ n++;
+ LOG.info("Accumulated degradations in the path including ROADM {} + {} are CD: {}; PMD2: "
+ + "{}; Pdl2 : {}; ONSRdB : {}", currentNode.getNodeId().toString(),
+ nextNode.getNodeId().toString(), calcCd, calcPmd2, calcPdl2, getOsnrDbfromOnsrLin(calcOnsrLin));
+ break;
+ default:
+ LOG.error("PostAlgoPathValidator.CheckOSNR : unsupported resource type in the path chain");
}
}
- try {
- osnrDb = getOsnrDb(1 / inverseLocalOsnr);
- } catch (ArithmeticException e) {
- LOG.debug("In checkOSNR: OSNR is equal to 0 and the number of links is: {}", path.getEdgeList().size());
- return false;
+ LOG.info("- In checkOSNR: accumulated CD = {} ps, PMD = {} ps, PDL = {} dB, and resulting OSNR calcOsnrdB = {} "
+ + "dB and ONSR dB exterapolated from calcosnrlin = {}"
+ + " including non linear contributions",
+ calcCd, Math.sqrt(calcPmd2), Math.sqrt(calcPdl2), calcOsnrdB, getOsnrDbfromOnsrLin(calcOnsrLin));
+ if (!transponderPresent) {
+ LOG.info("No transponder in the path, User shall check from CD, PMD, and OSNR values provided "
+ + "that optical tunnel degradations are compatible with external transponder performances");
+ return 0.0;
}
- LOG.info("In checkOSNR: OSNR of the path is {} dB", osnrDb);
- return ((osnrDb + SYS_MARGIN) > MIN_OSNR_W100G);
+ LOG.info("In checkOSNR: Transponder Operational mode {} results in a residual margin of {} dB, according "
+ + "to CD, PMD and DGD induced penalties and set System Margin of {} dB.",
+ opMode, margin - SYS_MARGIN, SYS_MARGIN);
+ String validationMessage = "INVALIDATED";
+ if ((margin - SYS_MARGIN) >= 0) {
+ validationMessage = "VALIDATED";
+ }
+ if ((StringConstants.SERVICE_DIRECTION_AZ).equals(direction)) {
+ LOG.info("- In checkOSNR: A to Z Path from {} to {} {}", vertices.get(0),
+ vertices.get(vertices.size() - 1), validationMessage);
+ } else {
+ LOG.info("- In checkOSNR: Z to A Path from {} to {} {}", vertices.get(vertices.size() - 1),
+ vertices.get(0), validationMessage);
+ }
+ return (margin - SYS_MARGIN);
}
- private double getOsnrDb(double osnrLu) {
- return (10 * Math.log10(osnrLu));
+ // Method to provide either regular link (AtoZ) or Opposite link (ZtoA) in the list of PceGraphEdges
+ private PceLink getAppropriatePceLink(Integer pathEltNber, List<PceGraphEdge> edges,
+ Map<LinkId, PceLink> allPceLinks, String direction) {
+ if ((StringConstants.SERVICE_DIRECTION_AZ).equals(direction)) {
+ // Returns regular link.
+ return edges.get(pathEltNber).link();
+ }
+ //For Z to A direction, must return the opposite link
+ return allPceLinks.get(new LinkId(edges.get(pathEltNber).link()
+ .getOppositeLink()));
}
- private double getInverseOsnrLinkLu(double linkOsnrDb) {
- // 1 over the link OSNR, in linear units
- double linkOsnrLu = Math.pow(10, (linkOsnrDb / 10.0));
- LOG.debug("In retrieveosnr: the inverse of link osnr is {} (Linear Unit)", linkOsnrLu);
- return (CONST_OSNR / linkOsnrLu);
+ private double getOsnrDbfromOnsrLin(double onsrLu) {
+ return (10 * Math.log10(1 / onsrLu));
}
/**
}
return spectrumAssignmentBldr.build();
}
+
+ public Double getTpceCalculatedMargin() {
+ return tpceCalculatedMargin;
+ }
}
Code Review / transportpce.git / blobdiff