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.IfOCHOTU2EODU2E;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCHOTU2ODU2;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCHOTU4ODU4;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOTUCnODUCn;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
39 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
40 import org.slf4j.Logger;
41 import org.slf4j.LoggerFactory;
43 public class MappingUtilsImpl implements MappingUtils {
45 private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
47 private final DataBroker dataBroker;
49 private static Map<String, Class<? extends SupportedIfCapability>> capTypeClassMap = new HashMap<>() {
51 put("IfOTUCnODUCn", IfOTUCnODUCn.class);
52 put("IfOCHOTU4ODU4", IfOCHOTU4ODU4.class);
53 put("IfOCH", IfOCH.class);
54 put("If100GEODU4", If100GEODU4.class);
55 put("If10GEODU2e", If10GEODU2e.class);
56 put("If10GEODU2", If10GEODU2.class);
57 put("If1GEODU0", If1GEODU0.class);
58 put("If400GE", If400GE.class);
59 put("If100GE", If100GE.class);
60 put("If10GE", If10GE.class);
61 put("If1GE", If1GE.class);
62 put("IfOCHOTU2EODU2E", IfOCHOTU2EODU2E.class);
63 put("IfOCHOTU2ODU2", IfOCHOTU2ODU2.class);
67 public MappingUtilsImpl(DataBroker dataBroker) {
69 this.dataBroker = dataBroker;
73 public String getOpenRoadmVersion(String nodeId) {
75 * Getting physical mapping corresponding to logical connection point
77 InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
78 new NodesKey(nodeId)).child(NodeInfo.class).build();
79 try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
80 Optional<NodeInfo> nodeInfoObj =
81 readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
82 if (nodeInfoObj.isPresent()) {
83 NodeInfo nodInfo = nodeInfoObj.get();
84 switch (nodInfo.getOpenroadmVersion()) {
86 return StringConstants.OPENROADM_DEVICE_VERSION_7_1;
88 return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
90 return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
92 LOG.warn("unknown openROADM device version");
95 LOG.warn("Could not find mapping for nodeId {}", nodeId);
97 } catch (InterruptedException | ExecutionException ex) {
98 LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
106 * @see org.opendaylight.transportpce.common.mapping.MappingUtils#getMcCapabilitiesForNode(java.lang.String)
109 public List<McCapabilities> getMcCapabilitiesForNode(String nodeId) {
110 List<McCapabilities> mcCapabilities = new ArrayList<>();
111 InstanceIdentifier<Nodes> nodePortMappingIID = InstanceIdentifier.builder(Network.class)
112 .child(Nodes.class, new NodesKey(nodeId)).build();
113 try (ReadTransaction readTx = this.dataBroker.newReadOnlyTransaction()) {
114 Optional<Nodes> nodePortMapObject = readTx.read(LogicalDatastoreType.CONFIGURATION, nodePortMappingIID)
116 if (nodePortMapObject.isPresent()) {
117 LOG.info("Found node {}", nodeId);
118 Nodes node = nodePortMapObject.get();
119 mcCapabilities.addAll(node.nonnullMcCapabilities().values());
121 } catch (ExecutionException e) {
122 LOG.error("Something went wrong while getting node {}", nodeId, e);
123 } catch (InterruptedException e) {
124 LOG.error("Request interrupted for node {} interrupted", nodeId, e);
125 Thread.currentThread().interrupt();
127 LOG.info("Capabilitities for node {}: {}", nodeId, mcCapabilities);
128 return mcCapabilities;
131 public static Class<? extends SupportedIfCapability> convertSupIfCapa(String ifCapType) {
132 if (!capTypeClassMap.containsKey(ifCapType)) {
135 return capTypeClassMap.get(ifCapType);