import java.util.stream.Stream;
import org.eclipse.jdt.annotation.Nullable;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.transportpce.common.Timeouts;
import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev181019.current.pm.list.CurrentPmEntryKey;
import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev181019.current.pm.val.group.Measurement;
import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.Direction;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.Location;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.PmNamesEnum;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.get.pm.input.ResourceIdentifier;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev200128.Direction;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev200128.Location;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev200128.PmNamesEnum;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev200128.olm.get.pm.input.ResourceIdentifier;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
*
* @return Result of the request list of PM readings
*/
+ //LOG.info message length is >120 char and can be difficultly shortened
+ @SuppressWarnings("checkstyle:linelength")
public static GetPmOutputBuilder pmFetch(GetPmInput input, DeviceTransactionManager deviceTransactionManager) {
LOG.info("Getting PM Data for 2.2.1 NodeId: {} ResourceType: {} ResourceName: {}", input.getNodeId(),
input.getResourceType(), input.getResourceIdentifier());
List<CurrentPm> filteredPMs = currentPMStream.collect(Collectors.toList());
List<Measurements> measurements = extractWantedMeasurements(filteredPMs,input.getGranularity());
if (measurements.isEmpty()) {
- LOG.error("No Matching PM data found for node: {}, " + "resource type: {},"
- + " resource name: {}, pm type: {}, extention: {}"
- + ", location: {} and direction: {}",
+ LOG.error(
+ "No Matching PM data found for node: {}, resource type: {}, resource name: {}, pm type: {}, extention: {}, location: {} and direction: {}",
input.getNodeId(), input.getResourceType(),
getResourceIdentifierAsString(input.getResourceIdentifier()),
input.getPmNameType(),input.getPmExtension(),input.getLocation(),
pmOutputBuilder.setNodeId(input.getNodeId()).setResourceType(input.getResourceType())
.setResourceIdentifier(input.getResourceIdentifier()).setGranularity(input.getGranularity())
.setMeasurements(measurements);
- LOG.info("PM data found successfully for node: {}, " + "resource type: {},"
- + " resource name: {}, pm type: {}, extention: {}"
- + ", location: {} and direction: {}",
+ LOG.info(
+ "PM data found successfully for node: {}, resource type: {}, resource name: {}, pm type: {}, extention: {}, location: {} and direction: {}",
input.getNodeId(), input.getResourceType(),
getResourceIdentifierAsString(input.getResourceIdentifier()),
input.getPmNameType(),input.getPmExtension(),input.getLocation(),