multipart request message updated
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / deserialization / factories / MultipartReplyMessageFactory.java
index 64bf2ac39cedd932e0afb823129e525d7070f3b6..c8bfe6e011d20c77d9b775631efb63986049c421 100644 (file)
@@ -8,19 +8,39 @@ import java.util.ArrayList;
 import java.util.List;\r
 \r
 import org.opendaylight.openflowjava.protocol.impl.deserialization.OFDeserializer;\r
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterBandType;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterModCommand;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessageBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDropBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemarkBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregate;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDesc;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDescBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenterBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlow;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroup;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeter;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfig;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfigBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeatures;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeaturesBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDesc;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDescBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStats;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueue;\r
@@ -33,6 +53,16 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.GroupStatsBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStats;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStatsBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStats;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStatsBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfig;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfigBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.Bands;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.BandsBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStats;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStatsBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.Ports;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.PortsBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStats;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStatsBuilder;\r
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStats;\r
@@ -89,6 +119,16 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
                  break;         \r
         case 6:  builder.setMultipartReplyBody(setGroup(rawMessage));\r
                  break;\r
+        case 9:  builder.setMultipartReplyBody(setMeter(rawMessage));\r
+                 break;\r
+        case 10:  builder.setMultipartReplyBody(setMeterConfig(rawMessage));\r
+                 break;\r
+        case 11: builder.setMultipartReplyBody(setMeterFeatures(rawMessage));\r
+                 break;\r
+        case 13: builder.setMultipartReplyBody(setPortDesc(rawMessage));\r
+                 break;\r
+        case 0xFFFF: builder.setMultipartReplyBody(setExperimenter(rawMessage));\r
+                 break;\r
         default: \r
                  break;\r
         }\r
@@ -129,7 +169,9 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
         MultipartReplyFlowBuilder flowBuilder = new MultipartReplyFlowBuilder();\r
         List<FlowStats> flowStatsList = new ArrayList<>();\r
         FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();\r
+        int flowLen = 0;\r
         while (input.readableBytes() > 0) {\r
+            flowLen = input.readUnsignedShort();\r
             flowStatsBuilder.setTableId(input.readUnsignedByte());\r
             input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_01);\r
             flowStatsBuilder.setDurationSec(input.readUnsignedInt());\r
@@ -152,7 +194,8 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
             // TODO instructions\r
             flowStatsList.add(flowStatsBuilder.build());\r
         }\r
-        flowBuilder.setFlowStats(flowStatsList);\r
+        flowBuilder.setFlowStats(new ArrayList<>(flowStatsList));\r
+        flowStatsList.clear();\r
         return flowBuilder.build();\r
     }\r
     \r
@@ -196,7 +239,8 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
             tableStatsBuilder.setMatchedCount(new BigInteger(matchedCount));\r
             tableStatsList.add(tableStatsBuilder.build());\r
         }\r
-        builder.setTableStats(tableStatsList);\r
+        builder.setTableStats(new ArrayList<>(tableStatsList));\r
+        tableStatsList.clear();\r
         return builder.build();\r
     }\r
     \r
@@ -261,7 +305,8 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
             portStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
             portStatsList.add(portStatsBuilder.build());\r
         }\r
-        builder.setPortStats(portStatsList);\r
+        builder.setPortStats(new ArrayList<>(portStatsList));\r
+        portStatsList.clear();\r
         return builder.build();\r
     }\r
     \r
@@ -290,7 +335,8 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
             queueStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
             queueStatsList.add(queueStatsBuilder.build());\r
         }\r
-        builder.setQueueStats(queueStatsList);\r
+        builder.setQueueStats(new ArrayList<>(queueStatsList));\r
+        queueStatsList.clear();\r
         return builder.build();\r
     }\r
     \r
@@ -334,12 +380,231 @@ public class MultipartReplyMessageFactory implements OFDeserializer<MultipartRep
                 bucketStatsBuilder.setByteCount(new BigInteger(byteCountBucket));\r
                 bucketStatsList.add(bucketStatsBuilder.build());\r
 \r
-                groupStatsBuilder.setBucketStats(bucketStatsList);\r
-                groupStatsList.add(groupStatsBuilder.build());\r
                 actualLength = actualLength + BUCKET_COUNTER_LENGTH;\r
             } \r
+            groupStatsBuilder.setBucketStats(new ArrayList<>(bucketStatsList));\r
+            bucketStatsList.clear();\r
+            groupStatsList.add(groupStatsBuilder.build());\r
+        }\r
+        builder.setGroupStats(new ArrayList<>(groupStatsList));\r
+        groupStatsList.clear();\r
+        return builder.build();\r
+    }\r
+    \r
+    private static MultipartReplyMeterFeatures setMeterFeatures(ByteBuf input) {\r
+        final byte PADDING_IN_METER_FEATURES_HEADER = 2;\r
+        MultipartReplyMeterFeaturesBuilder builder = new MultipartReplyMeterFeaturesBuilder();\r
+        builder.setMaxMeter(input.readUnsignedInt());\r
+        builder.setBandTypes(MeterBandType.forValue(input.readInt()));\r
+        builder.setCapabilities(decodeMeterModFlags((int) input.readUnsignedInt()));\r
+        builder.setMaxBands(input.readUnsignedByte());\r
+        builder.setMaxColor(input.readUnsignedByte());\r
+        input.skipBytes(PADDING_IN_METER_FEATURES_HEADER);\r
+        return builder.build();\r
+    }\r
+    \r
+    private static MeterFlags decodeMeterModFlags(int input){\r
+        final Boolean _oFPMFKBPS = (input & (1 << 0)) > 0;\r
+        final Boolean _oFPMFPKTPS = (input & (1 << 1)) > 0;\r
+        final Boolean _oFPMFBURST = (input & (1 << 2)) > 0; \r
+        final Boolean _oFPMFSTATS = (input & (1 << 3)) > 0;\r
+        return new MeterFlags(_oFPMFBURST, _oFPMFKBPS, _oFPMFPKTPS, _oFPMFSTATS);\r
+    }\r
+    \r
+    private static MultipartReplyMeter setMeter(ByteBuf input) {\r
+        final byte PADDING_IN_METER_STATS_HEADER = 6;\r
+        final byte METER_BAND_STATS_LENGTH = 16;\r
+        final byte METER_BODY_LENGTH = 40;\r
+        int actualLength;\r
+        MultipartReplyMeterBuilder builder = new MultipartReplyMeterBuilder();\r
+        List<MeterStats> meterStatsList = new ArrayList<>();\r
+        MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();\r
+        List<MeterBandStats> meterBandStatsList = new ArrayList<>();\r
+        MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();\r
+        while (input.readableBytes() > 0) {\r
+            meterStatsBuilder.setMeterId(input.readUnsignedInt());\r
+            actualLength = 0;\r
+            int meterStatsBodyLength = input.readUnsignedShort();\r
+            input.skipBytes(PADDING_IN_METER_STATS_HEADER);\r
+            meterStatsBuilder.setFlowCount(input.readUnsignedInt());\r
+            byte[] packetInCount = new byte[Long.SIZE/Byte.SIZE];\r
+            input.readBytes(packetInCount);\r
+            meterStatsBuilder.setPacketInCount(new BigInteger(packetInCount));\r
+            byte[] byteInCount = new byte[Long.SIZE/Byte.SIZE];\r
+            input.readBytes(byteInCount);\r
+            meterStatsBuilder.setByteInCount(new BigInteger(byteInCount));\r
+            meterStatsBuilder.setDurationSec(input.readUnsignedInt());\r
+            meterStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
+            actualLength = METER_BODY_LENGTH;\r
+            \r
+            while (actualLength < meterStatsBodyLength) {\r
+                byte[] packetBandCount = new byte[Long.SIZE/Byte.SIZE];\r
+                input.readBytes(packetBandCount);\r
+                meterBandStatsBuilder.setPacketBandCount(new BigInteger(packetBandCount));\r
+                byte[] byteBandCount = new byte[Long.SIZE/Byte.SIZE];\r
+                input.readBytes(byteBandCount);\r
+                meterBandStatsBuilder.setByteBandCount(new BigInteger(byteBandCount));\r
+                \r
+                meterBandStatsList.add(meterBandStatsBuilder.build());\r
+                actualLength = actualLength + METER_BAND_STATS_LENGTH;\r
+            }\r
+        \r
+            meterStatsBuilder.setMeterBandStats(new ArrayList<>(meterBandStatsList));\r
+            meterBandStatsList.clear();\r
+            meterStatsList.add(meterStatsBuilder.build());\r
+        }\r
+        builder.setMeterStats(new ArrayList<>(meterStatsList));\r
+        meterStatsList.clear();\r
+        return builder.build();\r
+    }\r
+    \r
+    private static MultipartReplyMeterConfig setMeterConfig(ByteBuf input) {\r
+        final byte METER_BAND_LENGTH = 16;\r
+        final byte METER_CONFIG_LENGTH = 8;\r
+        int actualLength;\r
+        MultipartReplyMeterConfigBuilder builder = new MultipartReplyMeterConfigBuilder();\r
+        List<MeterConfig> meterConfigList = new ArrayList<>();\r
+        MeterConfigBuilder meterConfigBuilder = new MeterConfigBuilder();\r
+        List<Bands> bandsList = new ArrayList<Bands>();\r
+        BandsBuilder bandsBuilder = new BandsBuilder();\r
+        \r
+        while (input.readableBytes() > 0) {\r
+            int meterConfigBodyLength = input.readUnsignedShort();\r
+            actualLength = 0;\r
+            meterConfigBuilder.setFlags(MeterModCommand.forValue(input.readUnsignedShort()));\r
+            meterConfigBuilder.setMeterId(input.readUnsignedInt());\r
+            actualLength = METER_CONFIG_LENGTH;\r
+            \r
+            while (actualLength < meterConfigBodyLength) {\r
+                MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();\r
+                final byte PADDING_IN_METER_BAND_DROP_HEADER = 4;\r
+                MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();\r
+                final byte PADDING_IN_METER_BAND_DSCP_HEADER = 3;\r
+                MeterBandExperimenterBuilder bandExperimenterBuilder = new MeterBandExperimenterBuilder(); \r
+                int bandLen = 0;\r
+                int bandType = input.readUnsignedShort();\r
+                switch (bandType) {\r
+                    case 1: bandDropBuilder.setType(MeterBandType.forValue(bandType));\r
+                            bandLen = input.readUnsignedShort();\r
+                            bandDropBuilder.setRate(input.readUnsignedInt());\r
+                            bandDropBuilder.setBurstSize(input.readUnsignedInt());\r
+                            input.skipBytes(PADDING_IN_METER_BAND_DROP_HEADER);\r
+                            bandsBuilder.setMeterBand(bandDropBuilder.build());\r
+                            break;\r
+                    case 2: bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));\r
+                            bandLen = input.readUnsignedShort();\r
+                            bandDscpRemarkBuilder.setRate(input.readUnsignedInt());\r
+                            bandDscpRemarkBuilder.setBurstSize(input.readUnsignedInt());\r
+                            bandDscpRemarkBuilder.setPrecLevel(input.readUnsignedByte());\r
+                            input.skipBytes(PADDING_IN_METER_BAND_DSCP_HEADER);\r
+                            bandsBuilder.setMeterBand(bandDscpRemarkBuilder.build());\r
+                            break;\r
+                    case 0xFFFF: bandExperimenterBuilder.setType(MeterBandType.forValue(bandType));\r
+                                 bandLen = input.readUnsignedShort();          \r
+                                 bandExperimenterBuilder.setRate(input.readUnsignedInt());\r
+                                 bandExperimenterBuilder.setBurstSize(input.readUnsignedInt());\r
+                                 bandExperimenterBuilder.setExperimenter(input.readUnsignedInt());\r
+                                 bandsBuilder.setMeterBand(bandExperimenterBuilder.build());\r
+                                 break;\r
+                    default: break;\r
+                }\r
+                bandsList.add(bandsBuilder.build());\r
+                actualLength = actualLength + METER_BAND_LENGTH;\r
+            }\r
+            meterConfigBuilder.setBands(new ArrayList<>(bandsList));\r
+            bandsList.clear();\r
+            meterConfigList.add(meterConfigBuilder.build());\r
         }\r
-        builder.setGroupStats(groupStatsList);\r
+        builder.setMeterConfig(new ArrayList<>(meterConfigList));\r
+        meterConfigList.clear();\r
+        return builder.build();\r
+    }\r
+    \r
+    private static MultipartReplyExperimenter setExperimenter(ByteBuf input) {\r
+        MultipartReplyExperimenterBuilder builder = new MultipartReplyExperimenterBuilder();\r
+        builder.setExperimenter(input.readUnsignedInt());\r
+        builder.setExpType(input.readUnsignedInt());\r
+        byte[] data = new byte[Long.SIZE/Byte.SIZE];\r
+        input.readBytes(data);\r
+        builder.setData(data);\r
         return builder.build();\r
     }\r
+    \r
+    private static MultipartReplyPortDesc setPortDesc(ByteBuf input) {\r
+        final byte PADDING_IN_PORT_DESC_HEADER_01 = 4;\r
+        final byte PADDING_IN_PORT_DESC_HEADER_02 = 2;\r
+        final int macAddressLength = 6;\r
+        final byte MAX_PORT_NAME_LEN = 16;\r
+        MultipartReplyPortDescBuilder builder = new MultipartReplyPortDescBuilder();\r
+        List<Ports> portsList = new ArrayList<>();\r
+        PortsBuilder portsBuilder = new PortsBuilder();\r
+        \r
+        while (input.readableBytes() > 0) {\r
+            portsBuilder.setPortNo(input.readUnsignedInt());\r
+            input.skipBytes(PADDING_IN_PORT_DESC_HEADER_01);\r
+            StringBuffer macToString = new StringBuffer();\r
+            for(int i=0; i<macAddressLength; i++){\r
+                short mac = 0;\r
+                mac = input.readUnsignedByte();\r
+                macToString.append(String.format("%02X", mac));\r
+            }\r
+            portsBuilder.setHwAddr(new MacAddress(macToString.toString()));\r
+            input.skipBytes(PADDING_IN_PORT_DESC_HEADER_02);\r
+            \r
+            byte[] portNameBytes = new byte[MAX_PORT_NAME_LEN];\r
+            input.readBytes(portNameBytes);\r
+            String portName = new String(portNameBytes);\r
+            portsBuilder.setName(portName.trim());\r
+            \r
+            portsBuilder.setConfig(createPortConfig(input.readUnsignedInt()));\r
+            portsBuilder.setState(createPortState(input.readUnsignedInt()));\r
+            portsBuilder.setCurrentFeatures(createPortFeatures(input.readUnsignedInt()));\r
+            portsBuilder.setAdvertisedFeatures(createPortFeatures(input.readUnsignedInt()));\r
+            portsBuilder.setSupportedFeatures(createPortFeatures(input.readUnsignedInt()));\r
+            portsBuilder.setPeerFeatures(createPortFeatures(input.readUnsignedInt()));\r
+            portsBuilder.setCurrSpeed(input.readUnsignedInt());\r
+            portsBuilder.setMaxSpeed(input.readUnsignedInt());\r
+            portsList.add(portsBuilder.build());\r
+        }\r
+        \r
+        builder.setPorts(new ArrayList<>(portsList));\r
+        portsList.clear();\r
+        return builder.build();\r
+    }\r
+    \r
+    private static PortConfig createPortConfig(long input){\r
+        final Boolean _portDown   = ((input) & (1<<0)) != 0;\r
+        final Boolean _noRecv    = ((input) & (1<<2)) != 0;\r
+        final Boolean _noFwd       = ((input) & (1<<5)) != 0;\r
+        final Boolean _noPacketIn = ((input) & (1<<6)) != 0;\r
+        return new PortConfig(_noFwd, _noPacketIn, _noRecv, _portDown);\r
+    }\r
+    \r
+    private static PortState createPortState(long input){\r
+        final Boolean _linkDown = ((input) & (1<<0)) != 0;\r
+        final Boolean _blocked  = ((input) & (1<<1)) != 0;\r
+        final Boolean _live     = ((input) & (1<<2)) != 0;\r
+        return new PortState(_linkDown, _blocked,_live);\r
+    }\r
+    \r
+    private static PortFeatures createPortFeatures(long input){\r
+        final Boolean _10mbHd = ((input) & (1<<0)) != 0;\r
+        final Boolean _10mbFd = ((input) & (1<<1)) != 0;\r
+        final Boolean _100mbHd = ((input) & (1<<2)) != 0;\r
+        final Boolean _100mbFd = ((input) & (1<<3)) != 0;\r
+        final Boolean _1gbHd = ((input) & (1<<4)) != 0;\r
+        final Boolean _1gbFd = ((input) & (1<<5)) != 0;\r
+        final Boolean _10gbFd = ((input) & (1<<6)) != 0;\r
+        final Boolean _40gbFd = ((input) & (1<<7)) != 0;\r
+        final Boolean _100gbFd = ((input) & (1<<8)) != 0;\r
+        final Boolean _1tbFd = ((input) & (1<<9)) != 0;\r
+        final Boolean _other = ((input) & (1<<10)) != 0;\r
+        final Boolean _copper = ((input) & (1<<11)) != 0;\r
+        final Boolean _fiber = ((input) & (1<<12)) != 0;\r
+        final Boolean _autoneg = ((input) & (1<<13)) != 0;\r
+        final Boolean _pause = ((input) & (1<<14)) != 0;\r
+        final Boolean _pauseAsym = ((input) & (1<<15)) != 0;\r
+        return new PortFeatures(_10mbHd, _10mbFd, _100mbHd, _100mbFd, _1gbHd, _1gbFd, _10gbFd,\r
+                _40gbFd, _100gbFd, _1tbFd, _other, _copper, _fiber, _autoneg, _pause, _pauseAsym);\r
+    }\r
 }\r