openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/factories/MultipartReplyMessageFactory.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
   2 package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;\r
   3 \r
   4 import io.netty.buffer.ByteBuf;\r
   5 \r
   6 import java.math.BigInteger;\r
   7 import java.util.ArrayList;\r
   8 import java.util.List;\r
   9 \r
  10 import org.opendaylight.openflowjava.protocol.impl.deserialization.OFDeserializer;\r
  11 import org.opendaylight.openflowjava.protocol.impl.util.ActionsDeserializer;\r
  12 import org.opendaylight.openflowjava.protocol.impl.util.InstructionsDeserializer;\r
  13 import org.opendaylight.openflowjava.protocol.impl.util.MatchEntriesDeserializer;\r
  14 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterRelatedTableFeatureProperty;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterRelatedTableFeaturePropertyBuilder;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NextTableRelatedTableFeatureProperty;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NextTableRelatedTableFeaturePropertyBuilder;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.table.features.properties.container.table.feature.properties.NextTableIds;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.table.features.properties.container.table.feature.properties.NextTableIdsBuilder;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.ActionsList;\r
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;\r
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupCapabilities;\r
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;\r
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupTypes;\r
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterBandType;\r
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;\r
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterModCommand;\r
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;\r
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;\r
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;\r
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableFeaturesPropType;\r
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;\r
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessageBuilder;\r
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.BucketsList;\r
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.BucketsListBuilder;\r
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDropBuilder;\r
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemarkBuilder;\r
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterBuilder;\r
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.MultipartReplyBody;\r
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregate;\r
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateBuilder;\r
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDesc;\r
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDescBuilder;\r
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;\r
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenterBuilder;\r
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlow;\r
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowBuilder;\r
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroup;\r
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupBuilder;\r
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupDesc;\r
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupDescBuilder;\r
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupFeaturesBuilder;\r
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeter;\r
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterBuilder;\r
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfig;\r
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfigBuilder;\r
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeatures;\r
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeaturesBuilder;\r
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDesc;\r
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDescBuilder;\r
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStats;\r
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsBuilder;\r
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueue;\r
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueueBuilder;\r
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTable;\r
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableBuilder;\r
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableFeatures;\r
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableFeaturesBuilder;\r
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStats;\r
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStatsBuilder;\r
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.GroupStats;\r
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.GroupStatsBuilder;\r
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc.GroupDesc;\r
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.desc.GroupDescBuilder;\r
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStats;\r
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStatsBuilder;\r
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStats;\r
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStatsBuilder;\r
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfig;\r
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfigBuilder;\r
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.Bands;\r
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.BandsBuilder;\r
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStats;\r
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStatsBuilder;\r
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.Ports;\r
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.PortsBuilder;\r
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStats;\r
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStatsBuilder;\r
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStats;\r
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStatsBuilder;\r
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStats;\r
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStatsBuilder;\r
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.features.TableFeatures;\r
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.features.TableFeaturesBuilder;\r
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.TableFeatureProperties;\r
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.TableFeaturePropertiesBuilder;\r
 101 \r
 102 /**\r
 103  * @author timotej.kubas\r
 104  * @author michal.polkorab\r
 105  */\r
 106 public class MultipartReplyMessageFactory implements OFDeserializer<MultipartReplyMessage> {\r
 107 \r
 108     private static MultipartReplyMessageFactory instance;\r
 109     private static final byte PADDING_IN_MULTIPART_REPLY_HEADER = 4;\r
 110     \r
 111     private MultipartReplyMessageFactory() {\r
 112         // singleton\r
 113     }\r
 114     \r
 115     /**\r
 116      * @return singleton factory\r
 117      */\r
 118     public static synchronized MultipartReplyMessageFactory getInstance() {\r
 119         if (instance == null){\r
 120             instance = new MultipartReplyMessageFactory();\r
 121         }\r
 122         return instance;\r
 123     }\r
 124 \r
 125     @Override\r
 126     public MultipartReplyMessage bufferToMessage(ByteBuf rawMessage, short version) {\r
 127         MultipartReplyMessageBuilder builder = new MultipartReplyMessageBuilder();\r
 128         builder.setVersion(version);\r
 129         builder.setXid(rawMessage.readUnsignedInt());\r
 130         int type = rawMessage.readUnsignedShort();\r
 131         builder.setType(MultipartType.forValue(type));\r
 132         builder.setFlags(new MultipartRequestFlags((rawMessage.readUnsignedShort() & 0x01) != 0));\r
 133         rawMessage.skipBytes(PADDING_IN_MULTIPART_REPLY_HEADER);\r
 134 \r
 135         switch (type) {\r
 136         case 0:  builder.setMultipartReplyBody(setDesc(rawMessage));\r
 137                  break;\r
 138         case 1:  builder.setMultipartReplyBody(setFlow(rawMessage));\r
 139                  break;\r
 140         case 2:  builder.setMultipartReplyBody(setAggregate(rawMessage));\r
 141                  break;\r
 142         case 3:  builder.setMultipartReplyBody(setTable(rawMessage));\r
 143                  break;         \r
 144         case 4:  builder.setMultipartReplyBody(setPortStats(rawMessage));\r
 145                  break;\r
 146         case 5:  builder.setMultipartReplyBody(setQueue(rawMessage));\r
 147                  break;         \r
 148         case 6:  builder.setMultipartReplyBody(setGroup(rawMessage));\r
 149                  break;\r
 150         case 7:  builder.setMultipartReplyBody(setGroupDesc(rawMessage));\r
 151                  break;\r
 152         case 8:  builder.setMultipartReplyBody(setGroupFeatures(rawMessage));\r
 153                  break;\r
 154         case 9:  builder.setMultipartReplyBody(setMeter(rawMessage));\r
 155                  break;\r
 156         case 10: builder.setMultipartReplyBody(setMeterConfig(rawMessage));\r
 157                  break;\r
 158         case 11: builder.setMultipartReplyBody(setMeterFeatures(rawMessage));\r
 159                  break;\r
 160         case 12: builder.setMultipartReplyBody(setTableFeatures(rawMessage));\r
 161                  break;\r
 162         case 13: builder.setMultipartReplyBody(setPortDesc(rawMessage));\r
 163                  break;\r
 164         case 0xFFFF: builder.setMultipartReplyBody(setExperimenter(rawMessage));\r
 165                  break;\r
 166         default: \r
 167                  break;\r
 168         }\r
 169         \r
 170         return builder.build();\r
 171     }\r
 172     \r
 173     private static MultipartReplyDesc setDesc(ByteBuf input) {\r
 174         final int DESC_STR_LEN = 256;\r
 175         final int SERIAL_NUM_LEN = 32;\r
 176         MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();\r
 177         byte[] mfrDescBytes = new byte[DESC_STR_LEN];\r
 178         input.readBytes(mfrDescBytes);\r
 179         String mfrDesc = new String(mfrDescBytes);\r
 180         descBuilder.setMfrDesc(mfrDesc.trim());\r
 181         byte[] hwDescBytes = new byte[DESC_STR_LEN];\r
 182         input.readBytes(hwDescBytes);\r
 183         String hwDesc = new String(hwDescBytes);\r
 184         descBuilder.setHwDesc(hwDesc.trim());\r
 185         byte[] swDescBytes = new byte[DESC_STR_LEN];\r
 186         input.readBytes(swDescBytes);\r
 187         String swDesc = new String(swDescBytes);\r
 188         descBuilder.setSwDesc(swDesc.trim());\r
 189         byte[] serialNumBytes = new byte[SERIAL_NUM_LEN];\r
 190         input.readBytes(serialNumBytes);\r
 191         String serialNum = new String(serialNumBytes);\r
 192         descBuilder.setSerialNum(serialNum.trim());\r
 193         byte[] dpDescBytes = new byte[DESC_STR_LEN];\r
 194         input.readBytes(dpDescBytes);\r
 195         String dpDesc = new String(dpDescBytes);\r
 196         descBuilder.setDpDesc(dpDesc.trim());\r
 197         return descBuilder.build();\r
 198     }\r
 199     \r
 200     private static MultipartReplyFlow setFlow(ByteBuf input) {\r
 201         final byte PADDING_IN_FLOW_STATS_HEADER_01 = 1;\r
 202         final byte PADDING_IN_FLOW_STATS_HEADER_02 = 4;\r
 203         final byte flowLength = 2;\r
 204         MultipartReplyFlowBuilder flowBuilder = new MultipartReplyFlowBuilder();\r
 205         List<FlowStats> flowStatsList = new ArrayList<>();\r
 206         FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();\r
 207         while (input.readableBytes() > 0) {\r
 208             input.skipBytes(flowLength);\r
 209             flowStatsBuilder.setTableId(input.readUnsignedByte());\r
 210             input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_01);\r
 211             flowStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 212             flowStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 213             flowStatsBuilder.setPriority(input.readUnsignedShort());\r
 214             flowStatsBuilder.setIdleTimeout(input.readUnsignedShort());\r
 215             flowStatsBuilder.setHardTimeout(input.readUnsignedShort());\r
 216             flowStatsBuilder.setFlags(createFlowModFlagsFromBitmap(input.readShort()));\r
 217             input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_02);\r
 218             byte[] cookie = new byte[Long.SIZE/Byte.SIZE];\r
 219             input.readBytes(cookie);\r
 220             flowStatsBuilder.setCookie(new BigInteger(cookie));\r
 221             byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 222             input.readBytes(packetCount);\r
 223             flowStatsBuilder.setPacketCount(new BigInteger(packetCount));\r
 224             byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 225             input.readBytes(byteCount);\r
 226             flowStatsBuilder.setByteCount(new BigInteger(byteCount));\r
 227             // TODO match\r
 228             // TODO instructions\r
 229             flowStatsList.add(flowStatsBuilder.build());\r
 230         }\r
 231         flowBuilder.setFlowStats(new ArrayList<>(flowStatsList));\r
 232         flowStatsList.clear();\r
 233         return flowBuilder.build();\r
 234     }\r
 235     \r
 236     private static FlowModFlags createFlowModFlagsFromBitmap(short input){\r
 237         final Boolean _oFPFFSENDFLOWREM = (input & (1 << 0)) != 0;\r
 238         final Boolean _oFPFFCHECKOVERLAP = (input & (1 << 1)) != 0;\r
 239         final Boolean _oFPFFRESETCOUNTS = (input & (1 << 2)) != 0; \r
 240         final Boolean _oFPFFNOPKTCOUNTS = (input & (1 << 3)) != 0;\r
 241         final Boolean _oFPFFNOBYTCOUNTS = (input & (1 << 4)) != 0;\r
 242         return new FlowModFlags(_oFPFFCHECKOVERLAP, _oFPFFNOBYTCOUNTS, _oFPFFNOPKTCOUNTS, _oFPFFRESETCOUNTS, _oFPFFSENDFLOWREM);\r
 243     }\r
 244     \r
 245     private static MultipartReplyAggregate setAggregate(ByteBuf input) {\r
 246         final byte PADDING_IN_AGGREGATE_HEADER = 4;\r
 247         MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();\r
 248         byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 249         input.readBytes(packetCount);\r
 250         builder.setPacketCount(new BigInteger(packetCount));\r
 251         byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 252         input.readBytes(byteCount);\r
 253         builder.setByteCount(new BigInteger(byteCount));\r
 254         builder.setFlowCount(input.readUnsignedInt());\r
 255         input.skipBytes(PADDING_IN_AGGREGATE_HEADER);\r
 256         return builder.build();\r
 257     }\r
 258     \r
 259     private static MultipartReplyTable setTable(ByteBuf input) {\r
 260         final byte PADDING_IN_TABLE_HEADER = 3;\r
 261         MultipartReplyTableBuilder builder = new MultipartReplyTableBuilder();\r
 262         TableStatsBuilder tableStatsBuilder = new TableStatsBuilder();\r
 263         List<TableStats> tableStatsList = new ArrayList<>();\r
 264         while (input.readableBytes() > 0) {\r
 265             tableStatsBuilder.setTableId(input.readUnsignedByte());\r
 266             input.skipBytes(PADDING_IN_TABLE_HEADER);\r
 267             tableStatsBuilder.setActiveCount(input.readUnsignedInt());\r
 268             byte[] lookupCount = new byte[Long.SIZE/Byte.SIZE];\r
 269             input.readBytes(lookupCount);\r
 270             tableStatsBuilder.setLookupCount(new BigInteger(lookupCount));\r
 271             byte[] matchedCount = new byte[Long.SIZE/Byte.SIZE];\r
 272             input.readBytes(matchedCount);\r
 273             tableStatsBuilder.setMatchedCount(new BigInteger(matchedCount));\r
 274             tableStatsList.add(tableStatsBuilder.build());\r
 275         }\r
 276         builder.setTableStats(new ArrayList<>(tableStatsList));\r
 277         tableStatsList.clear();\r
 278         return builder.build();\r
 279     }\r
 280     \r
 281     private static MultipartReplyTableFeatures setTableFeatures(ByteBuf input) {\r
 282         final byte PADDING_IN_MULTIPART_REPLY_TABLE_FEATURES = 5;\r
 283         final byte MAX_TABLE_NAME_LENGTH = 32;\r
 284         final byte MULTIPART_REPLY_TABLE_FEATURES_STRUCTURE_LENGTH = 64;\r
 285         MultipartReplyTableFeaturesBuilder builder = new MultipartReplyTableFeaturesBuilder();\r
 286         List<TableFeatures> features = new ArrayList<>();\r
 287         while (input.readableBytes() > 0) {\r
 288             TableFeaturesBuilder featuresBuilder = new TableFeaturesBuilder();\r
 289             int length = input.readUnsignedShort();\r
 290             featuresBuilder.setTableId(input.readUnsignedByte());\r
 291             input.skipBytes(PADDING_IN_MULTIPART_REPLY_TABLE_FEATURES);\r
 292             featuresBuilder.setName(input.readBytes(MAX_TABLE_NAME_LENGTH).toString());\r
 293             byte[] metadataMatch = new byte[Long.SIZE / Byte.SIZE];\r
 294             input.readBytes(metadataMatch);\r
 295             featuresBuilder.setMetadataMatch(metadataMatch);\r
 296             byte[] metadataWrite = new byte[Long.SIZE / Byte.SIZE];\r
 297             input.readBytes(metadataWrite);\r
 298             featuresBuilder.setMetadataWrite(metadataWrite);\r
 299             featuresBuilder.setConfig(createPortConfig(input.readUnsignedInt()));\r
 300             featuresBuilder.setMaxEntries(input.readUnsignedInt());\r
 301             featuresBuilder.setTableFeatureProperties(createTableFeaturesProperties(input, \r
 302                     length - MULTIPART_REPLY_TABLE_FEATURES_STRUCTURE_LENGTH));\r
 303             features.add(featuresBuilder.build());\r
 304         }\r
 305         builder.setTableFeatures(features);\r
 306         return builder.build();\r
 307     }\r
 308     \r
 309     private static List<TableFeatureProperties> createTableFeaturesProperties(ByteBuf input, int length) {\r
 310         final byte COMMON_PROPERTY_LENGTH = 4;\r
 311         List<TableFeatureProperties> properties = new ArrayList<>();\r
 312         int tableFeaturesLength = length;\r
 313         while (tableFeaturesLength > 0) {\r
 314             TableFeaturePropertiesBuilder builder = new TableFeaturePropertiesBuilder();\r
 315             TableFeaturesPropType type = TableFeaturesPropType.forValue(input.readUnsignedShort());\r
 316             builder.setType(type);\r
 317             int propertyLength = input.readUnsignedShort();\r
 318             tableFeaturesLength -= propertyLength;\r
 319             if (type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONS)\r
 320                     || type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONSMISS)) {\r
 321                 InstructionsDeserializer.createInstructions(input, propertyLength - COMMON_PROPERTY_LENGTH);\r
 322             } else if (type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLES)\r
 323                     || type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLESMISS)) {\r
 324                 propertyLength -= COMMON_PROPERTY_LENGTH;\r
 325                 NextTableRelatedTableFeaturePropertyBuilder tableBuilder = new NextTableRelatedTableFeaturePropertyBuilder();\r
 326                 List<NextTableIds> ids = new ArrayList<>();\r
 327                 while (propertyLength > 0) {\r
 328                     NextTableIdsBuilder nextTableIdsBuilder = new NextTableIdsBuilder();\r
 329                     nextTableIdsBuilder.setTableId(input.readUnsignedByte());\r
 330                     ids.add(nextTableIdsBuilder.build());\r
 331                 }\r
 332                 tableBuilder.setNextTableIds(ids);\r
 333                 builder.addAugmentation(NextTableRelatedTableFeatureProperty.class, tableBuilder.build());\r
 334                 properties.add(builder.build());\r
 335             } else if (type.equals(TableFeaturesPropType.OFPTFPTWRITEACTIONS)\r
 336                     || type.equals(TableFeaturesPropType.OFPTFPTWRITEACTIONSMISS)\r
 337                     || type.equals(TableFeaturesPropType.OFPTFPTAPPLYACTIONS)\r
 338                     || type.equals(TableFeaturesPropType.OFPTFPTAPPLYACTIONSMISS)) {\r
 339                 ActionsDeserializer.createActionsList(input, propertyLength - COMMON_PROPERTY_LENGTH);\r
 340             } else if (type.equals(TableFeaturesPropType.OFPTFPTMATCH)\r
 341                     || type.equals(TableFeaturesPropType.OFPTFPTWILDCARDS)\r
 342                     || type.equals(TableFeaturesPropType.OFPTFPTWRITESETFIELD)\r
 343                     || type.equals(TableFeaturesPropType.OFPTFPTWRITESETFIELDMISS)\r
 344                     || type.equals(TableFeaturesPropType.OFPTFPTAPPLYSETFIELD)\r
 345                     || type.equals(TableFeaturesPropType.OFPTFPTAPPLYSETFIELDMISS)) {\r
 346                 MatchEntriesDeserializer.createMatchEntries(input, propertyLength - COMMON_PROPERTY_LENGTH);\r
 347             } else if (type.equals(TableFeaturesPropType.OFPTFPTEXPERIMENTER)\r
 348                     || type.equals(TableFeaturesPropType.OFPTFPTEXPERIMENTERMISS)) {\r
 349                 final byte EXPERIMENTER_PROPERTY_LENGTH = 12;\r
 350                 ExperimenterRelatedTableFeaturePropertyBuilder expBuilder = new ExperimenterRelatedTableFeaturePropertyBuilder();\r
 351                 expBuilder.setExperimenter(input.readUnsignedInt());\r
 352                 expBuilder.setExpType(input.readUnsignedInt());\r
 353                 byte[] data = new byte[propertyLength - EXPERIMENTER_PROPERTY_LENGTH];\r
 354                 input.readBytes(data);\r
 355                 expBuilder.setData(data);\r
 356                 builder.addAugmentation(ExperimenterRelatedTableFeatureProperty.class, expBuilder.build());\r
 357                 properties.add(builder.build());\r
 358             }\r
 359         }\r
 360         return properties;\r
 361     }\r
 362     \r
 363     private static MultipartReplyPortStats setPortStats(ByteBuf input) {\r
 364         final byte PADDING_IN_PORT_STATS_HEADER = 4;\r
 365         MultipartReplyPortStatsBuilder builder = new MultipartReplyPortStatsBuilder();\r
 366         PortStatsBuilder portStatsBuilder = new PortStatsBuilder();\r
 367         List<PortStats> portStatsList = new ArrayList<>();\r
 368         while (input.readableBytes() > 0) {\r
 369             portStatsBuilder.setPortNo(input.readUnsignedInt());\r
 370             input.skipBytes(PADDING_IN_PORT_STATS_HEADER);\r
 371             \r
 372             byte[] rxPackets = new byte[Long.SIZE/Byte.SIZE];\r
 373             input.readBytes(rxPackets);\r
 374             portStatsBuilder.setRxPackets(new BigInteger(rxPackets));\r
 375             \r
 376             byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
 377             input.readBytes(txPackets);\r
 378             portStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
 379             \r
 380             byte[] rxBytes = new byte[Long.SIZE/Byte.SIZE];\r
 381             input.readBytes(rxBytes);\r
 382             portStatsBuilder.setRxBytes(new BigInteger(rxBytes));\r
 383             \r
 384             byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
 385             input.readBytes(txBytes);\r
 386             portStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
 387             \r
 388             byte[] rxDropped = new byte[Long.SIZE/Byte.SIZE];\r
 389             input.readBytes(rxDropped);\r
 390             portStatsBuilder.setRxDropped(new BigInteger(rxDropped));\r
 391             \r
 392             byte[] txDropped = new byte[Long.SIZE/Byte.SIZE];\r
 393             input.readBytes(txDropped);\r
 394             portStatsBuilder.setTxDropped(new BigInteger(txDropped));\r
 395             \r
 396             byte[] rxErrors = new byte[Long.SIZE/Byte.SIZE];\r
 397             input.readBytes(rxErrors);\r
 398             portStatsBuilder.setRxErrors(new BigInteger(rxErrors));\r
 399             \r
 400             byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
 401             input.readBytes(txErrors);\r
 402             portStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
 403             \r
 404             byte[] rxFrameErr = new byte[Long.SIZE/Byte.SIZE];\r
 405             input.readBytes(rxFrameErr);\r
 406             portStatsBuilder.setRxFrameErr(new BigInteger(rxFrameErr));\r
 407             \r
 408             byte[] rxOverErr = new byte[Long.SIZE/Byte.SIZE];\r
 409             input.readBytes(rxOverErr);\r
 410             portStatsBuilder.setRxOverErr(new BigInteger(rxOverErr));\r
 411             \r
 412             byte[] rxCrcErr = new byte[Long.SIZE/Byte.SIZE];\r
 413             input.readBytes(rxCrcErr);\r
 414             portStatsBuilder.setRxCrcErr(new BigInteger(rxCrcErr));\r
 415             \r
 416             byte[] collisions = new byte[Long.SIZE/Byte.SIZE];\r
 417             input.readBytes(collisions);\r
 418             portStatsBuilder.setCollisions(new BigInteger(collisions));\r
 419             \r
 420             portStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 421             portStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 422             portStatsList.add(portStatsBuilder.build());\r
 423         }\r
 424         builder.setPortStats(new ArrayList<>(portStatsList));\r
 425         portStatsList.clear();\r
 426         return builder.build();\r
 427     }\r
 428     \r
 429     private static MultipartReplyQueue setQueue(ByteBuf input) {\r
 430         MultipartReplyQueueBuilder builder = new MultipartReplyQueueBuilder();\r
 431         QueueStatsBuilder queueStatsBuilder = new QueueStatsBuilder();\r
 432         List<QueueStats> queueStatsList = new ArrayList<>();\r
 433         \r
 434         while (input.readableBytes() > 0) {\r
 435             queueStatsBuilder.setPortNo(input.readUnsignedInt());\r
 436             queueStatsBuilder.setQueueId(input.readUnsignedInt());\r
 437 \r
 438             byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
 439             input.readBytes(txBytes);\r
 440             queueStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
 441 \r
 442             byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
 443             input.readBytes(txPackets);\r
 444             queueStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
 445 \r
 446             byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
 447             input.readBytes(txErrors);\r
 448             queueStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
 449 \r
 450             queueStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 451             queueStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 452             queueStatsList.add(queueStatsBuilder.build());\r
 453         }\r
 454         builder.setQueueStats(new ArrayList<>(queueStatsList));\r
 455         queueStatsList.clear();\r
 456         return builder.build();\r
 457     }\r
 458     \r
 459     private static MultipartReplyGroup setGroup(ByteBuf input) {\r
 460         final byte PADDING_IN_GROUP_HEADER_01 = 2;\r
 461         final byte PADDING_IN_GROUP_HEADER_02 = 4;\r
 462         final byte BUCKET_COUNTER_LENGTH = 16;\r
 463         final byte GROUP_BODY_LENGTH = 40;\r
 464         int actualLength;\r
 465         MultipartReplyGroupBuilder builder = new MultipartReplyGroupBuilder();\r
 466         GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();\r
 467         List<GroupStats> groupStatsList = new ArrayList<>();\r
 468         \r
 469         BucketStatsBuilder bucketStatsBuilder = new BucketStatsBuilder();\r
 470         List<BucketStats> bucketStatsList = new ArrayList<>();\r
 471         \r
 472         while (input.readableBytes() > 0) {\r
 473             int bodyLength = input.readUnsignedShort();\r
 474             actualLength = 0;\r
 475             \r
 476             input.skipBytes(PADDING_IN_GROUP_HEADER_01);\r
 477             groupStatsBuilder.setGroupId(input.readUnsignedInt());\r
 478             groupStatsBuilder.setRefCount(input.readUnsignedInt());\r
 479             input.skipBytes(PADDING_IN_GROUP_HEADER_02);\r
 480             byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 481             input.readBytes(packetCount);\r
 482             groupStatsBuilder.setPacketCount(new BigInteger(packetCount));\r
 483             byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 484             input.readBytes(byteCount);\r
 485             groupStatsBuilder.setByteCount(new BigInteger(byteCount));\r
 486             groupStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 487             groupStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 488             actualLength = GROUP_BODY_LENGTH;\r
 489             \r
 490             while (actualLength < bodyLength) {\r
 491                 byte[] packetCountBucket = new byte[Long.SIZE/Byte.SIZE];\r
 492                 input.readBytes(packetCountBucket);\r
 493                 bucketStatsBuilder.setPacketCount(new BigInteger(packetCountBucket));\r
 494                 byte[] byteCountBucket = new byte[Long.SIZE/Byte.SIZE];\r
 495                 input.readBytes(byteCountBucket);\r
 496                 bucketStatsBuilder.setByteCount(new BigInteger(byteCountBucket));\r
 497                 bucketStatsList.add(bucketStatsBuilder.build());\r
 498 \r
 499                 actualLength = actualLength + BUCKET_COUNTER_LENGTH;\r
 500             } \r
 501             groupStatsBuilder.setBucketStats(new ArrayList<>(bucketStatsList));\r
 502             bucketStatsList.clear();\r
 503             groupStatsList.add(groupStatsBuilder.build());\r
 504         }\r
 505         builder.setGroupStats(new ArrayList<>(groupStatsList));\r
 506         groupStatsList.clear();\r
 507         return builder.build();\r
 508     }\r
 509     \r
 510     private static MultipartReplyMeterFeatures setMeterFeatures(ByteBuf input) {\r
 511         final byte PADDING_IN_METER_FEATURES_HEADER = 2;\r
 512         MultipartReplyMeterFeaturesBuilder builder = new MultipartReplyMeterFeaturesBuilder();\r
 513         builder.setMaxMeter(input.readUnsignedInt());\r
 514         builder.setBandTypes(MeterBandType.forValue(input.readInt()));\r
 515         builder.setCapabilities(decodeMeterModFlags((int) input.readUnsignedInt()));\r
 516         builder.setMaxBands(input.readUnsignedByte());\r
 517         builder.setMaxColor(input.readUnsignedByte());\r
 518         input.skipBytes(PADDING_IN_METER_FEATURES_HEADER);\r
 519         return builder.build();\r
 520     }\r
 521     \r
 522     private static MeterFlags decodeMeterModFlags(int input){\r
 523         final Boolean _oFPMFKBPS = (input & (1 << 0)) != 0;\r
 524         final Boolean _oFPMFPKTPS = (input & (1 << 1)) != 0;\r
 525         final Boolean _oFPMFBURST = (input & (1 << 2)) != 0; \r
 526         final Boolean _oFPMFSTATS = (input & (1 << 3)) != 0;\r
 527         return new MeterFlags(_oFPMFBURST, _oFPMFKBPS, _oFPMFPKTPS, _oFPMFSTATS);\r
 528     }\r
 529     \r
 530     private static MultipartReplyMeter setMeter(ByteBuf input) {\r
 531         final byte PADDING_IN_METER_STATS_HEADER = 6;\r
 532         final byte METER_BAND_STATS_LENGTH = 16;\r
 533         final byte METER_BODY_LENGTH = 40;\r
 534         int actualLength;\r
 535         MultipartReplyMeterBuilder builder = new MultipartReplyMeterBuilder();\r
 536         List<MeterStats> meterStatsList = new ArrayList<>();\r
 537         MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();\r
 538         List<MeterBandStats> meterBandStatsList = new ArrayList<>();\r
 539         MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();\r
 540         while (input.readableBytes() > 0) {\r
 541             meterStatsBuilder.setMeterId(input.readUnsignedInt());\r
 542             actualLength = 0;\r
 543             int meterStatsBodyLength = input.readUnsignedShort();\r
 544             input.skipBytes(PADDING_IN_METER_STATS_HEADER);\r
 545             meterStatsBuilder.setFlowCount(input.readUnsignedInt());\r
 546             byte[] packetInCount = new byte[Long.SIZE/Byte.SIZE];\r
 547             input.readBytes(packetInCount);\r
 548             meterStatsBuilder.setPacketInCount(new BigInteger(packetInCount));\r
 549             byte[] byteInCount = new byte[Long.SIZE/Byte.SIZE];\r
 550             input.readBytes(byteInCount);\r
 551             meterStatsBuilder.setByteInCount(new BigInteger(byteInCount));\r
 552             meterStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 553             meterStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 554             actualLength = METER_BODY_LENGTH;\r
 555             \r
 556             while (actualLength < meterStatsBodyLength) {\r
 557                 byte[] packetBandCount = new byte[Long.SIZE/Byte.SIZE];\r
 558                 input.readBytes(packetBandCount);\r
 559                 meterBandStatsBuilder.setPacketBandCount(new BigInteger(packetBandCount));\r
 560                 byte[] byteBandCount = new byte[Long.SIZE/Byte.SIZE];\r
 561                 input.readBytes(byteBandCount);\r
 562                 meterBandStatsBuilder.setByteBandCount(new BigInteger(byteBandCount));\r
 563                 \r
 564                 meterBandStatsList.add(meterBandStatsBuilder.build());\r
 565                 actualLength = actualLength + METER_BAND_STATS_LENGTH;\r
 566             }\r
 567         \r
 568             meterStatsBuilder.setMeterBandStats(new ArrayList<>(meterBandStatsList));\r
 569             meterBandStatsList.clear();\r
 570             meterStatsList.add(meterStatsBuilder.build());\r
 571         }\r
 572         builder.setMeterStats(new ArrayList<>(meterStatsList));\r
 573         meterStatsList.clear();\r
 574         return builder.build();\r
 575     }\r
 576     \r
 577     private static MultipartReplyMeterConfig setMeterConfig(ByteBuf input) {\r
 578         final byte METER_BAND_LENGTH = 16;\r
 579         final byte METER_CONFIG_LENGTH = 8;\r
 580         final byte bandLength = 2;\r
 581         int actualLength;\r
 582         MultipartReplyMeterConfigBuilder builder = new MultipartReplyMeterConfigBuilder();\r
 583         List<MeterConfig> meterConfigList = new ArrayList<>();\r
 584         MeterConfigBuilder meterConfigBuilder = new MeterConfigBuilder();\r
 585         List<Bands> bandsList = new ArrayList<>();\r
 586         BandsBuilder bandsBuilder = new BandsBuilder();\r
 587         \r
 588         while (input.readableBytes() > 0) {\r
 589             int meterConfigBodyLength = input.readUnsignedShort();\r
 590             actualLength = 0;\r
 591             meterConfigBuilder.setFlags(MeterModCommand.forValue(input.readUnsignedShort()));\r
 592             meterConfigBuilder.setMeterId(input.readUnsignedInt());\r
 593             actualLength = METER_CONFIG_LENGTH;\r
 594             \r
 595             while (actualLength < meterConfigBodyLength) {\r
 596                 MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();\r
 597                 final byte PADDING_IN_METER_BAND_DROP_HEADER = 4;\r
 598                 MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();\r
 599                 final byte PADDING_IN_METER_BAND_DSCP_HEADER = 3;\r
 600                 MeterBandExperimenterBuilder bandExperimenterBuilder = new MeterBandExperimenterBuilder(); \r
 601                 int bandType = input.readUnsignedShort();\r
 602                 switch (bandType) {\r
 603                     case 1: bandDropBuilder.setType(MeterBandType.forValue(bandType));\r
 604                             input.skipBytes(bandLength);\r
 605                             bandDropBuilder.setRate(input.readUnsignedInt());\r
 606                             bandDropBuilder.setBurstSize(input.readUnsignedInt());\r
 607                             input.skipBytes(PADDING_IN_METER_BAND_DROP_HEADER);\r
 608                             bandsBuilder.setMeterBand(bandDropBuilder.build());\r
 609                             break;\r
 610                     case 2: bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));\r
 611                             input.skipBytes(bandLength);\r
 612                             bandDscpRemarkBuilder.setRate(input.readUnsignedInt());\r
 613                             bandDscpRemarkBuilder.setBurstSize(input.readUnsignedInt());\r
 614                             bandDscpRemarkBuilder.setPrecLevel(input.readUnsignedByte());\r
 615                             input.skipBytes(PADDING_IN_METER_BAND_DSCP_HEADER);\r
 616                             bandsBuilder.setMeterBand(bandDscpRemarkBuilder.build());\r
 617                             break;\r
 618                     case 0xFFFF: bandExperimenterBuilder.setType(MeterBandType.forValue(bandType));\r
 619                                  input.skipBytes(bandLength);\r
 620                                  bandExperimenterBuilder.setRate(input.readUnsignedInt());\r
 621                                  bandExperimenterBuilder.setBurstSize(input.readUnsignedInt());\r
 622                                  bandExperimenterBuilder.setExperimenter(input.readUnsignedInt());\r
 623                                  bandsBuilder.setMeterBand(bandExperimenterBuilder.build());\r
 624                                  break;\r
 625                     default: break;\r
 626                 }\r
 627                 bandsList.add(bandsBuilder.build());\r
 628                 actualLength = actualLength + METER_BAND_LENGTH;\r
 629             }\r
 630             meterConfigBuilder.setBands(new ArrayList<>(bandsList));\r
 631             bandsList.clear();\r
 632             meterConfigList.add(meterConfigBuilder.build());\r
 633         }\r
 634         builder.setMeterConfig(new ArrayList<>(meterConfigList));\r
 635         meterConfigList.clear();\r
 636         return builder.build();\r
 637     }\r
 638     \r
 639     private static MultipartReplyExperimenter setExperimenter(ByteBuf input) {\r
 640         MultipartReplyExperimenterBuilder builder = new MultipartReplyExperimenterBuilder();\r
 641         builder.setExperimenter(input.readUnsignedInt());\r
 642         builder.setExpType(input.readUnsignedInt());\r
 643         byte[] data = new byte[Long.SIZE/Byte.SIZE];\r
 644         input.readBytes(data);\r
 645         builder.setData(data);\r
 646         return builder.build();\r
 647     }\r
 648     \r
 649     private static MultipartReplyPortDesc setPortDesc(ByteBuf input) {\r
 650         final byte PADDING_IN_PORT_DESC_HEADER_01 = 4;\r
 651         final byte PADDING_IN_PORT_DESC_HEADER_02 = 2;\r
 652         final int macAddressLength = 6;\r
 653         final byte MAX_PORT_NAME_LEN = 16;\r
 654         MultipartReplyPortDescBuilder builder = new MultipartReplyPortDescBuilder();\r
 655         List<Ports> portsList = new ArrayList<>();\r
 656         PortsBuilder portsBuilder = new PortsBuilder();\r
 657         \r
 658         while (input.readableBytes() > 0) {\r
 659             portsBuilder.setPortNo(input.readUnsignedInt());\r
 660             input.skipBytes(PADDING_IN_PORT_DESC_HEADER_01);\r
 661             StringBuffer macToString = new StringBuffer();\r
 662             for(int i=0; i<macAddressLength; i++){\r
 663                 short mac = 0;\r
 664                 mac = input.readUnsignedByte();\r
 665                 macToString.append(String.format("%02X", mac));\r
 666             }\r
 667             portsBuilder.setHwAddr(new MacAddress(macToString.toString()));\r
 668             input.skipBytes(PADDING_IN_PORT_DESC_HEADER_02);\r
 669             \r
 670             byte[] portNameBytes = new byte[MAX_PORT_NAME_LEN];\r
 671             input.readBytes(portNameBytes);\r
 672             String portName = new String(portNameBytes);\r
 673             portsBuilder.setName(portName.trim());\r
 674             \r
 675             portsBuilder.setConfig(createPortConfig(input.readUnsignedInt()));\r
 676             portsBuilder.setState(createPortState(input.readUnsignedInt()));\r
 677             portsBuilder.setCurrentFeatures(createPortFeatures(input.readUnsignedInt()));\r
 678             portsBuilder.setAdvertisedFeatures(createPortFeatures(input.readUnsignedInt()));\r
 679             portsBuilder.setSupportedFeatures(createPortFeatures(input.readUnsignedInt()));\r
 680             portsBuilder.setPeerFeatures(createPortFeatures(input.readUnsignedInt()));\r
 681             portsBuilder.setCurrSpeed(input.readUnsignedInt());\r
 682             portsBuilder.setMaxSpeed(input.readUnsignedInt());\r
 683             portsList.add(portsBuilder.build());\r
 684         }\r
 685         \r
 686         builder.setPorts(new ArrayList<>(portsList));\r
 687         portsList.clear();\r
 688         return builder.build();\r
 689     }\r
 690     \r
 691     private static PortConfig createPortConfig(long input){\r
 692         final Boolean _portDown   = ((input) & (1<<0)) != 0;\r
 693         final Boolean _noRecv    = ((input) & (1<<2)) != 0;\r
 694         final Boolean _noFwd       = ((input) & (1<<5)) != 0;\r
 695         final Boolean _noPacketIn = ((input) & (1<<6)) != 0;\r
 696         return new PortConfig(_noFwd, _noPacketIn, _noRecv, _portDown);\r
 697     }\r
 698     \r
 699     private static PortState createPortState(long input){\r
 700         final Boolean _linkDown = ((input) & (1<<0)) != 0;\r
 701         final Boolean _blocked  = ((input) & (1<<1)) != 0;\r
 702         final Boolean _live     = ((input) & (1<<2)) != 0;\r
 703         return new PortState(_linkDown, _blocked,_live);\r
 704     }\r
 705     \r
 706     private static PortFeatures createPortFeatures(long input){\r
 707         final Boolean _10mbHd = ((input) & (1<<0)) != 0;\r
 708         final Boolean _10mbFd = ((input) & (1<<1)) != 0;\r
 709         final Boolean _100mbHd = ((input) & (1<<2)) != 0;\r
 710         final Boolean _100mbFd = ((input) & (1<<3)) != 0;\r
 711         final Boolean _1gbHd = ((input) & (1<<4)) != 0;\r
 712         final Boolean _1gbFd = ((input) & (1<<5)) != 0;\r
 713         final Boolean _10gbFd = ((input) & (1<<6)) != 0;\r
 714         final Boolean _40gbFd = ((input) & (1<<7)) != 0;\r
 715         final Boolean _100gbFd = ((input) & (1<<8)) != 0;\r
 716         final Boolean _1tbFd = ((input) & (1<<9)) != 0;\r
 717         final Boolean _other = ((input) & (1<<10)) != 0;\r
 718         final Boolean _copper = ((input) & (1<<11)) != 0;\r
 719         final Boolean _fiber = ((input) & (1<<12)) != 0;\r
 720         final Boolean _autoneg = ((input) & (1<<13)) != 0;\r
 721         final Boolean _pause = ((input) & (1<<14)) != 0;\r
 722         final Boolean _pauseAsym = ((input) & (1<<15)) != 0;\r
 723         return new PortFeatures(_10mbHd, _10mbFd, _100mbHd, _100mbFd, _1gbHd, _1gbFd, _10gbFd,\r
 724                 _40gbFd, _100gbFd, _1tbFd, _other, _copper, _fiber, _autoneg, _pause, _pauseAsym);\r
 725     }\r
 726     \r
 727     private static MultipartReplyBody setGroupFeatures(ByteBuf rawMessage) {\r
 728         final int SIZE_OF_MAX_GROUPS = 4;\r
 729         MultipartReplyGroupFeaturesBuilder featuresBuilder = new MultipartReplyGroupFeaturesBuilder();\r
 730         featuresBuilder.setTypes(createGroupType(rawMessage.readUnsignedInt()));\r
 731         featuresBuilder.setCapabilities(createCapabilities(rawMessage.readUnsignedInt()));\r
 732         List<Long> maxGroupsList = new ArrayList<>();\r
 733         for (int i = 0; i < SIZE_OF_MAX_GROUPS ; i++) {\r
 734             maxGroupsList.add(rawMessage.readUnsignedInt());\r
 735         }\r
 736         featuresBuilder.setMaxGroups(maxGroupsList);\r
 737         // TODO - groupfeatures - actions bitmap\r
 738         rawMessage.skipBytes(4);\r
 739         return featuresBuilder.build();\r
 740     }\r
 741 \r
 742     private static GroupCapabilities createCapabilities(long input) {\r
 743         final Boolean OFOFPGFC_SELECT_WEIGHT = ((input) & (1<<0)) != 0;\r
 744         final Boolean OFPGFC_SELECT_LIVENESS = ((input) & (1<<1)) != 0;\r
 745         final Boolean OFPGFC_CHAINING = ((input) & (1<<2)) != 0;\r
 746         final Boolean OFPGFC_CHAINING_CHECKS = ((input) & (1<<3)) != 0;\r
 747         return new GroupCapabilities(OFPGFC_CHAINING, OFPGFC_CHAINING_CHECKS, OFPGFC_SELECT_LIVENESS, OFOFPGFC_SELECT_WEIGHT);\r
 748     }\r
 749 \r
 750     private static GroupTypes createGroupType(long input) {\r
 751         final Boolean OFPGT_ALL = ((input) & (1<<0)) != 0;\r
 752         final Boolean OFPGT_SELECT = ((input) & (1<<1)) != 0;\r
 753         final Boolean OFPGT_INDIRECT = ((input) & (1<<2)) != 0;\r
 754         final Boolean OFPGT_FF = ((input) & (1<<3)) != 0;\r
 755         return new GroupTypes(OFPGT_ALL, OFPGT_FF, OFPGT_INDIRECT, OFPGT_SELECT);\r
 756     }\r
 757     \r
 758     private static MultipartReplyGroupDesc setGroupDesc(ByteBuf input) {\r
 759         final byte PADDING_IN_GROUP_DESC_HEADER = 1;\r
 760         final byte PADDING_IN_BUCKETS_HEADER = 4;\r
 761         final byte GROUP_DESC_HEADER_LENGTH = 8;\r
 762         int actualLength;\r
 763         int bucketsLength = 0;\r
 764         int bucketsCurrentLength = 0;\r
 765         int bodyLength = 0;\r
 766         MultipartReplyGroupDescBuilder builder = new MultipartReplyGroupDescBuilder();\r
 767         GroupDescBuilder groupDescBuilder = new GroupDescBuilder();\r
 768         List<GroupDesc> groupDescsList = new ArrayList<>();\r
 769         BucketsListBuilder bucketsBuilder = new BucketsListBuilder();\r
 770         List<BucketsList> bucketsList = new ArrayList<>();\r
 771         List<ActionsList> actionsList = new ArrayList<>();\r
 772         \r
 773         while (input.readableBytes() > 0) {\r
 774             bodyLength = input.readUnsignedShort();\r
 775             actualLength = 0;\r
 776             \r
 777             groupDescBuilder.setType(GroupType.forValue(input.readUnsignedByte())); // TODO enum or class?\r
 778             input.skipBytes(PADDING_IN_GROUP_DESC_HEADER);\r
 779             groupDescBuilder.setGroupId(input.readUnsignedInt());\r
 780             actualLength = GROUP_DESC_HEADER_LENGTH;\r
 781             \r
 782             while (actualLength < bodyLength) {\r
 783                 \r
 784                 bucketsLength = input.readUnsignedShort();\r
 785                 bucketsBuilder.setWeight(input.readUnsignedShort());\r
 786                 bucketsBuilder.setWatchPort(new PortNumber(input.readUnsignedInt()));\r
 787                 bucketsBuilder.setWatchGroup(input.readUnsignedInt());\r
 788                 input.skipBytes(PADDING_IN_BUCKETS_HEADER);\r
 789                 bucketsCurrentLength = bucketsLength;\r
 790                 actionsList = ActionsDeserializer.createActionsList(input, bucketsLength);\r
 791                 bucketsBuilder.setActionsList(new ArrayList<>(actionsList));\r
 792                 actionsList.clear();\r
 793                 bucketsList.add(bucketsBuilder.build());\r
 794                 actualLength = actualLength + bucketsCurrentLength;\r
 795             }\r
 796             groupDescBuilder.setBucketsList(new ArrayList<>(bucketsList));\r
 797             bucketsList.clear();\r
 798             groupDescsList.add(groupDescBuilder.build());\r
 799         }\r
 800         builder.setGroupDesc(new ArrayList<>(groupDescsList));\r
 801         groupDescsList.clear();\r
 802         return builder.build();\r
 803     }\r
 804     \r
 805 }\r