Minor fixes to lldp speaker and packet out
[openflowplugin.git] / openflowplugin / src / main / java / org / opendaylight / openflowplugin / openflow / md / core / sal / convertor / PortConvertor.java
1 package org.opendaylight.openflowplugin.openflow.md.core.sal.convertor;
2
3 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
4 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;
5 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;
6 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
7 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;
8 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInput;
9 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInputBuilder;
10 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc._case.multipart.reply.port.desc.Ports;
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc._case.multipart.reply.port.desc.PortsBuilder;
12 import org.slf4j.Logger;
13 import org.slf4j.LoggerFactory;
14
15 /**
16  * @author esssuuu This convertor class is used for Port Mod,port status and
17  *         port description messages,decodes SAL and encodes to OF Data
18  *
19  */
20 public final class PortConvertor {
21     private static final Logger log = LoggerFactory.getLogger(PortConvertor.class);
22
23     private PortConvertor() {
24
25     }
26
27     /**
28      * This method is used by PORT_MOD_MESSAGE
29      *
30      * @param source
31      * @return
32      */
33
34     public static PortModInput toPortModInput(
35             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.port.mod.port.Port source,
36             short version) {
37
38
39         PortConfig config = null;
40
41         PortModInputBuilder portModInputBuilder = new PortModInputBuilder();
42         portModInputBuilder.setAdvertise(getPortFeatures(source.getAdvertisedFeatures()));
43         portModInputBuilder.setPortNo(new PortNumber(source.getPortNumber()));
44         maskPortConfigFields(source.getConfiguration(), config);
45         portModInputBuilder.setConfig(config);
46         portModInputBuilder.setHwAddress(new MacAddress(source.getHardwareAddress()));
47         config = null;
48         maskPortConfigFields(source.getMask(), config);
49         portModInputBuilder.setMask(config);
50         portModInputBuilder.setVersion(version);
51         return portModInputBuilder.build();
52
53     }
54
55     private static void maskPortConfigFields(
56             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig configData,
57             PortConfig config) {
58         Boolean portDown = false;
59         Boolean noRecv = false;
60         Boolean noFwd = false;
61         Boolean noPacketIn = false;
62         if (configData.isNOFWD())
63             noFwd = true;
64         if (configData.isNOPACKETIN())
65             noPacketIn = true;
66         if (configData.isNORECV())
67             noRecv = true;
68         if (configData.isPORTDOWN())
69             portDown = true;
70
71         config = new PortConfig(noFwd, noPacketIn, noRecv, portDown);
72
73     }
74
75     private static PortFeatures getPortFeatures(
76             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures salPortFeatures) {
77
78         return new PortFeatures(salPortFeatures.is_100gbFd(), salPortFeatures.is_100mbFd(),
79                 salPortFeatures.is_100mbHd(), salPortFeatures.is_10gbFd(), salPortFeatures.is_10mbFd(),
80                 salPortFeatures.is_10mbHd(), salPortFeatures.is_1gbFd(), salPortFeatures.is_1gbHd(),
81                 salPortFeatures.is_1tbFd(), salPortFeatures.is_40gbFd(), salPortFeatures.isAutoeng(),
82                 salPortFeatures.isCopper(), salPortFeatures.isFiber(), salPortFeatures.isOther(),
83                 salPortFeatures.isPause(), salPortFeatures.isPauseAsym());
84     }
85
86     /*
87      * This method is called as a reply to OFPMP_PORT_DESCRIPTION
88      * message(OF1.3.1)
89      */
90     /**
91      * @param source
92      *            :SAL FlowCapablePort
93      * @return OF:Ports
94      */
95     public static Ports toPortDesc(
96             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.FlowCapablePort source) {
97
98         PortConfig config = null;
99         PortState portState = null;
100
101         PortsBuilder OFPortDescDataBuilder = new PortsBuilder();
102         OFPortDescDataBuilder.setPortNo(source.getPortNumber()); // portNO
103
104         OFPortDescDataBuilder.setHwAddr(source.getHardwareAddress());
105         OFPortDescDataBuilder.setName(source.getName());
106
107         maskPortConfigFields(source.getConfiguration(), config);
108
109         OFPortDescDataBuilder.setConfig(config);
110
111         getPortState(source.getState(), portState);
112         OFPortDescDataBuilder.setState(portState);
113         OFPortDescDataBuilder.setCurrentFeatures(getPortFeatures(source.getCurrentFeature()));
114         OFPortDescDataBuilder.setAdvertisedFeatures(getPortFeatures(source.getAdvertisedFeatures()));
115         OFPortDescDataBuilder.setSupportedFeatures(getPortFeatures(source.getSupported()));
116         OFPortDescDataBuilder.setPeerFeatures(getPortFeatures(source.getPeerFeatures()));
117         OFPortDescDataBuilder.setCurrSpeed(source.getCurrentSpeed());
118         OFPortDescDataBuilder.setMaxSpeed(source.getMaximumSpeed());
119
120         return OFPortDescDataBuilder.build();
121
122     }
123
124     private static void getPortState(
125             org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortState state, PortState portState) {
126
127         boolean isLinkDown = false;// (0),
128         boolean isBlocked = false; // (1),
129         boolean isLive = false; // (2);
130
131         if (state.getIntValue() == 0) {
132             isLinkDown = true;
133         } else if (state.getIntValue() == 1) {
134             isBlocked = true;
135         } else if (state.getIntValue() == 2) {
136             isLive = true;
137         }
138         portState = new PortState(isLinkDown, isBlocked, isLive);
139
140     }
141
142
143
144 }