Copyright update
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / deserialization / factories / OF10StatsReplyMessageFactory.java
index bbff2e372c463a45af180e723a30ba2f663db48f..b88876564bd7de3ff2bbabdef5690f95006c657d 100644 (file)
-/* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
-package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;\r
-\r
-import io.netty.buffer.ByteBuf;\r
-\r
-import java.math.BigInteger;\r
-import java.util.ArrayList;\r
-import java.util.List;\r
-\r
-import org.opendaylight.openflowjava.protocol.impl.deserialization.OFDeserializer;\r
-import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;\r
-import org.opendaylight.openflowjava.protocol.impl.util.OF10ActionsDeserializer;\r
-import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchDeserializer;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessageBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregate;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDesc;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDescBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenterBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlow;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStats;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueue;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueueBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTable;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStats;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStatsBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStats;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStatsBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStats;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStatsBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStats;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStatsBuilder;\r
-\r
-/**\r
- * Translates StatsReply messages (OpenFlow v1.0)\r
- * @author michal.polkorab\r
- */\r
-public class OF10StatsReplyMessageFactory implements OFDeserializer<MultipartReplyMessage> {\r
-\r
-    private static final int DESC_STR_LEN = 256;\r
-    private static final int SERIAL_NUM_LEN = 32;\r
-    private static final byte PADDING_IN_FLOW_STATS_HEADER = 1;\r
-    private static final byte PADDING_IN_FLOW_STATS_HEADER_02 = 6;\r
-    private static final byte PADDING_IN_AGGREGATE_HEADER = 4;\r
-    private static final byte PADDING_IN_TABLE_HEADER = 3;\r
-    private static final byte MAX_TABLE_NAME_LENGTH = 32;\r
-    private static final byte PADDING_IN_PORT_STATS_HEADER = 6;\r
-    private static final byte PADDING_IN_QUEUE_HEADER = 2;\r
-\r
-    private static OF10StatsReplyMessageFactory instance;\r
-    \r
-    private OF10StatsReplyMessageFactory() {\r
-        // singleton\r
-    }\r
-    \r
-    /**\r
-     * @return singleton factory\r
-     */\r
-    public static synchronized OF10StatsReplyMessageFactory getInstance() {\r
-        if (instance == null){\r
-            instance = new OF10StatsReplyMessageFactory();\r
-        }\r
-        return instance;\r
-    }\r
-\r
-    @Override\r
-    public MultipartReplyMessage bufferToMessage(ByteBuf rawMessage, short version) {\r
-        MultipartReplyMessageBuilder builder = new MultipartReplyMessageBuilder();\r
-        builder.setVersion(version);\r
-        builder.setXid(rawMessage.readUnsignedInt());\r
-        int type = rawMessage.readUnsignedShort();\r
-        builder.setType(MultipartType.forValue(type));\r
-        builder.setFlags(new MultipartRequestFlags((rawMessage.readUnsignedShort() & 0x01) != 0));\r
-        switch (type) {\r
-        case 0:  builder.setMultipartReplyBody(setDesc(rawMessage));\r
-            break;\r
-        case 1:  builder.setMultipartReplyBody(setFlow(rawMessage));\r
-            break;\r
-        case 2:  builder.setMultipartReplyBody(setAggregate(rawMessage));\r
-            break;\r
-        case 3:  builder.setMultipartReplyBody(setTable(rawMessage));\r
-            break;         \r
-        case 4:  builder.setMultipartReplyBody(setPortStats(rawMessage));\r
-            break;\r
-        case 5:  builder.setMultipartReplyBody(setQueue(rawMessage));\r
-            break;         \r
-        case 0xFFFF: builder.setMultipartReplyBody(setExperimenter(rawMessage));\r
-            break;\r
-        default: \r
-            break;\r
-        }\r
-        return builder.build();\r
-    }\r
-    \r
-    private static MultipartReplyDesc setDesc(ByteBuf input) {\r
-        MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();\r
-        byte[] mfrDescBytes = new byte[DESC_STR_LEN];\r
-        input.readBytes(mfrDescBytes);\r
-        String mfrDesc = new String(mfrDescBytes);\r
-        descBuilder.setMfrDesc(mfrDesc.trim());\r
-        byte[] hwDescBytes = new byte[DESC_STR_LEN];\r
-        input.readBytes(hwDescBytes);\r
-        String hwDesc = new String(hwDescBytes);\r
-        descBuilder.setHwDesc(hwDesc.trim());\r
-        byte[] swDescBytes = new byte[DESC_STR_LEN];\r
-        input.readBytes(swDescBytes);\r
-        String swDesc = new String(swDescBytes);\r
-        descBuilder.setSwDesc(swDesc.trim());\r
-        byte[] serialNumBytes = new byte[SERIAL_NUM_LEN];\r
-        input.readBytes(serialNumBytes);\r
-        String serialNum = new String(serialNumBytes);\r
-        descBuilder.setSerialNum(serialNum.trim());\r
-        byte[] dpDescBytes = new byte[DESC_STR_LEN];\r
-        input.readBytes(dpDescBytes);\r
-        String dpDesc = new String(dpDescBytes);\r
-        descBuilder.setDpDesc(dpDesc.trim());\r
-        return descBuilder.build();\r
-    }\r
-    \r
-    private static MultipartReplyFlow setFlow(ByteBuf input) {\r
-        MultipartReplyFlowBuilder flowBuilder = new MultipartReplyFlowBuilder();\r
-        List<FlowStats> flowStatsList = new ArrayList<>();\r
-        while (input.readableBytes() > 0) {\r
-            FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();\r
-            input.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);\r
-            flowStatsBuilder.setTableId(input.readUnsignedByte());\r
-            input.skipBytes(PADDING_IN_FLOW_STATS_HEADER);\r
-            flowStatsBuilder.setMatchV10(OF10MatchDeserializer.createMatchV10(input));\r
-            flowStatsBuilder.setDurationSec(input.readUnsignedInt());\r
-            flowStatsBuilder.setDurationNsec(input.readUnsignedInt());\r
-            flowStatsBuilder.setPriority(input.readUnsignedShort());\r
-            flowStatsBuilder.setIdleTimeout(input.readUnsignedShort());\r
-            flowStatsBuilder.setHardTimeout(input.readUnsignedShort());\r
-            input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_02);\r
-            byte[] cookie = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(cookie);\r
-            flowStatsBuilder.setCookie(new BigInteger(cookie));\r
-            byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(packetCount);\r
-            flowStatsBuilder.setPacketCount(new BigInteger(packetCount));\r
-            byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(byteCount);\r
-            flowStatsBuilder.setByteCount(new BigInteger(byteCount));\r
-            flowStatsBuilder.setActionsList(OF10ActionsDeserializer.createActionsList(input));\r
-            flowStatsList.add(flowStatsBuilder.build());\r
-        }\r
-        flowBuilder.setFlowStats(flowStatsList);\r
-        return flowBuilder.build();\r
-    }\r
-    \r
-    private static MultipartReplyAggregate setAggregate(ByteBuf input) {\r
-        MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();\r
-        byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
-        input.readBytes(packetCount);\r
-        builder.setPacketCount(new BigInteger(packetCount));\r
-        byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];\r
-        input.readBytes(byteCount);\r
-        builder.setByteCount(new BigInteger(byteCount));\r
-        builder.setFlowCount(input.readUnsignedInt());\r
-        input.skipBytes(PADDING_IN_AGGREGATE_HEADER);\r
-        return builder.build();\r
-    }\r
-    \r
-    private static MultipartReplyTable setTable(ByteBuf input) {\r
-        MultipartReplyTableBuilder builder = new MultipartReplyTableBuilder();\r
-        List<TableStats> tableStatsList = new ArrayList<>();\r
-        while (input.readableBytes() > 0) {\r
-            TableStatsBuilder tableStatsBuilder = new TableStatsBuilder();\r
-            tableStatsBuilder.setTableId(input.readUnsignedByte());\r
-            input.skipBytes(PADDING_IN_TABLE_HEADER);\r
-            tableStatsBuilder.setName(input.readBytes(MAX_TABLE_NAME_LENGTH).toString());\r
-            tableStatsBuilder.setActiveCount(input.readUnsignedInt());\r
-            byte[] lookupCount = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(lookupCount);\r
-            tableStatsBuilder.setLookupCount(new BigInteger(lookupCount));\r
-            byte[] matchedCount = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(matchedCount);\r
-            tableStatsBuilder.setMatchedCount(new BigInteger(matchedCount));\r
-            tableStatsList.add(tableStatsBuilder.build());\r
-        }\r
-        builder.setTableStats(tableStatsList);\r
-        return builder.build();\r
-    }\r
-    \r
-    private static MultipartReplyPortStats setPortStats(ByteBuf input) {\r
-        MultipartReplyPortStatsBuilder builder = new MultipartReplyPortStatsBuilder();\r
-        List<PortStats> portStatsList = new ArrayList<>();\r
-        while (input.readableBytes() > 0) {\r
-            PortStatsBuilder portStatsBuilder = new PortStatsBuilder();\r
-            portStatsBuilder.setPortNo((long) input.readUnsignedShort());\r
-            input.skipBytes(PADDING_IN_PORT_STATS_HEADER);\r
-            byte[] rxPackets = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxPackets);\r
-            portStatsBuilder.setRxPackets(new BigInteger(rxPackets));\r
-            byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txPackets);\r
-            portStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
-            byte[] rxBytes = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxBytes);\r
-            portStatsBuilder.setRxBytes(new BigInteger(rxBytes));\r
-            byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txBytes);\r
-            portStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
-            byte[] rxDropped = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxDropped);\r
-            portStatsBuilder.setRxDropped(new BigInteger(rxDropped));\r
-            byte[] txDropped = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txDropped);\r
-            portStatsBuilder.setTxDropped(new BigInteger(txDropped));\r
-            byte[] rxErrors = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxErrors);\r
-            portStatsBuilder.setRxErrors(new BigInteger(rxErrors));\r
-            byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txErrors);\r
-            portStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
-            byte[] rxFrameErr = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxFrameErr);\r
-            portStatsBuilder.setRxFrameErr(new BigInteger(rxFrameErr));\r
-            byte[] rxOverErr = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxOverErr);\r
-            portStatsBuilder.setRxOverErr(new BigInteger(rxOverErr));\r
-            byte[] rxCrcErr = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(rxCrcErr);\r
-            portStatsBuilder.setRxCrcErr(new BigInteger(rxCrcErr));\r
-            byte[] collisions = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(collisions);\r
-            portStatsBuilder.setCollisions(new BigInteger(collisions));\r
-        }\r
-        builder.setPortStats(portStatsList);\r
-        return builder.build();\r
-    }\r
-    \r
-    private static MultipartReplyQueue setQueue(ByteBuf input) {\r
-        MultipartReplyQueueBuilder builder = new MultipartReplyQueueBuilder();\r
-        List<QueueStats> queueStatsList = new ArrayList<>();\r
-        while (input.readableBytes() > 0) {\r
-            QueueStatsBuilder queueStatsBuilder = new QueueStatsBuilder();\r
-            queueStatsBuilder.setPortNo((long) input.readUnsignedShort());\r
-            input.skipBytes(PADDING_IN_QUEUE_HEADER);\r
-            queueStatsBuilder.setQueueId(input.readUnsignedInt());\r
-            byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txBytes);\r
-            queueStatsBuilder.setTxBytes(new BigInteger(txBytes));\r
-            byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txPackets);\r
-            queueStatsBuilder.setTxPackets(new BigInteger(txPackets));\r
-            byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];\r
-            input.readBytes(txErrors);\r
-            queueStatsBuilder.setTxErrors(new BigInteger(txErrors));\r
-            queueStatsList.add(queueStatsBuilder.build());\r
-        }\r
-        builder.setQueueStats(queueStatsList);\r
-        return builder.build();\r
-    }\r
-    \r
-    private static MultipartReplyExperimenter setExperimenter(ByteBuf input) {\r
-        MultipartReplyExperimenterBuilder builder = new MultipartReplyExperimenterBuilder();\r
-        builder.setExperimenter(input.readUnsignedInt());\r
-        byte[] data = new byte[Long.SIZE/Byte.SIZE];\r
-        input.readBytes(data);\r
-        builder.setData(data);\r
-        return builder.build();\r
-    }\r
-}\r
+/*
+ * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
+
+import io.netty.buffer.ByteBuf;
+
+import java.math.BigInteger;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.opendaylight.openflowjava.protocol.impl.deserialization.OFDeserializer;
+import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;
+import org.opendaylight.openflowjava.protocol.impl.util.OF10ActionsDeserializer;
+import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchDeserializer;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessageBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregate;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyAggregateBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDesc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyDescBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyExperimenterBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlow;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyFlowBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyPortStatsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueue;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyQueueBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTable;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyTableBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.flow.FlowStatsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.port.stats.PortStatsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.queue.QueueStatsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table.TableStatsBuilder;
+
+/**
+ * Translates StatsReply messages (OpenFlow v1.0)
+ * @author michal.polkorab
+ */
+public class OF10StatsReplyMessageFactory implements OFDeserializer<MultipartReplyMessage> {
+
+    private static final int DESC_STR_LEN = 256;
+    private static final int SERIAL_NUM_LEN = 32;
+    private static final byte PADDING_IN_FLOW_STATS_HEADER = 1;
+    private static final byte PADDING_IN_FLOW_STATS_HEADER_02 = 6;
+    private static final byte PADDING_IN_AGGREGATE_HEADER = 4;
+    private static final byte PADDING_IN_TABLE_HEADER = 3;
+    private static final byte MAX_TABLE_NAME_LENGTH = 32;
+    private static final byte PADDING_IN_PORT_STATS_HEADER = 6;
+    private static final byte PADDING_IN_QUEUE_HEADER = 2;
+
+    private static OF10StatsReplyMessageFactory instance;
+    
+    private OF10StatsReplyMessageFactory() {
+        // singleton
+    }
+    
+    /**
+     * @return singleton factory
+     */
+    public static synchronized OF10StatsReplyMessageFactory getInstance() {
+        if (instance == null){
+            instance = new OF10StatsReplyMessageFactory();
+        }
+        return instance;
+    }
+
+    @Override
+    public MultipartReplyMessage bufferToMessage(ByteBuf rawMessage, short version) {
+        MultipartReplyMessageBuilder builder = new MultipartReplyMessageBuilder();
+        builder.setVersion(version);
+        builder.setXid(rawMessage.readUnsignedInt());
+        int type = rawMessage.readUnsignedShort();
+        builder.setType(MultipartType.forValue(type));
+        builder.setFlags(new MultipartRequestFlags((rawMessage.readUnsignedShort() & 0x01) != 0));
+        switch (type) {
+        case 0:  builder.setMultipartReplyBody(setDesc(rawMessage));
+            break;
+        case 1:  builder.setMultipartReplyBody(setFlow(rawMessage));
+            break;
+        case 2:  builder.setMultipartReplyBody(setAggregate(rawMessage));
+            break;
+        case 3:  builder.setMultipartReplyBody(setTable(rawMessage));
+            break;         
+        case 4:  builder.setMultipartReplyBody(setPortStats(rawMessage));
+            break;
+        case 5:  builder.setMultipartReplyBody(setQueue(rawMessage));
+            break;         
+        case 0xFFFF: builder.setMultipartReplyBody(setExperimenter(rawMessage));
+            break;
+        default: 
+            break;
+        }
+        return builder.build();
+    }
+    
+    private static MultipartReplyDesc setDesc(ByteBuf input) {
+        MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();
+        byte[] mfrDescBytes = new byte[DESC_STR_LEN];
+        input.readBytes(mfrDescBytes);
+        String mfrDesc = new String(mfrDescBytes);
+        descBuilder.setMfrDesc(mfrDesc.trim());
+        byte[] hwDescBytes = new byte[DESC_STR_LEN];
+        input.readBytes(hwDescBytes);
+        String hwDesc = new String(hwDescBytes);
+        descBuilder.setHwDesc(hwDesc.trim());
+        byte[] swDescBytes = new byte[DESC_STR_LEN];
+        input.readBytes(swDescBytes);
+        String swDesc = new String(swDescBytes);
+        descBuilder.setSwDesc(swDesc.trim());
+        byte[] serialNumBytes = new byte[SERIAL_NUM_LEN];
+        input.readBytes(serialNumBytes);
+        String serialNum = new String(serialNumBytes);
+        descBuilder.setSerialNum(serialNum.trim());
+        byte[] dpDescBytes = new byte[DESC_STR_LEN];
+        input.readBytes(dpDescBytes);
+        String dpDesc = new String(dpDescBytes);
+        descBuilder.setDpDesc(dpDesc.trim());
+        return descBuilder.build();
+    }
+    
+    private static MultipartReplyFlow setFlow(ByteBuf input) {
+        MultipartReplyFlowBuilder flowBuilder = new MultipartReplyFlowBuilder();
+        List<FlowStats> flowStatsList = new ArrayList<>();
+        while (input.readableBytes() > 0) {
+            FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();
+            input.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
+            flowStatsBuilder.setTableId(input.readUnsignedByte());
+            input.skipBytes(PADDING_IN_FLOW_STATS_HEADER);
+            flowStatsBuilder.setMatchV10(OF10MatchDeserializer.createMatchV10(input));
+            flowStatsBuilder.setDurationSec(input.readUnsignedInt());
+            flowStatsBuilder.setDurationNsec(input.readUnsignedInt());
+            flowStatsBuilder.setPriority(input.readUnsignedShort());
+            flowStatsBuilder.setIdleTimeout(input.readUnsignedShort());
+            flowStatsBuilder.setHardTimeout(input.readUnsignedShort());
+            input.skipBytes(PADDING_IN_FLOW_STATS_HEADER_02);
+            byte[] cookie = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(cookie);
+            flowStatsBuilder.setCookie(new BigInteger(cookie));
+            byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(packetCount);
+            flowStatsBuilder.setPacketCount(new BigInteger(packetCount));
+            byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(byteCount);
+            flowStatsBuilder.setByteCount(new BigInteger(byteCount));
+            flowStatsBuilder.setActionsList(OF10ActionsDeserializer.createActionsList(input));
+            flowStatsList.add(flowStatsBuilder.build());
+        }
+        flowBuilder.setFlowStats(flowStatsList);
+        return flowBuilder.build();
+    }
+    
+    private static MultipartReplyAggregate setAggregate(ByteBuf input) {
+        MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();
+        byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];
+        input.readBytes(packetCount);
+        builder.setPacketCount(new BigInteger(packetCount));
+        byte[] byteCount = new byte[Long.SIZE/Byte.SIZE];
+        input.readBytes(byteCount);
+        builder.setByteCount(new BigInteger(byteCount));
+        builder.setFlowCount(input.readUnsignedInt());
+        input.skipBytes(PADDING_IN_AGGREGATE_HEADER);
+        return builder.build();
+    }
+    
+    private static MultipartReplyTable setTable(ByteBuf input) {
+        MultipartReplyTableBuilder builder = new MultipartReplyTableBuilder();
+        List<TableStats> tableStatsList = new ArrayList<>();
+        while (input.readableBytes() > 0) {
+            TableStatsBuilder tableStatsBuilder = new TableStatsBuilder();
+            tableStatsBuilder.setTableId(input.readUnsignedByte());
+            input.skipBytes(PADDING_IN_TABLE_HEADER);
+            tableStatsBuilder.setName(input.readBytes(MAX_TABLE_NAME_LENGTH).toString());
+            tableStatsBuilder.setActiveCount(input.readUnsignedInt());
+            byte[] lookupCount = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(lookupCount);
+            tableStatsBuilder.setLookupCount(new BigInteger(lookupCount));
+            byte[] matchedCount = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(matchedCount);
+            tableStatsBuilder.setMatchedCount(new BigInteger(matchedCount));
+            tableStatsList.add(tableStatsBuilder.build());
+        }
+        builder.setTableStats(tableStatsList);
+        return builder.build();
+    }
+    
+    private static MultipartReplyPortStats setPortStats(ByteBuf input) {
+        MultipartReplyPortStatsBuilder builder = new MultipartReplyPortStatsBuilder();
+        List<PortStats> portStatsList = new ArrayList<>();
+        while (input.readableBytes() > 0) {
+            PortStatsBuilder portStatsBuilder = new PortStatsBuilder();
+            portStatsBuilder.setPortNo((long) input.readUnsignedShort());
+            input.skipBytes(PADDING_IN_PORT_STATS_HEADER);
+            byte[] rxPackets = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxPackets);
+            portStatsBuilder.setRxPackets(new BigInteger(rxPackets));
+            byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txPackets);
+            portStatsBuilder.setTxPackets(new BigInteger(txPackets));
+            byte[] rxBytes = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxBytes);
+            portStatsBuilder.setRxBytes(new BigInteger(rxBytes));
+            byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txBytes);
+            portStatsBuilder.setTxBytes(new BigInteger(txBytes));
+            byte[] rxDropped = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxDropped);
+            portStatsBuilder.setRxDropped(new BigInteger(rxDropped));
+            byte[] txDropped = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txDropped);
+            portStatsBuilder.setTxDropped(new BigInteger(txDropped));
+            byte[] rxErrors = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxErrors);
+            portStatsBuilder.setRxErrors(new BigInteger(rxErrors));
+            byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txErrors);
+            portStatsBuilder.setTxErrors(new BigInteger(txErrors));
+            byte[] rxFrameErr = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxFrameErr);
+            portStatsBuilder.setRxFrameErr(new BigInteger(rxFrameErr));
+            byte[] rxOverErr = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxOverErr);
+            portStatsBuilder.setRxOverErr(new BigInteger(rxOverErr));
+            byte[] rxCrcErr = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(rxCrcErr);
+            portStatsBuilder.setRxCrcErr(new BigInteger(rxCrcErr));
+            byte[] collisions = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(collisions);
+            portStatsBuilder.setCollisions(new BigInteger(collisions));
+        }
+        builder.setPortStats(portStatsList);
+        return builder.build();
+    }
+    
+    private static MultipartReplyQueue setQueue(ByteBuf input) {
+        MultipartReplyQueueBuilder builder = new MultipartReplyQueueBuilder();
+        List<QueueStats> queueStatsList = new ArrayList<>();
+        while (input.readableBytes() > 0) {
+            QueueStatsBuilder queueStatsBuilder = new QueueStatsBuilder();
+            queueStatsBuilder.setPortNo((long) input.readUnsignedShort());
+            input.skipBytes(PADDING_IN_QUEUE_HEADER);
+            queueStatsBuilder.setQueueId(input.readUnsignedInt());
+            byte[] txBytes = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txBytes);
+            queueStatsBuilder.setTxBytes(new BigInteger(txBytes));
+            byte[] txPackets = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txPackets);
+            queueStatsBuilder.setTxPackets(new BigInteger(txPackets));
+            byte[] txErrors = new byte[Long.SIZE/Byte.SIZE];
+            input.readBytes(txErrors);
+            queueStatsBuilder.setTxErrors(new BigInteger(txErrors));
+            queueStatsList.add(queueStatsBuilder.build());
+        }
+        builder.setQueueStats(queueStatsList);
+        return builder.build();
+    }
+    
+    private static MultipartReplyExperimenter setExperimenter(ByteBuf input) {
+        MultipartReplyExperimenterBuilder builder = new MultipartReplyExperimenterBuilder();
+        builder.setExperimenter(input.readUnsignedInt());
+        byte[] data = new byte[Long.SIZE/Byte.SIZE];
+        input.readBytes(data);
+        builder.setData(data);
+        return builder.build();
+    }
+}