-/* 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 = 16;\r
- private static final int MESSAGE_LENGTH = 12;\r
- private static final byte FLOW_BODY_LENGTH = 44;\r
- private static final byte AGGREGATE_BODY_LENGTH = 44;\r
- private static final byte PORT_STATS_BODY_LENGTH = 8;\r
- private static final byte QUEUE_BODY_LENGTH = 8;\r
- private static final byte EXPERIMENTER_BODY_LENGTH = 4;\r
- private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;\r
- private static final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;\r
- private static final byte PADING_IN_QUEUE_BODY = 2;\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
- length += FLOW_BODY_LENGTH;\r
- } else if (type.equals(MultipartType.OFPMPAGGREGATE)) {\r
- length += AGGREGATE_BODY_LENGTH;\r
- } else if (type.equals(MultipartType.OFPMPPORTSTATS)) {\r
- length += PORT_STATS_BODY_LENGTH;\r
- } else if (type.equals(MultipartType.OFPMPQUEUE)) {\r
- length += QUEUE_BODY_LENGTH;\r
- } else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {\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
- 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
- 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
- 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
+/*
+ * 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.serialization.factories;
+
+import io.netty.buffer.ByteBuf;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;
+import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;
+import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchSerializer;
+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.MultipartRequestInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregate;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDesc;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlow;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStats;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueue;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTable;
+
+/**
+ * Translates StatsRequest messages
+ * @author michal.polkorab
+ */
+public class OF10StatsRequestInputFactory implements OFSerializer<MultipartRequestInput> {
+
+ private static final byte MESSAGE_TYPE = 16;
+ private static final int MESSAGE_LENGTH = 12;
+ private static final byte FLOW_BODY_LENGTH = 44;
+ private static final byte AGGREGATE_BODY_LENGTH = 44;
+ private static final byte PORT_STATS_BODY_LENGTH = 8;
+ private static final byte QUEUE_BODY_LENGTH = 8;
+ private static final byte EXPERIMENTER_BODY_LENGTH = 4;
+ private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;
+ private static final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;
+ private static final byte PADING_IN_QUEUE_BODY = 2;
+
+ private static OF10StatsRequestInputFactory instance;
+
+ private OF10StatsRequestInputFactory() {
+ // singleton
+ }
+
+ /**
+ * @return singleton factory
+ */
+ public static synchronized OF10StatsRequestInputFactory getInstance() {
+ if (instance == null) {
+ instance = new OF10StatsRequestInputFactory();
+ }
+ return instance;
+ }
+
+ @Override
+ public void messageToBuffer(short version, ByteBuf out,
+ MultipartRequestInput message) {
+ ByteBufUtils.writeOFHeader(instance, message, out);
+ out.writeShort(message.getType().getIntValue());
+ out.writeShort(createMultipartRequestFlagsBitmask(message.getFlags()));
+ if (message.getMultipartRequestBody() instanceof MultipartRequestDesc) {
+ encodeDescBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestFlow) {
+ encodeFlowBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestAggregate) {
+ encodeAggregateBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestTable) {
+ encodeTableBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStats) {
+ encodePortBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueue) {
+ encodeQueueBody(message.getMultipartRequestBody(), out);
+ } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenter) {
+ encodeExperimenterBody(message.getMultipartRequestBody(), out);
+ }
+ }
+
+ @Override
+ public int computeLength(MultipartRequestInput message) {
+ return MESSAGE_LENGTH + computeBodyLength(message);
+ }
+ @Override
+ public byte getMessageType() {
+ return MESSAGE_TYPE;
+ }
+
+ /**
+ *
+ * @param message
+ * @return length of MultipartRequestMessage
+ */
+ public int computeBodyLength(MultipartRequestInput message) {
+ int length = 0;
+ MultipartType type = message.getType();
+ if (type.equals(MultipartType.OFPMPFLOW)) {
+ length += FLOW_BODY_LENGTH;
+ } else if (type.equals(MultipartType.OFPMPAGGREGATE)) {
+ length += AGGREGATE_BODY_LENGTH;
+ } else if (type.equals(MultipartType.OFPMPPORTSTATS)) {
+ length += PORT_STATS_BODY_LENGTH;
+ } else if (type.equals(MultipartType.OFPMPQUEUE)) {
+ length += QUEUE_BODY_LENGTH;
+ } else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {
+ MultipartRequestExperimenter body = (MultipartRequestExperimenter) message.getMultipartRequestBody();
+ length += EXPERIMENTER_BODY_LENGTH;
+ if (body.getData() != null) {
+ length += body.getData().length;
+ }
+ }
+ return length;
+ }
+
+ private static int createMultipartRequestFlagsBitmask(MultipartRequestFlags flags) {
+ int multipartRequestFlagsBitmask = 0;
+ Map<Integer, Boolean> multipartRequestFlagsMap = new HashMap<>();
+ multipartRequestFlagsMap.put(0, flags.isOFPMPFREQMORE());
+ multipartRequestFlagsBitmask = ByteBufUtils.fillBitMaskFromMap(multipartRequestFlagsMap);
+ return multipartRequestFlagsBitmask;
+ }
+
+ /**
+ * @param multipartRequestBody
+ * @param output
+ */
+ private void encodeDescBody(MultipartRequestBody multipartRequestBody,
+ ByteBuf output) {
+ // The body of MultiPartRequestDesc is empty
+ }
+
+ /**
+ * @param multipartRequestBody
+ * @param out
+ */
+ private void encodeTableBody(MultipartRequestBody multipartRequestBody,
+ ByteBuf out) {
+ // The body of MultiPartTable is empty
+ }
+
+ private static void encodeFlowBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ encodeFlowAndAggregateBody(multipartRequestBody, output);
+ }
+
+ private static void encodeAggregateBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ encodeFlowAndAggregateBody(multipartRequestBody, output);
+ }
+
+ private static void encodeFlowAndAggregateBody(
+ MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ MultipartRequestFlow flow = (MultipartRequestFlow) multipartRequestBody;
+ OF10MatchSerializer.encodeMatchV10(output, flow.getMatchV10());
+ output.writeByte(flow.getTableId().shortValue());
+ ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_FLOW_BODY, output);
+ output.writeShort(flow.getOutPort().intValue());
+ }
+
+ private static void encodePortBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ MultipartRequestPortStats portstats = (MultipartRequestPortStats) multipartRequestBody;
+ output.writeShort(portstats.getPortNo().intValue());
+ ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_PORT_BODY, output);
+ }
+
+ private static void encodeQueueBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ MultipartRequestQueue queue = (MultipartRequestQueue) multipartRequestBody;
+ output.writeShort(queue.getPortNo().intValue());
+ ByteBufUtils.padBuffer(PADING_IN_QUEUE_BODY, output);
+ output.writeInt(queue.getQueueId().intValue());
+ }
+
+ private static void encodeExperimenterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
+ MultipartRequestExperimenter experimenter = (MultipartRequestExperimenter) multipartRequestBody;
+ output.writeInt(experimenter.getExperimenter().intValue());
+ output.writeBytes(experimenter.getData());
+ }
+
+}
Code Review / openflowjava.git / blobdiff