--- /dev/null
+/*
+ * Copyright © 2017 AT&T 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.olm;
+
+import com.google.common.base.Optional;
+
+import java.lang.reflect.InvocationTargetException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.MountPointService;
+import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.transportpce.olm.spanloss.RoadmLinks;
+import org.opendaylight.transportpce.olm.spanloss.SpanLoss;
+import org.opendaylight.transportpce.renderer.mapping.PortMapping;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.CurrentPmlist;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.current.pm.Measurements;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.currentpmlist.CurrentPm;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmNamesEnum;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmOutputBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.OlmService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.ServicePowerSetupInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.ServicePowerSetupOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.ServicePowerSetupOutputBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.get.pm.output.MeasurementsBuilder;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.common.RpcResult;
+import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * The Class OlmPowerSetupImpl.
+ */
+public class OlmPowerSetupImpl implements OlmService {
+
+ /** The Constant LOG. */
+ private static final Logger LOG = LoggerFactory.getLogger(OlmPowerSetupImpl.class);
+
+ /** The db. */
+ private final DataBroker db;
+
+ /** The mps. */
+ private final MountPointService mps;
+
+ /**
+ * Instantiates a new olm power setup impl.
+ *
+ * @param db
+ * the db
+ * @param mps
+ * the mps
+ */
+ public OlmPowerSetupImpl(DataBroker db, MountPointService mps) {
+ this.db = db;
+ this.mps = mps;
+ }
+
+ /**
+ * This method is the implementation of the 'get-pm' RESTCONF service, which
+ * is one of the external APIs into the olm application.
+ *
+ * <p>
+ * 1. get-pm This operation traverse through current PM list and gets PM for
+ * given NodeId and Resource name
+ *
+ * <p>
+ * The signature for this method was generated by yang tools from the
+ * renderer API model.
+ *
+ * @param input
+ * Input parameter from the olm yang model
+ *
+ * @return Result of the request
+ */
+ @Override
+ public Future<RpcResult<GetPmOutput>> getPm(GetPmInput input) {
+ LOG.info("Getting PM Data for NodeId: {} ResouceType: {} ResourceName: {}",
+ input.getNodeId(),input.getResourceType(),input.getResourceName());
+ new PortMapping(db, mps, input.getNodeId());
+ DataBroker deviceDb = PortMapping.getDeviceDataBroker(input.getNodeId(), mps);
+ InstanceIdentifier<CurrentPmlist> currentPmsIID = InstanceIdentifier.create(CurrentPmlist.class);
+ ReadOnlyTransaction rtx = deviceDb.newReadOnlyTransaction();
+ Optional<CurrentPmlist> currentPmList;
+ String methodName = "";
+ List<CurrentPm> currentPms = new ArrayList<>();
+ GetPmOutputBuilder pmOutputBuilder = new GetPmOutputBuilder();
+ List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.get.pm.output.Measurements>
+ measrements = new ArrayList<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418
+ .get.pm.output.Measurements>();
+ try {
+ currentPmList = rtx.read(LogicalDatastoreType.OPERATIONAL, currentPmsIID).get();
+ if (currentPmList.isPresent()) {
+ currentPms.addAll(currentPmList.get().getCurrentPm());
+ for (CurrentPm pm : currentPms) {
+ MeasurementsBuilder measurement = new MeasurementsBuilder();
+ if (pm.getResource().getResourceType().getType().toString().equals(input.getResourceType())) {
+
+ switch (pm.getResource().getResourceType().getType()) {
+ case CircuitPack:
+ methodName = "getCircuitPackName";
+ break;
+ case Connection:
+ methodName = "getConnectionNumber";
+ break;
+ case Degree:
+ methodName = "getDegreeNumber";
+ break;
+ case Interface:
+ methodName = "getInterfaceName";
+ break;
+ case InternalLink:
+ methodName = "getInternalLinkName";
+ break;
+ case PhysicalLink:
+ methodName = "getPhysicalLinkName";
+ break;
+ case Service:
+ methodName = "getServiceName";
+ break;
+ case Shelf:
+ methodName = "getShelfName";
+ break;
+ case SharedRiskGroup:
+ methodName = "getSrgNumber";
+ break;
+ default:
+ methodName = "getPort";
+ break;
+ }
+ try {
+
+ String pmResourceId = pm.getResource().getResource().getResource().getImplementedInterface()
+ .getMethod(methodName).invoke(pm.getResource().getResource().getResource()).toString();
+ if (pmResourceId.equals(input.getResourceName()) && pm.getGranularity() != null) {
+ if (pm.getGranularity().getName().equals(input.getGranularity())) {
+ for (Measurements measure : pm.getMeasurements()) {
+ if (!measure.getMeasurement().getPmParameterName().getType().equals(
+ PmNamesEnum.VendorExtension)) {
+ measurement.setPmparameterName(measure.getMeasurement().getPmParameterName()
+ .getType().toString());
+ measurement.setPmparameterValue(measure.getMeasurement()
+ .getPmParameterValue().getDecimal64().toString());
+ measrements.add(measurement.build());
+ }
+ }
+ }
+ }
+
+ } catch (IllegalAccessException | IllegalArgumentException | InvocationTargetException
+ | NoSuchMethodException | SecurityException ex) {
+ LOG.warn("Unable to find PM for NodeID: {} ResourceName: {} ",input.getNodeId(),
+ input.getResourceName(),ex);
+ }
+ }
+ }
+ if (measrements.size() > 0) {
+ pmOutputBuilder.setNodeId(input.getNodeId()).setResourceType(input.getResourceType()).setResourceId(
+ input.getResourceName()).setGranularity(input.getGranularity()).setMeasurements(measrements);
+ }
+
+ } else {
+ LOG.info("Device PM Data is not available");
+ }
+
+ } catch (InterruptedException | ExecutionException ex) {
+ LOG.warn("Unable to get currentPmList for NodeID: {}",input.getNodeId(),ex);
+ }
+ LOG.info("PM Data found successfully for {}-{}",pmOutputBuilder.getNodeId(),pmOutputBuilder.getResourceId());
+ return RpcResultBuilder.success(pmOutputBuilder).buildFuture();
+ }
+
+
+ /**
+ * This method is the implementation of the 'service-power-setup' RESTCONF service, which
+ * is one of the external APIs into the olm application.
+ *
+ * <p>
+ * 1. service-power-setup: This operation performs following steps:
+ * Step1: Calculate Spanloss on all links which are part of service.
+ * TODO Step2: Calculate power levels for each Tp-Id
+ * TODO Step3: Post power values on roadm connections
+ *
+ * <p>
+ * The signature for this method was generated by yang tools from the
+ * renderer API model.
+ *
+ * @param input
+ * Input parameter from the olm yang model
+ * Input will contain nodeId and termination point
+ *
+ * @return Result of the request
+ */
+ @Override
+ public Future<org.opendaylight.yangtools.yang.common.RpcResult<ServicePowerSetupOutput>> servicePowerSetup(
+ ServicePowerSetupInput input) {
+ List<RoadmLinks> roadmLinks = new ArrayList<RoadmLinks>();
+ ServicePowerSetupOutputBuilder output = new ServicePowerSetupOutputBuilder();
+ //Finds degree TpID from node and generates a list of links
+ for (int i = 0; i < input.getNodes().size(); i++) {
+ if (input.getNodes().get(i).getDestTp().toLowerCase().contains("deg")) {
+ RoadmLinks rdmLink = new RoadmLinks();
+ rdmLink.setSrcNodeId(input.getNodes().get(i).getNodeId());
+ rdmLink.setSrcTpId(input.getNodes().get(i).getDestTp());
+ rdmLink.setDestNodeId(input.getNodes().get(i + 1).getNodeId());
+ rdmLink.setDestTpid(input.getNodes().get(i + 1).getSrcTp());
+ roadmLinks.add(rdmLink);
+ }
+ }
+ boolean successVal = new SpanLoss(db, mps).getLinkSpanloss(roadmLinks);
+
+ if (successVal) {
+ output.setResult("Success");
+ } else {
+ output.setResult("Failed");
+ }
+
+ return RpcResultBuilder.success(output).buildFuture();
+
+ }
+
+}
\ No newline at end of file
Code Review / transportpce.git / blobdiff