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.rev220114.Network;
21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.mc.capabilities.McCapabilities;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.Nodes;
23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.NodesKey;
24 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220114.network.nodes.NodeInfo;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If100GE;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If100GEODU4;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GE;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GEODU2;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GEODU2e;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If1GE;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If1GEODU0;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If400GE;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCH;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCHOTU4ODU4;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOTUCnODUCn;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
37 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
38 import org.slf4j.Logger;
39 import org.slf4j.LoggerFactory;
41 public class MappingUtilsImpl implements MappingUtils {
43 private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
45 private final DataBroker dataBroker;
47 private static Map<String, Class<? extends SupportedIfCapability>> capTypeClassMap = new HashMap<>() {
49 put("IfOTUCnODUCn", IfOTUCnODUCn.class);
50 put("IfOCHOTU4ODU4", IfOCHOTU4ODU4.class);
51 put("IfOCH", IfOCH.class);
52 put("If100GEODU4", If100GEODU4.class);
53 put("If10GEODU2e", If10GEODU2e.class);
54 put("If10GEODU2", If10GEODU2.class);
55 put("If1GEODU0", If1GEODU0.class);
56 put("If400GE", If400GE.class);
57 put("If100GE", If100GE.class);
58 put("If10GE", If10GE.class);
59 put("If1GE", If1GE.class);
63 public MappingUtilsImpl(DataBroker dataBroker) {
65 this.dataBroker = dataBroker;
69 public String getOpenRoadmVersion(String nodeId) {
71 * Getting physical mapping corresponding to logical connection point
73 InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
74 new NodesKey(nodeId)).child(NodeInfo.class).build();
75 try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
76 Optional<NodeInfo> nodeInfoObj =
77 readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
78 if (nodeInfoObj.isPresent()) {
79 NodeInfo nodInfo = nodeInfoObj.get();
80 switch (nodInfo.getOpenroadmVersion()) {
82 return StringConstants.OPENROADM_DEVICE_VERSION_7_1;
84 return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
86 return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
88 LOG.warn("unknown openROADM device version");
91 LOG.warn("Could not find mapping for nodeId {}", nodeId);
93 } catch (InterruptedException | ExecutionException ex) {
94 LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
102 * @see org.opendaylight.transportpce.common.mapping.MappingUtils#getMcCapabilitiesForNode(java.lang.String)
105 public List<McCapabilities> getMcCapabilitiesForNode(String nodeId) {
106 List<McCapabilities> mcCapabilities = new ArrayList<>();
107 InstanceIdentifier<Nodes> nodePortMappingIID = InstanceIdentifier.builder(Network.class)
108 .child(Nodes.class, new NodesKey(nodeId)).build();
109 try (ReadTransaction readTx = this.dataBroker.newReadOnlyTransaction()) {
110 Optional<Nodes> nodePortMapObject = readTx.read(LogicalDatastoreType.CONFIGURATION, nodePortMappingIID)
112 if (nodePortMapObject.isPresent()) {
113 LOG.info("Found node {}", nodeId);
114 Nodes node = nodePortMapObject.get();
115 mcCapabilities.addAll(node.nonnullMcCapabilities().values());
117 } catch (ExecutionException e) {
118 LOG.error("Something went wrong while getting node {}", nodeId, e);
119 } catch (InterruptedException e) {
120 LOG.error("Request interrupted for node {} interrupted", nodeId, e);
121 Thread.currentThread().interrupt();
123 LOG.info("Capabilitities for node {}: {}", nodeId, mcCapabilities);
124 return mcCapabilities;
127 public static Class<? extends SupportedIfCapability> convertSupIfCapa(String ifCapType) {
128 if (!capTypeClassMap.containsKey(ifCapType)) {
131 return capTypeClassMap.get(ifCapType);