Code Review / openflowjava.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Updated Multipart message code
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / serialization / factories / OF10StatsRequestInputFactory.java
diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestInputFactory.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestInputFactory.java
new file mode 100644 (file)
index 0000000..7ae59b0
--- /dev/null
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestInputFactory.java
@@ -0,0 +1,177 @@
+/* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
+package org.opendaylight.openflowjava.protocol.impl.serialization.factories;\r
+\r
+import io.netty.buffer.ByteBuf;\r
+\r
+import java.util.HashMap;\r
+import java.util.Map;\r
+\r
+import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
+import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
+import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchSerializer;\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.MultipartRequestInput;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregate;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDesc;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenter;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlow;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStats;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueue;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTable;\r
+\r
+/**\r
+ * Translates StatsRequest messages\r
+ * @author michal.polkorab\r
+ */\r
+public class OF10StatsRequestInputFactory implements OFSerializer<MultipartRequestInput> {\r
+\r
+    private static final byte MESSAGE_TYPE = 18;\r
+    private static final int MESSAGE_LENGTH = 16;\r
+\r
+    private static OF10StatsRequestInputFactory instance; \r
+    \r
+    private OF10StatsRequestInputFactory() {\r
+        // singleton\r
+    }\r
+    \r
+    /**\r
+     * @return singleton factory\r
+     */\r
+    public static synchronized OF10StatsRequestInputFactory getInstance() {\r
+        if (instance == null) {\r
+            instance = new OF10StatsRequestInputFactory();\r
+        }\r
+        return instance;\r
+    }\r
+    \r
+    @Override\r
+    public void messageToBuffer(short version, ByteBuf out,\r
+            MultipartRequestInput message) {\r
+        ByteBufUtils.writeOFHeader(instance, message, out);\r
+        out.writeShort(message.getType().getIntValue());\r
+        out.writeShort(createMultipartRequestFlagsBitmask(message.getFlags()));\r
+        if (message.getMultipartRequestBody() instanceof MultipartRequestDesc) {\r
+            encodeDescBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestFlow) {\r
+            encodeFlowBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestAggregate) {\r
+            encodeAggregateBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestTable) {\r
+            encodeTableBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStats) {\r
+            encodePortBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueue) {\r
+            encodeQueueBody(message.getMultipartRequestBody(), out);\r
+        } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenter) {\r
+            encodeExperimenterBody(message.getMultipartRequestBody(), out);\r
+        }\r
+    }\r
+    \r
+    @Override\r
+    public int computeLength(MultipartRequestInput message) {\r
+        return MESSAGE_LENGTH + computeBodyLength(message);\r
+    }\r
+    @Override\r
+    public byte getMessageType() {\r
+        return MESSAGE_TYPE;\r
+    }\r
+    \r
+    /**\r
+     * \r
+     * @param message\r
+     * @return length of MultipartRequestMessage\r
+     */\r
+    public int computeBodyLength(MultipartRequestInput message) {\r
+        int length = 0;\r
+        MultipartType type = message.getType();\r
+        if (type.equals(MultipartType.OFPMPFLOW)) {\r
+            final byte FLOW_BODY_LENGTH = 44;\r
+            length += FLOW_BODY_LENGTH;\r
+        } else if (type.equals(MultipartType.OFPMPAGGREGATE)) {\r
+            final byte AGGREGATE_BODY_LENGTH = 44;\r
+            length += AGGREGATE_BODY_LENGTH;\r
+        } else if (type.equals(MultipartType.OFPMPPORTSTATS)) {\r
+            final byte PORT_STATS_BODY_LENGTH = 8;\r
+            length += PORT_STATS_BODY_LENGTH;\r
+        } else if (type.equals(MultipartType.OFPMPQUEUE)) {\r
+            final byte QUEUE_BODY_LENGTH = 8;\r
+            length += QUEUE_BODY_LENGTH;\r
+        } else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {\r
+            final byte EXPERIMENTER_BODY_LENGTH = 4;\r
+            MultipartRequestExperimenter body = (MultipartRequestExperimenter) message.getMultipartRequestBody();\r
+            length += EXPERIMENTER_BODY_LENGTH;\r
+            if (body.getData() != null) {\r
+                length += body.getData().length;\r
+            }\r
+        }\r
+        return length;\r
+    }\r
+    \r
+    private static int createMultipartRequestFlagsBitmask(MultipartRequestFlags flags) {\r
+        int multipartRequestFlagsBitmask = 0;\r
+        Map<Integer, Boolean> multipartRequestFlagsMap = new HashMap<>();\r
+        multipartRequestFlagsMap.put(0, flags.isOFPMPFREQMORE());\r
+        multipartRequestFlagsBitmask = ByteBufUtils.fillBitMaskFromMap(multipartRequestFlagsMap);\r
+        return multipartRequestFlagsBitmask;\r
+    }\r
+    \r
+    /**\r
+     * @param multipartRequestBody  \r
+     * @param output \r
+     */\r
+    private void encodeDescBody(MultipartRequestBody multipartRequestBody,\r
+            ByteBuf output) {\r
+        // The body of MultiPartRequestDesc is empty\r
+    }\r
+\r
+    /**\r
+     * @param multipartRequestBody\r
+     * @param out\r
+     */\r
+    private void encodeTableBody(MultipartRequestBody multipartRequestBody,\r
+            ByteBuf out) {\r
+     // The body of MultiPartTable is empty\r
+    }\r
+    \r
+    private static void encodeFlowBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
+        encodeFlowAndAggregateBody(multipartRequestBody, output);\r
+    }\r
+    \r
+    private static void encodeAggregateBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
+        encodeFlowAndAggregateBody(multipartRequestBody, output);\r
+    }\r
+\r
+    private static void encodeFlowAndAggregateBody(\r
+            MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
+        final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;\r
+        MultipartRequestFlow flow = (MultipartRequestFlow) multipartRequestBody;\r
+        OF10MatchSerializer.encodeMatchV10(output, flow.getMatchV10());\r
+        output.writeByte(flow.getTableId().shortValue());\r
+        ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_FLOW_BODY, output);\r
+        output.writeShort(flow.getOutPort().intValue());\r
+    }\r
+    \r
+    private static void encodePortBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
+        final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;\r
+        MultipartRequestPortStats portstats = (MultipartRequestPortStats) multipartRequestBody;\r
+        output.writeShort(portstats.getPortNo().intValue());\r
+        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
Opendaylight Openflow Protocol Library