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