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.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterBandType;\r
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterModCommand;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortState;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;\r
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessageBuilder;\r
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDropBuilder;\r
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemarkBuilder;\r
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterBuilder;\r
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregate;\r
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateBuilder;\r
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDesc;\r
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDescBuilder;\r
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;\r
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenterBuilder;\r
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlow;\r
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowBuilder;\r
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroup;\r
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupBuilder;\r
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeter;\r
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterBuilder;\r
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfig;\r
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterConfigBuilder;\r
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeatures;\r
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyMeterFeaturesBuilder;\r
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDesc;\r
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortDescBuilder;\r
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStats;\r
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsBuilder;\r
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueue;\r
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueueBuilder;\r
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTable;\r
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableBuilder;\r
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStats;\r
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStatsBuilder;\r
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.GroupStats;\r
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.GroupStatsBuilder;\r
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStats;\r
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group.group.stats.BucketStatsBuilder;\r
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStats;\r
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.MeterStatsBuilder;\r
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfig;\r
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.MeterConfigBuilder;\r
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.Bands;\r
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config.meter.config.BandsBuilder;\r
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStats;\r
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.meter.stats.MeterBandStatsBuilder;\r
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.Ports;\r
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.desc.PortsBuilder;\r
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStats;\r
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStatsBuilder;\r
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStats;\r
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStatsBuilder;\r
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStats;\r
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStatsBuilder;\r
  72 \r
  73 /**\r
  74  * @author timotej.kubas\r
  75  * @author michal.polkorab\r
  76  */\r
  77 public class MultipartReplyMessageFactory implements OFDeserializer<MultipartReplyMessage> {\r
  78 \r
  79     private static MultipartReplyMessageFactory instance;\r
  80     private static final byte PADDING_IN_MULTIPART_REPLY_HEADER = 4;\r
  81     \r
  82     private MultipartReplyMessageFactory() {\r
  83         // singleton\r
  84     }\r
  85     \r
  86     /**\r
  87      * @return singleton factory\r
  88      */\r
  89     public static synchronized MultipartReplyMessageFactory getInstance() {\r
  90         if (instance == null){\r
  91             instance = new MultipartReplyMessageFactory();\r
  92         }\r
  93         return instance;\r
  94     }\r
  95 \r
  96     @Override\r
  97     public MultipartReplyMessage bufferToMessage(ByteBuf rawMessage, short version) {\r
  98         MultipartReplyMessageBuilder builder = new MultipartReplyMessageBuilder();\r
  99         builder.setVersion(version);\r
 100         builder.setXid(rawMessage.readUnsignedInt());\r
 101         builder.setType(MultipartType.forValue(rawMessage.readUnsignedShort()));\r
 102         builder.setFlags(new MultipartRequestFlags((rawMessage.readUnsignedShort() & 0x01) != 0));\r
 103         rawMessage.skipBytes(PADDING_IN_MULTIPART_REPLY_HEADER);\r
 104         // TODO - implement body\r
 105         //mrmb.setBody(rawMessage.readBytes(rawMessage.readableBytes()).array());\r
 106 \r
 107         switch (builder.getType().getIntValue()) {\r
 108         case 0:  builder.setMultipartReplyBody(setDesc(rawMessage));\r
 109                  break;\r
 110         case 1:  builder.setMultipartReplyBody(setFlow(rawMessage));\r
 111                  break;\r
 112         case 2:  builder.setMultipartReplyBody(setAggregate(rawMessage));\r
 113                  break;\r
 114         case 3:  builder.setMultipartReplyBody(setTable(rawMessage));\r
 115                  break;         \r
 116         case 4:  builder.setMultipartReplyBody(setPortStats(rawMessage));\r
 117                  break;\r
 118         case 5:  builder.setMultipartReplyBody(setQueue(rawMessage));\r
 119                  break;         \r
 120         case 6:  builder.setMultipartReplyBody(setGroup(rawMessage));\r
 121                  break;\r
 122         case 9:  builder.setMultipartReplyBody(setMeter(rawMessage));\r
 123                  break;\r
 124         case 10:  builder.setMultipartReplyBody(setMeterConfig(rawMessage));\r
 125                  break;\r
 126         case 11: builder.setMultipartReplyBody(setMeterFeatures(rawMessage));\r
 127                  break;\r
 128         case 13: builder.setMultipartReplyBody(setPortDesc(rawMessage));\r
 129                  break;\r
 130         case 0xFFFF: builder.setMultipartReplyBody(setExperimenter(rawMessage));\r
 131                  break;\r
 132         default: \r
 133                  break;\r
 134         }\r
 135         \r
 136         return builder.build();\r
 137     }\r
 138     \r
 139     private static MultipartReplyDesc setDesc(ByteBuf input) {\r
 140         final int DESC_STR_LEN = 256;\r
 141         final int SERIAL_NUM_LEN = 32;\r
 142         MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();\r
 143         byte[] mfrDescBytes = new byte[DESC_STR_LEN];\r
 144         input.readBytes(mfrDescBytes);\r
 145         String mfrDesc = new String(mfrDescBytes);\r
 146         descBuilder.setMfrDesc(mfrDesc.trim());\r
 147         byte[] hwDescBytes = new byte[DESC_STR_LEN];\r
 148         input.readBytes(hwDescBytes);\r
 149         String hwDesc = new String(hwDescBytes);\r
 150         descBuilder.setHwDesc(hwDesc.trim());\r
 151         byte[] swDescBytes = new byte[DESC_STR_LEN];\r
 152         input.readBytes(swDescBytes);\r
 153         String swDesc = new String(swDescBytes);\r
 154         descBuilder.setSwDesc(swDesc.trim());\r
 155         byte[] serialNumBytes = new byte[SERIAL_NUM_LEN];\r
 156         input.readBytes(serialNumBytes);\r
 157         String serialNum = new String(serialNumBytes);\r
 158         descBuilder.setSerialNum(serialNum.trim());\r
 159         byte[] dpDescBytes = new byte[DESC_STR_LEN];\r
 160         input.readBytes(dpDescBytes);\r
 161         String dpDesc = new String(dpDescBytes);\r
 162         descBuilder.setDpDesc(dpDesc.trim());\r
 163         return descBuilder.build();\r
 164     }\r
 165     \r
 166     private static MultipartReplyFlow setFlow(ByteBuf input) {\r
 167         final byte PADDING_IN_FLOW_STATS_HEADER_01 = 1;\r
 168         final byte PADDING_IN_FLOW_STATS_HEADER_02 = 4;\r
 169         MultipartReplyFlowBuilder flowBuilder = new MultipartReplyFlowBuilder();\r
 170         List<FlowStats> flowStatsList = new ArrayList<>();\r
 171         FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();\r
 172         int flowLen = 0;\r
 173         while (input.readableBytes() > 0) {\r
 174             flowLen = input.readUnsignedShort();\r
 175             flowStatsBuilder.setTableId(input.readUnsignedByte());\r
 176             input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_01);\r
 177             flowStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 178             flowStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 179             flowStatsBuilder.setPriority(input.readUnsignedShort());\r
 180             flowStatsBuilder.setIdleTimeout(input.readUnsignedShort());\r
 181             flowStatsBuilder.setHardTimeout(input.readUnsignedShort());\r
 182             flowStatsBuilder.setFlags(createFlowModFalgsFromBitmap(input.readShort()));\r
 183             input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_02);\r
 184             byte[] cookie = new byte[Long.SIZE/Byte.SIZE];\r
 185             input.readBytes(cookie);\r
 186             flowStatsBuilder.setCookie(new BigInteger(cookie));\r
 187             byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 188             input.readBytes(packetCount);\r
 189             flowStatsBuilder.setPacketCount(new BigInteger(packetCount));\r
 190             byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 191             input.readBytes(byteCount);\r
 192             flowStatsBuilder.setByteCount(new BigInteger(byteCount));\r
 193             // TODO match\r
 194             // TODO instructions\r
 195             flowStatsList.add(flowStatsBuilder.build());\r
 196         }\r
 197         flowBuilder.setFlowStats(new ArrayList<>(flowStatsList));\r
 198         flowStatsList.clear();\r
 199         return flowBuilder.build();\r
 200     }\r
 201     \r
 202     private static FlowModFlags createFlowModFalgsFromBitmap(short input){\r
 203         final Boolean _oFPFFSENDFLOWREM = (input & (1 << 0)) > 0;\r
 204         final Boolean _oFPFFCHECKOVERLAP = (input & (1 << 1)) > 0;\r
 205         final Boolean _oFPFFRESETCOUNTS = (input & (1 << 2)) > 0; \r
 206         final Boolean _oFPFFNOPKTCOUNTS = (input & (1 << 3)) > 0;\r
 207         final Boolean _oFPFFNOBYTCOUNTS = (input & (1 << 4)) > 0;\r
 208         return new FlowModFlags(_oFPFFCHECKOVERLAP, _oFPFFNOBYTCOUNTS, _oFPFFNOPKTCOUNTS, _oFPFFRESETCOUNTS, _oFPFFSENDFLOWREM);\r
 209     }\r
 210     \r
 211     private static MultipartReplyAggregate setAggregate(ByteBuf input) {\r
 212         final byte PADDING_IN_AGGREGATE_HEADER = 4;\r
 213         MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();\r
 214         byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 215         input.readBytes(packetCount);\r
 216         builder.setPacketCount(new BigInteger(packetCount));\r
 217         byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 218         input.readBytes(byteCount);\r
 219         builder.setByteCount(new BigInteger(byteCount));\r
 220         builder.setFlowCount(input.readUnsignedInt());\r
 221         input.skipBytes(PADDING_IN_AGGREGATE_HEADER);\r
 222         return builder.build();\r
 223     }\r
 224     \r
 225     private static MultipartReplyTable setTable(ByteBuf input) {\r
 226         final byte PADDING_IN_TABLE_HEADER = 3;\r
 227         MultipartReplyTableBuilder builder = new MultipartReplyTableBuilder();\r
 228         TableStatsBuilder tableStatsBuilder = new TableStatsBuilder();\r
 229         List<TableStats> tableStatsList = new ArrayList<>();\r
 230         while (input.readableBytes() > 0) {\r
 231             tableStatsBuilder.setTableId(input.readUnsignedByte());\r
 232             input.skipBytes(PADDING_IN_TABLE_HEADER);\r
 233             tableStatsBuilder.setActiveCount(input.readUnsignedInt());\r
 234             byte[] lookupCount = new byte[Long.SIZE/Byte.SIZE];\r
 235             input.readBytes(lookupCount);\r
 236             tableStatsBuilder.setLookupCount(new BigInteger(lookupCount));\r
 237             byte[] matchedCount = new byte[Long.SIZE/Byte.SIZE];\r
 238             input.readBytes(matchedCount);\r
 239             tableStatsBuilder.setMatchedCount(new BigInteger(matchedCount));\r
 240             tableStatsList.add(tableStatsBuilder.build());\r
 241         }\r
 242         builder.setTableStats(new ArrayList<>(tableStatsList));\r
 243         tableStatsList.clear();\r
 244         return builder.build();\r
 245     }\r
 246     \r
 247     private static MultipartReplyPortStats setPortStats(ByteBuf input) {\r
 248         final byte PADDING_IN_PORT_STATS_HEADER = 4;\r
 249         MultipartReplyPortStatsBuilder builder = new MultipartReplyPortStatsBuilder();\r
 250         PortStatsBuilder portStatsBuilder = new PortStatsBuilder();\r
 251         List<PortStats> portStatsList = new ArrayList<>();\r
 252         while (input.readableBytes() > 0) {\r
 253             portStatsBuilder.setPortNo(input.readUnsignedInt());\r
 254             input.skipBytes(PADDING_IN_PORT_STATS_HEADER);\r
 255             \r
 256             byte[] rxPackets = new byte[Long.SIZE/Byte.SIZE];\r
 257             input.readBytes(rxPackets);\r
 258             portStatsBuilder.setRxPackets(new BigInteger(rxPackets));\r
 259             \r
 260             byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
 261             input.readBytes(txPackets);\r
 262             portStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
 263             \r
 264             byte[] rxBytes = new byte[Long.SIZE/Byte.SIZE];\r
 265             input.readBytes(rxBytes);\r
 266             portStatsBuilder.setRxBytes(new BigInteger(rxBytes));\r
 267             \r
 268             byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
 269             input.readBytes(txBytes);\r
 270             portStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
 271             \r
 272             byte[] rxDropped = new byte[Long.SIZE/Byte.SIZE];\r
 273             input.readBytes(rxDropped);\r
 274             portStatsBuilder.setRxDropped(new BigInteger(rxDropped));\r
 275             \r
 276             byte[] txDropped = new byte[Long.SIZE/Byte.SIZE];\r
 277             input.readBytes(txDropped);\r
 278             portStatsBuilder.setTxDropped(new BigInteger(txDropped));\r
 279             \r
 280             byte[] rxErrors = new byte[Long.SIZE/Byte.SIZE];\r
 281             input.readBytes(rxErrors);\r
 282             portStatsBuilder.setRxErrors(new BigInteger(rxErrors));\r
 283             \r
 284             byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
 285             input.readBytes(txErrors);\r
 286             portStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
 287             \r
 288             byte[] rxFrameErr = new byte[Long.SIZE/Byte.SIZE];\r
 289             input.readBytes(rxFrameErr);\r
 290             portStatsBuilder.setRxFrameErr(new BigInteger(rxFrameErr));\r
 291             \r
 292             byte[] rxOverErr = new byte[Long.SIZE/Byte.SIZE];\r
 293             input.readBytes(rxOverErr);\r
 294             portStatsBuilder.setRxOverErr(new BigInteger(rxOverErr));\r
 295             \r
 296             byte[] rxCrcErr = new byte[Long.SIZE/Byte.SIZE];\r
 297             input.readBytes(rxCrcErr);\r
 298             portStatsBuilder.setRxCrcErr(new BigInteger(rxCrcErr));\r
 299             \r
 300             byte[] collisions = new byte[Long.SIZE/Byte.SIZE];\r
 301             input.readBytes(collisions);\r
 302             portStatsBuilder.setCollisions(new BigInteger(collisions));\r
 303             \r
 304             portStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 305             portStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 306             portStatsList.add(portStatsBuilder.build());\r
 307         }\r
 308         builder.setPortStats(new ArrayList<>(portStatsList));\r
 309         portStatsList.clear();\r
 310         return builder.build();\r
 311     }\r
 312     \r
 313     private static MultipartReplyQueue setQueue(ByteBuf input) {\r
 314         MultipartReplyQueueBuilder builder = new MultipartReplyQueueBuilder();\r
 315         QueueStatsBuilder queueStatsBuilder = new QueueStatsBuilder();\r
 316         List<QueueStats> queueStatsList = new ArrayList<>();\r
 317         \r
 318         while (input.readableBytes() > 0) {\r
 319             queueStatsBuilder.setPortNo(input.readUnsignedInt());\r
 320             queueStatsBuilder.setQueueId(input.readUnsignedInt());\r
 321 \r
 322             byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
 323             input.readBytes(txBytes);\r
 324             queueStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
 325 \r
 326             byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
 327             input.readBytes(txPackets);\r
 328             queueStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
 329 \r
 330             byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
 331             input.readBytes(txErrors);\r
 332             queueStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
 333 \r
 334             queueStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 335             queueStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 336             queueStatsList.add(queueStatsBuilder.build());\r
 337         }\r
 338         builder.setQueueStats(new ArrayList<>(queueStatsList));\r
 339         queueStatsList.clear();\r
 340         return builder.build();\r
 341     }\r
 342     \r
 343     private static MultipartReplyGroup setGroup(ByteBuf input) {\r
 344         final byte PADDING_IN_GROUP_HEADER_01 = 2;\r
 345         final byte PADDING_IN_GROUP_HEADER_02 = 4;\r
 346         final byte BUCKET_COUNTER_LENGTH = 16;\r
 347         final byte GROUP_BODY_LENGTH = 40;\r
 348         int actualLength;\r
 349         MultipartReplyGroupBuilder builder = new MultipartReplyGroupBuilder();\r
 350         GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();\r
 351         List<GroupStats> groupStatsList = new ArrayList<>();\r
 352         \r
 353         BucketStatsBuilder bucketStatsBuilder = new BucketStatsBuilder();\r
 354         List<BucketStats> bucketStatsList = new ArrayList<>();\r
 355         \r
 356         while (input.readableBytes() > 0) {\r
 357             int bodyLength = input.readUnsignedShort();\r
 358             actualLength = 0;\r
 359             \r
 360             input.skipBytes(PADDING_IN_GROUP_HEADER_01);\r
 361             groupStatsBuilder.setGroupId(input.readUnsignedInt());\r
 362             groupStatsBuilder.setRefCount(input.readUnsignedInt());\r
 363             input.skipBytes(PADDING_IN_GROUP_HEADER_02);\r
 364             byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
 365             input.readBytes(packetCount);\r
 366             groupStatsBuilder.setPacketCount(new BigInteger(packetCount));\r
 367             byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
 368             input.readBytes(byteCount);\r
 369             groupStatsBuilder.setByteCount(new BigInteger(byteCount));\r
 370             groupStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 371             groupStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 372             actualLength = GROUP_BODY_LENGTH;\r
 373             \r
 374             while (actualLength < bodyLength) {\r
 375                 byte[] packetCountBucket = new byte[Long.SIZE/Byte.SIZE];\r
 376                 input.readBytes(packetCountBucket);\r
 377                 bucketStatsBuilder.setPacketCount(new BigInteger(packetCountBucket));\r
 378                 byte[] byteCountBucket = new byte[Long.SIZE/Byte.SIZE];\r
 379                 input.readBytes(byteCountBucket);\r
 380                 bucketStatsBuilder.setByteCount(new BigInteger(byteCountBucket));\r
 381                 bucketStatsList.add(bucketStatsBuilder.build());\r
 382 \r
 383                 actualLength = actualLength + BUCKET_COUNTER_LENGTH;\r
 384             } \r
 385             groupStatsBuilder.setBucketStats(new ArrayList<>(bucketStatsList));\r
 386             bucketStatsList.clear();\r
 387             groupStatsList.add(groupStatsBuilder.build());\r
 388         }\r
 389         builder.setGroupStats(new ArrayList<>(groupStatsList));\r
 390         groupStatsList.clear();\r
 391         return builder.build();\r
 392     }\r
 393     \r
 394     private static MultipartReplyMeterFeatures setMeterFeatures(ByteBuf input) {\r
 395         final byte PADDING_IN_METER_FEATURES_HEADER = 2;\r
 396         MultipartReplyMeterFeaturesBuilder builder = new MultipartReplyMeterFeaturesBuilder();\r
 397         builder.setMaxMeter(input.readUnsignedInt());\r
 398         builder.setBandTypes(MeterBandType.forValue(input.readInt()));\r
 399         builder.setCapabilities(decodeMeterModFlags((int) input.readUnsignedInt()));\r
 400         builder.setMaxBands(input.readUnsignedByte());\r
 401         builder.setMaxColor(input.readUnsignedByte());\r
 402         input.skipBytes(PADDING_IN_METER_FEATURES_HEADER);\r
 403         return builder.build();\r
 404     }\r
 405     \r
 406     private static MeterFlags decodeMeterModFlags(int input){\r
 407         final Boolean _oFPMFKBPS = (input & (1 << 0)) > 0;\r
 408         final Boolean _oFPMFPKTPS = (input & (1 << 1)) > 0;\r
 409         final Boolean _oFPMFBURST = (input & (1 << 2)) > 0; \r
 410         final Boolean _oFPMFSTATS = (input & (1 << 3)) > 0;\r
 411         return new MeterFlags(_oFPMFBURST, _oFPMFKBPS, _oFPMFPKTPS, _oFPMFSTATS);\r
 412     }\r
 413     \r
 414     private static MultipartReplyMeter setMeter(ByteBuf input) {\r
 415         final byte PADDING_IN_METER_STATS_HEADER = 6;\r
 416         final byte METER_BAND_STATS_LENGTH = 16;\r
 417         final byte METER_BODY_LENGTH = 40;\r
 418         int actualLength;\r
 419         MultipartReplyMeterBuilder builder = new MultipartReplyMeterBuilder();\r
 420         List<MeterStats> meterStatsList = new ArrayList<>();\r
 421         MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();\r
 422         List<MeterBandStats> meterBandStatsList = new ArrayList<>();\r
 423         MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();\r
 424         while (input.readableBytes() > 0) {\r
 425             meterStatsBuilder.setMeterId(input.readUnsignedInt());\r
 426             actualLength = 0;\r
 427             int meterStatsBodyLength = input.readUnsignedShort();\r
 428             input.skipBytes(PADDING_IN_METER_STATS_HEADER);\r
 429             meterStatsBuilder.setFlowCount(input.readUnsignedInt());\r
 430             byte[] packetInCount = new byte[Long.SIZE/Byte.SIZE];\r
 431             input.readBytes(packetInCount);\r
 432             meterStatsBuilder.setPacketInCount(new BigInteger(packetInCount));\r
 433             byte[] byteInCount = new byte[Long.SIZE/Byte.SIZE];\r
 434             input.readBytes(byteInCount);\r
 435             meterStatsBuilder.setByteInCount(new BigInteger(byteInCount));\r
 436             meterStatsBuilder.setDurationSec(input.readUnsignedInt());\r
 437             meterStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
 438             actualLength = METER_BODY_LENGTH;\r
 439             \r
 440             while (actualLength < meterStatsBodyLength) {\r
 441                 byte[] packetBandCount = new byte[Long.SIZE/Byte.SIZE];\r
 442                 input.readBytes(packetBandCount);\r
 443                 meterBandStatsBuilder.setPacketBandCount(new BigInteger(packetBandCount));\r
 444                 byte[] byteBandCount = new byte[Long.SIZE/Byte.SIZE];\r
 445                 input.readBytes(byteBandCount);\r
 446                 meterBandStatsBuilder.setByteBandCount(new BigInteger(byteBandCount));\r
 447                 \r
 448                 meterBandStatsList.add(meterBandStatsBuilder.build());\r
 449                 actualLength = actualLength + METER_BAND_STATS_LENGTH;\r
 450             }\r
 451         \r
 452             meterStatsBuilder.setMeterBandStats(new ArrayList<>(meterBandStatsList));\r
 453             meterBandStatsList.clear();\r
 454             meterStatsList.add(meterStatsBuilder.build());\r
 455         }\r
 456         builder.setMeterStats(new ArrayList<>(meterStatsList));\r
 457         meterStatsList.clear();\r
 458         return builder.build();\r
 459     }\r
 460     \r
 461     private static MultipartReplyMeterConfig setMeterConfig(ByteBuf input) {\r
 462         final byte METER_BAND_LENGTH = 16;\r
 463         final byte METER_CONFIG_LENGTH = 8;\r
 464         int actualLength;\r
 465         MultipartReplyMeterConfigBuilder builder = new MultipartReplyMeterConfigBuilder();\r
 466         List<MeterConfig> meterConfigList = new ArrayList<>();\r
 467         MeterConfigBuilder meterConfigBuilder = new MeterConfigBuilder();\r
 468         List<Bands> bandsList = new ArrayList<Bands>();\r
 469         BandsBuilder bandsBuilder = new BandsBuilder();\r
 470         \r
 471         while (input.readableBytes() > 0) {\r
 472             int meterConfigBodyLength = input.readUnsignedShort();\r
 473             actualLength = 0;\r
 474             meterConfigBuilder.setFlags(MeterModCommand.forValue(input.readUnsignedShort()));\r
 475             meterConfigBuilder.setMeterId(input.readUnsignedInt());\r
 476             actualLength = METER_CONFIG_LENGTH;\r
 477             \r
 478             while (actualLength < meterConfigBodyLength) {\r
 479                 MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();\r
 480                 final byte PADDING_IN_METER_BAND_DROP_HEADER = 4;\r
 481                 MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();\r
 482                 final byte PADDING_IN_METER_BAND_DSCP_HEADER = 3;\r
 483                 MeterBandExperimenterBuilder bandExperimenterBuilder = new MeterBandExperimenterBuilder(); \r
 484                 int bandLen = 0;\r
 485                 int bandType = input.readUnsignedShort();\r
 486                 switch (bandType) {\r
 487                     case 1: bandDropBuilder.setType(MeterBandType.forValue(bandType));\r
 488                             bandLen = input.readUnsignedShort();\r
 489                             bandDropBuilder.setRate(input.readUnsignedInt());\r
 490                             bandDropBuilder.setBurstSize(input.readUnsignedInt());\r
 491                             input.skipBytes(PADDING_IN_METER_BAND_DROP_HEADER);\r
 492                             bandsBuilder.setMeterBand(bandDropBuilder.build());\r
 493                             break;\r
 494                     case 2: bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));\r
 495                             bandLen = input.readUnsignedShort();\r
 496                             bandDscpRemarkBuilder.setRate(input.readUnsignedInt());\r
 497                             bandDscpRemarkBuilder.setBurstSize(input.readUnsignedInt());\r
 498                             bandDscpRemarkBuilder.setPrecLevel(input.readUnsignedByte());\r
 499                             input.skipBytes(PADDING_IN_METER_BAND_DSCP_HEADER);\r
 500                             bandsBuilder.setMeterBand(bandDscpRemarkBuilder.build());\r
 501                             break;\r
 502                     case 0xFFFF: bandExperimenterBuilder.setType(MeterBandType.forValue(bandType));\r
 503                                  bandLen = input.readUnsignedShort();          \r
 504                                  bandExperimenterBuilder.setRate(input.readUnsignedInt());\r
 505                                  bandExperimenterBuilder.setBurstSize(input.readUnsignedInt());\r
 506                                  bandExperimenterBuilder.setExperimenter(input.readUnsignedInt());\r
 507                                  bandsBuilder.setMeterBand(bandExperimenterBuilder.build());\r
 508                                  break;\r
 509                     default: break;\r
 510                 }\r
 511                 bandsList.add(bandsBuilder.build());\r
 512                 actualLength = actualLength + METER_BAND_LENGTH;\r
 513             }\r
 514             meterConfigBuilder.setBands(new ArrayList<>(bandsList));\r
 515             bandsList.clear();\r
 516             meterConfigList.add(meterConfigBuilder.build());\r
 517         }\r
 518         builder.setMeterConfig(new ArrayList<>(meterConfigList));\r
 519         meterConfigList.clear();\r
 520         return builder.build();\r
 521     }\r
 522     \r
 523     private static MultipartReplyExperimenter setExperimenter(ByteBuf input) {\r
 524         MultipartReplyExperimenterBuilder builder = new MultipartReplyExperimenterBuilder();\r
 525         builder.setExperimenter(input.readUnsignedInt());\r
 526         builder.setExpType(input.readUnsignedInt());\r
 527         byte[] data = new byte[Long.SIZE/Byte.SIZE];\r
 528         input.readBytes(data);\r
 529         builder.setData(data);\r
 530         return builder.build();\r
 531     }\r
 532     \r
 533     private static MultipartReplyPortDesc setPortDesc(ByteBuf input) {\r
 534         final byte PADDING_IN_PORT_DESC_HEADER_01 = 4;\r
 535         final byte PADDING_IN_PORT_DESC_HEADER_02 = 2;\r
 536         final int macAddressLength = 6;\r
 537         final byte MAX_PORT_NAME_LEN = 16;\r
 538         MultipartReplyPortDescBuilder builder = new MultipartReplyPortDescBuilder();\r
 539         List<Ports> portsList = new ArrayList<>();\r
 540         PortsBuilder portsBuilder = new PortsBuilder();\r
 541         \r
 542         while (input.readableBytes() > 0) {\r
 543             portsBuilder.setPortNo(input.readUnsignedInt());\r
 544             input.skipBytes(PADDING_IN_PORT_DESC_HEADER_01);\r
 545             StringBuffer macToString = new StringBuffer();\r
 546             for(int i=0; i<macAddressLength; i++){\r
 547                 short mac = 0;\r
 548                 mac = input.readUnsignedByte();\r
 549                 macToString.append(String.format("%02X", mac));\r
 550             }\r
 551             portsBuilder.setHwAddr(new MacAddress(macToString.toString()));\r
 552             input.skipBytes(PADDING_IN_PORT_DESC_HEADER_02);\r
 553             \r
 554             byte[] portNameBytes = new byte[MAX_PORT_NAME_LEN];\r
 555             input.readBytes(portNameBytes);\r
 556             String portName = new String(portNameBytes);\r
 557             portsBuilder.setName(portName.trim());\r
 558             \r
 559             portsBuilder.setConfig(createPortConfig(input.readUnsignedInt()));\r
 560             portsBuilder.setState(createPortState(input.readUnsignedInt()));\r
 561             portsBuilder.setCurrentFeatures(createPortFeatures(input.readUnsignedInt()));\r
 562             portsBuilder.setAdvertisedFeatures(createPortFeatures(input.readUnsignedInt()));\r
 563             portsBuilder.setSupportedFeatures(createPortFeatures(input.readUnsignedInt()));\r
 564             portsBuilder.setPeerFeatures(createPortFeatures(input.readUnsignedInt()));\r
 565             portsBuilder.setCurrSpeed(input.readUnsignedInt());\r
 566             portsBuilder.setMaxSpeed(input.readUnsignedInt());\r
 567             portsList.add(portsBuilder.build());\r
 568         }\r
 569         \r
 570         builder.setPorts(new ArrayList<>(portsList));\r
 571         portsList.clear();\r
 572         return builder.build();\r
 573     }\r
 574     \r
 575     private static PortConfig createPortConfig(long input){\r
 576         final Boolean _portDown   = ((input) & (1<<0)) != 0;\r
 577         final Boolean _noRecv    = ((input) & (1<<2)) != 0;\r
 578         final Boolean _noFwd       = ((input) & (1<<5)) != 0;\r
 579         final Boolean _noPacketIn = ((input) & (1<<6)) != 0;\r
 580         return new PortConfig(_noFwd, _noPacketIn, _noRecv, _portDown);\r
 581     }\r
 582     \r
 583     private static PortState createPortState(long input){\r
 584         final Boolean _linkDown = ((input) & (1<<0)) != 0;\r
 585         final Boolean _blocked  = ((input) & (1<<1)) != 0;\r
 586         final Boolean _live     = ((input) & (1<<2)) != 0;\r
 587         return new PortState(_linkDown, _blocked,_live);\r
 588     }\r
 589     \r
 590     private static PortFeatures createPortFeatures(long input){\r
 591         final Boolean _10mbHd = ((input) & (1<<0)) != 0;\r
 592         final Boolean _10mbFd = ((input) & (1<<1)) != 0;\r
 593         final Boolean _100mbHd = ((input) & (1<<2)) != 0;\r
 594         final Boolean _100mbFd = ((input) & (1<<3)) != 0;\r
 595         final Boolean _1gbHd = ((input) & (1<<4)) != 0;\r
 596         final Boolean _1gbFd = ((input) & (1<<5)) != 0;\r
 597         final Boolean _10gbFd = ((input) & (1<<6)) != 0;\r
 598         final Boolean _40gbFd = ((input) & (1<<7)) != 0;\r
 599         final Boolean _100gbFd = ((input) & (1<<8)) != 0;\r
 600         final Boolean _1tbFd = ((input) & (1<<9)) != 0;\r
 601         final Boolean _other = ((input) & (1<<10)) != 0;\r
 602         final Boolean _copper = ((input) & (1<<11)) != 0;\r
 603         final Boolean _fiber = ((input) & (1<<12)) != 0;\r
 604         final Boolean _autoneg = ((input) & (1<<13)) != 0;\r
 605         final Boolean _pause = ((input) & (1<<14)) != 0;\r
 606         final Boolean _pauseAsym = ((input) & (1<<15)) != 0;\r
 607         return new PortFeatures(_10mbHd, _10mbFd, _100mbHd, _100mbFd, _1gbHd, _1gbFd, _10gbFd,\r
 608                 _40gbFd, _100gbFd, _1tbFd, _other, _copper, _fiber, _autoneg, _pause, _pauseAsym);\r
 609     }\r
 610 }\r