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.HashMap;
12 import java.util.List;
14 import java.util.Optional;
15 import java.util.concurrent.ExecutionException;
16 import org.opendaylight.mdsal.binding.api.DataBroker;
17 import org.opendaylight.mdsal.binding.api.ReadTransaction;
18 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
19 import org.opendaylight.transportpce.common.StringConstants;
20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.Network;
21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.mc.capabilities.McCapabilities;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.Nodes;
23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.NodesKey;
24 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.nodes.NodeInfo;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If100GE;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If100GEODU4;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If10GE;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If10GEODU2;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If10GEODU2e;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If1GE;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If1GEODU0;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If400GE;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCH;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCHOTU2EODU2E;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCHOTU2ODU2;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCHOTU4ODU4;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOTU4ODU4;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOTUCnODUCn;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOtsiOtsigroup;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.SupportedIfCapability;
41 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
42 import org.slf4j.Logger;
43 import org.slf4j.LoggerFactory;
45 public class MappingUtilsImpl implements MappingUtils {
47 private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
49 private final DataBroker dataBroker;
51 private static Map<String, Class<? extends SupportedIfCapability>> capTypeClassMap = new HashMap<>() {
53 put("IfOtsiOtsigroup", IfOtsiOtsigroup.class);
54 put("IfOTUCnODUCn", IfOTUCnODUCn.class);
55 put("IfOCHOTU4ODU4", IfOCHOTU4ODU4.class);
56 put("IfOTU4ODU4", IfOTU4ODU4.class);
57 put("IfOCH", IfOCH.class);
58 put("If100GEODU4", If100GEODU4.class);
59 put("If10GEODU2e", If10GEODU2e.class);
60 put("If10GEODU2", If10GEODU2.class);
61 put("If1GEODU0", If1GEODU0.class);
62 put("If400GE", If400GE.class);
63 put("If100GE", If100GE.class);
64 put("If10GE", If10GE.class);
65 put("If1GE", If1GE.class);
66 put("IfOCHOTU2EODU2E", IfOCHOTU2EODU2E.class);
67 put("IfOCHOTU2ODU2", IfOCHOTU2ODU2.class);
71 public MappingUtilsImpl(DataBroker dataBroker) {
73 this.dataBroker = dataBroker;
77 public String getOpenRoadmVersion(String nodeId) {
79 * Getting physical mapping corresponding to logical connection point
81 InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
82 new NodesKey(nodeId)).child(NodeInfo.class).build();
83 try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
84 Optional<NodeInfo> nodeInfoObj =
85 readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
86 if (nodeInfoObj.isPresent()) {
87 NodeInfo nodInfo = nodeInfoObj.get();
88 switch (nodInfo.getOpenroadmVersion()) {
90 return StringConstants.OPENROADM_DEVICE_VERSION_7_1;
92 return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
94 return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
96 LOG.warn("unknown openROADM device version");
99 LOG.warn("Could not find mapping for nodeId {}", nodeId);
101 } catch (InterruptedException | ExecutionException ex) {
102 LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
110 * @see org.opendaylight.transportpce.common.mapping.MappingUtils#getMcCapabilitiesForNode(java.lang.String)
113 public List<McCapabilities> getMcCapabilitiesForNode(String nodeId) {
114 List<McCapabilities> mcCapabilities = new ArrayList<>();
115 InstanceIdentifier<Nodes> nodePortMappingIID = InstanceIdentifier.builder(Network.class)
116 .child(Nodes.class, new NodesKey(nodeId)).build();
117 try (ReadTransaction readTx = this.dataBroker.newReadOnlyTransaction()) {
118 Optional<Nodes> nodePortMapObject = readTx.read(LogicalDatastoreType.CONFIGURATION, nodePortMappingIID)
120 if (nodePortMapObject.isPresent()) {
121 LOG.info("Found node {}", nodeId);
122 Nodes node = nodePortMapObject.get();
123 mcCapabilities.addAll(node.nonnullMcCapabilities().values());
125 } catch (ExecutionException e) {
126 LOG.error("Something went wrong while getting node {}", nodeId, e);
127 } catch (InterruptedException e) {
128 LOG.error("Request interrupted for node {} interrupted", nodeId, e);
129 Thread.currentThread().interrupt();
131 LOG.info("Capabilitities for node {}: {}", nodeId, mcCapabilities);
132 return mcCapabilities;
135 public static Class<? extends SupportedIfCapability> convertSupIfCapa(String ifCapType) {
136 if (!capTypeClassMap.containsKey(ifCapType)) {
137 LOG.error("supported-if-capability {} not supported", ifCapType);
140 return capTypeClassMap.get(ifCapType);