2 * Copyright © 2017 AT&T and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.transportpce.common.mapping;
10 import java.util.ArrayList;
11 import java.util.List;
12 import java.util.Optional;
13 import java.util.concurrent.ExecutionException;
14 import org.opendaylight.mdsal.binding.api.DataBroker;
15 import org.opendaylight.mdsal.binding.api.ReadTransaction;
16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
17 import org.opendaylight.transportpce.common.StringConstants;
18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210310.Network;
19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210310.network.Nodes;
20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210310.network.NodesKey;
21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210310.network.nodes.McCapabilities;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210310.network.nodes.NodeInfo;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 public class MappingUtilsImpl implements MappingUtils {
29 private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
31 private final DataBroker dataBroker;
33 public MappingUtilsImpl(DataBroker dataBroker) {
35 this.dataBroker = dataBroker;
39 public String getOpenRoadmVersion(String nodeId) {
41 * Getting physical mapping corresponding to logical connection point
43 InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
44 new NodesKey(nodeId)).child(NodeInfo.class).build();
45 try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
46 Optional<NodeInfo> nodeInfoObj =
47 readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
48 if (nodeInfoObj.isPresent()) {
49 NodeInfo nodInfo = nodeInfoObj.get();
50 switch (nodInfo.getOpenroadmVersion()) {
52 return StringConstants.OPENROADM_DEVICE_VERSION_7_1_0;
54 return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
56 return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
58 LOG.warn("unknown openROADM device version");
61 LOG.warn("Could not find mapping for nodeId {}", nodeId);
63 } catch (InterruptedException | ExecutionException ex) {
64 LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
72 * @see org.opendaylight.transportpce.common.mapping.MappingUtils#getMcCapabilitiesForNode(java.lang.String)
75 public List<McCapabilities> getMcCapabilitiesForNode(String nodeId) {
76 List<McCapabilities> mcCapabilities = new ArrayList<>();
77 InstanceIdentifier<Nodes> nodePortMappingIID = InstanceIdentifier.builder(Network.class)
78 .child(Nodes.class, new NodesKey(nodeId)).build();
79 try (ReadTransaction readTx = this.dataBroker.newReadOnlyTransaction()) {
80 Optional<Nodes> nodePortMapObject = readTx.read(LogicalDatastoreType.CONFIGURATION, nodePortMappingIID)
82 if (nodePortMapObject.isPresent()) {
83 LOG.info("Found node {}", nodeId);
84 Nodes node = nodePortMapObject.get();
85 mcCapabilities.addAll(node.nonnullMcCapabilities().values());
87 } catch (ExecutionException e) {
88 LOG.error("Something went wrong while getting node {}", nodeId, e);
89 } catch (InterruptedException e) {
90 LOG.error("Request interrupted for node {} interrupted", nodeId, e);
91 Thread.currentThread().interrupt();
93 LOG.info("Capabilitities for node {}: {}", nodeId, mcCapabilities);
94 return mcCapabilities;