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