OpenFlow 1.0 support completed

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / serialization / factories / OF10StatsRequestMessageFactory.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsReuestMessageFactory.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestMessageFactory.java
similarity index 83%
rename from openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsReuestMessageFactory.java
rename to openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestMessageFactory.java
index eed71a94b1e0fd0811a34f1bc4eda8e22c0a41a2..ef0292d8bc8b8c08e000e528d6b00d45972bf7da 100644 (file)
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsReuestMessageFactory.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestMessageFactory.java
@@ -22,23 +22,23 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
  * @author michal.polkorab\r
  *\r
  */\r
-public class OF10StatsReuestMessageFactory implements OFSerializer<MultipartRequestMessage> {\r
+public class OF10StatsRequestMessageFactory implements OFSerializer<MultipartRequestMessage> {\r
 \r
     private static final byte MESSAGE_TYPE = 18;\r
     private static final int MESSAGE_LENGTH = 16;\r
 \r
-    private static OF10StatsReuestMessageFactory instance; \r
+    private static OF10StatsRequestMessageFactory instance; \r
     \r
-    private OF10StatsReuestMessageFactory() {\r
+    private OF10StatsRequestMessageFactory() {\r
         // singleton\r
     }\r
     \r
     /**\r
      * @return singleton factory\r
      */\r
-    public static synchronized OF10StatsReuestMessageFactory getInstance() {\r
+    public static synchronized OF10StatsRequestMessageFactory getInstance() {\r
         if (instance == null) {\r
-            instance = new OF10StatsReuestMessageFactory();\r
+            instance = new OF10StatsRequestMessageFactory();\r
         }\r
         return instance;\r
     }\r
@@ -57,7 +57,7 @@ public class OF10StatsReuestMessageFactory implements OFSerializer<MultipartRequ
         } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStats) {\r
             encodePortBody(message.getMultipartRequestBody(), out);\r
         } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueue) {\r
-            //encodeQueueBody(message.getMultipartRequestBody(), out);\r
+            encodeQueueBody(message.getMultipartRequestBody(), out);\r
         } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenter) {\r
             encodeExperimenterBody(message.getMultipartRequestBody(), out);\r
         }\r
@@ -106,9 +106,18 @@ public class OF10StatsReuestMessageFactory implements OFSerializer<MultipartRequ
         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_PORT_BODY, output);\r
     }\r
     \r
+    private static void encodeQueueBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
+        final byte PADING_IN_QUEUE_BODY = 2;\r
+        MultipartRequestQueue queue = (MultipartRequestQueue) multipartRequestBody;\r
+        output.writeShort(queue.getPortNo().intValue());\r
+        ByteBufUtils.padBuffer(PADING_IN_QUEUE_BODY, output);\r
+        output.writeInt(queue.getQueueId().intValue());\r
+    }\r
+    \r
     private static void encodeExperimenterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
         MultipartRequestExperimenter experimenter = (MultipartRequestExperimenter) multipartRequestBody;\r
         output.writeInt(experimenter.getExperimenter().intValue());\r
+        output.writeBytes(experimenter.getData());\r
     }\r
     \r
 }\r