2 * Copyright (c) 2013 Cisco Systems, Inc. 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.openflowplugin.impl.util;
10 import java.math.BigInteger;
11 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
12 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
13 import org.opendaylight.openflowplugin.openflow.md.util.OpenflowPortsUtil;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdatedBuilder;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortReason;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.State;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.StateBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemoved;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemovedBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdatedBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfigV10;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeaturesV10;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortStateV10;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortGrouping;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
34 public abstract class PortTranslatorUtil {
35 private static final Logger LOG = LoggerFactory.getLogger(PortTranslatorUtil.class);
36 public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures translatePortFeatures(final PortFeatures apf) {
37 org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures napf = null;
39 napf = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
40 apf.isAutoneg(), //_autoeng
41 apf.isCopper(), //_copper
42 apf.isFiber(), //_fiber
43 apf.is_40gbFd(), //_fortyGbFd
44 apf.is_100gbFd(), //_hundredGbFd
45 apf.is_100mbFd(), //_hundredMbFd
46 apf.is_100mbHd(), //_hundredMbHd
47 apf.is_1gbFd(), //_oneGbFd
48 apf.is_1gbHd(), //_oneGbHd
49 apf.is_1tbFd(), //_oneTbFd
50 apf.isOther(), //_other
51 apf.isPause(), //_pause
52 apf.isPauseAsym(), //_pauseAsym
53 apf.is_10gbFd(), //_tenGbFd
54 apf.is_10mbFd(), //_tenMbFd
55 apf.is_10mbHd()//_tenMbHd
62 public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures translatePortFeatures(
63 final PortFeaturesV10 apf) {
64 org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures napf = null;
66 napf = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures(
67 apf.isAutoneg(), //_autoeng
68 apf.isCopper(), //_copper
69 apf.isFiber(), //_fiber
72 apf.is_100mbFd(), //_hundredMbFd
73 apf.is_100mbHd(), //_hundredMbHd
74 apf.is_1gbFd(), //_oneGbFd
75 apf.is_1gbHd(), //_oneGbHd
78 apf.isPause(), //_pause
79 apf.isPauseAsym(), //_pauseAsym
80 apf.is_10gbFd(), //_tenGbFd
81 apf.is_10mbFd(), //_tenMbFd
82 apf.is_10mbHd()//_tenMbHd
88 public static State translatePortState(final PortState state) {
89 StateBuilder nstate = new StateBuilder();
91 nstate.setBlocked(state.isBlocked());
92 nstate.setLinkDown(state.isLinkDown());
93 nstate.setLive(state.isLive());
95 return nstate.build();
98 public static State translatePortState(final PortStateV10 state) {
99 StateBuilder nstate = new StateBuilder();
101 nstate.setBlocked(state.isBlocked());
102 nstate.setLinkDown(state.isLinkDown());
103 nstate.setLive(state.isLive());
105 return nstate.build();
108 public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig translatePortConfig(final PortConfig pc) {
109 org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig npc = null;
111 npc = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(pc.isNoFwd(),
112 pc.isNoPacketIn(), pc.isNoRecv(), pc.isPortDown());
117 public static org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig translatePortConfig(
118 final PortConfigV10 pc) {
119 org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig npc = null;
121 npc = new org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig(pc.isNoFwd(),
122 pc.isNoPacketIn(), pc.isNoRecv(), pc.isPortDown());
127 public static NodeConnectorUpdated translatePort(final Short version, final BigInteger datapathId, final Long portNumber, final PortGrouping port) {
128 OpenflowVersion ofVersion = OpenflowVersion.get(version);
129 NodeConnectorUpdatedBuilder builder = InventoryDataServiceUtil
130 .nodeConnectorUpdatedBuilderFromDatapathIdPortNo(datapathId, port.getPortNo(), ofVersion);
131 FlowCapableNodeConnectorUpdatedBuilder fcncub = new FlowCapableNodeConnectorUpdatedBuilder();
132 if (ofVersion == OpenflowVersion.OF13) {
133 fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeatures()));
134 fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfig()));
135 fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeatures()));
136 fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeatures()));
137 fcncub.setState(PortTranslatorUtil.translatePortState(port.getState()));
138 fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeatures()));
140 } else if (ofVersion == OpenflowVersion.OF10) {
141 fcncub.setAdvertisedFeatures(PortTranslatorUtil.translatePortFeatures(port.getAdvertisedFeaturesV10()));
142 fcncub.setConfiguration(PortTranslatorUtil.translatePortConfig(port.getConfigV10()));
143 fcncub.setCurrentFeature(PortTranslatorUtil.translatePortFeatures(port.getCurrentFeaturesV10()));
144 fcncub.setPeerFeatures(PortTranslatorUtil.translatePortFeatures(port.getPeerFeaturesV10()));
145 fcncub.setState(PortTranslatorUtil.translatePortState(port.getStateV10()));
146 fcncub.setSupported(PortTranslatorUtil.translatePortFeatures(port.getSupportedFeaturesV10()));
148 if (port instanceof PortStatusMessage) {
149 if (((PortStatusMessage) port).getReason() != null) {
150 fcncub.setReason(PortReason.forValue(((PortStatusMessage) port).getReason().getIntValue()));
152 LOG.debug("PortStatus Message has reason as null");
155 fcncub.setCurrentSpeed(port.getCurrSpeed());
156 fcncub.setHardwareAddress(port.getHwAddr());
157 fcncub.setMaximumSpeed(port.getMaxSpeed());
158 fcncub.setName(port.getName());
159 fcncub.setPortNumber(OpenflowPortsUtil.getProtocolAgnosticPort(ofVersion, portNumber));
160 builder.addAugmentation(FlowCapableNodeConnectorUpdated.class, fcncub.build());
161 return builder.build();
164 public static NodeConnectorRemoved translatePortRemoved(final Short version, final BigInteger datapathId, final Long portNumber, final PortGrouping port) {
165 OpenflowVersion ofVersion = OpenflowVersion.get(version);
166 NodeConnectorRemovedBuilder builder = new NodeConnectorRemovedBuilder();
167 builder.setNodeConnectorRef(InventoryDataServiceUtil.nodeConnectorRefFromDatapathIdPortno(datapathId, portNumber, ofVersion));
168 return builder.build();