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