openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10StatsRequestInputFactory.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
   2 package org.opendaylight.openflowjava.protocol.impl.serialization.factories;\r
   3 \r
   4 import io.netty.buffer.ByteBuf;\r
   5 \r
   6 import java.util.HashMap;\r
   7 import java.util.Map;\r
   8 \r
   9 import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
  10 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
  11 import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchSerializer;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregate;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDesc;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenter;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlow;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStats;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueue;\r
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTable;\r
  23 \r
  24 /**\r
  25  * Translates StatsRequest messages\r
  26  * @author michal.polkorab\r
  27  */\r
  28 public class OF10StatsRequestInputFactory implements OFSerializer<MultipartRequestInput> {\r
  29 \r
  30     private static final byte MESSAGE_TYPE = 16;\r
  31     private static final int MESSAGE_LENGTH = 12;\r
  32     private static final byte FLOW_BODY_LENGTH = 44;\r
  33     private static final byte AGGREGATE_BODY_LENGTH = 44;\r
  34     private static final byte PORT_STATS_BODY_LENGTH = 8;\r
  35     private static final byte QUEUE_BODY_LENGTH = 8;\r
  36     private static final byte EXPERIMENTER_BODY_LENGTH = 4;\r
  37     private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;\r
  38     private static final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;\r
  39     private static final byte PADING_IN_QUEUE_BODY = 2;\r
  40 \r
  41     private static OF10StatsRequestInputFactory instance; \r
  42     \r
  43     private OF10StatsRequestInputFactory() {\r
  44         // singleton\r
  45     }\r
  46     \r
  47     /**\r
  48      * @return singleton factory\r
  49      */\r
  50     public static synchronized OF10StatsRequestInputFactory getInstance() {\r
  51         if (instance == null) {\r
  52             instance = new OF10StatsRequestInputFactory();\r
  53         }\r
  54         return instance;\r
  55     }\r
  56     \r
  57     @Override\r
  58     public void messageToBuffer(short version, ByteBuf out,\r
  59             MultipartRequestInput message) {\r
  60         ByteBufUtils.writeOFHeader(instance, message, out);\r
  61         out.writeShort(message.getType().getIntValue());\r
  62         out.writeShort(createMultipartRequestFlagsBitmask(message.getFlags()));\r
  63         if (message.getMultipartRequestBody() instanceof MultipartRequestDesc) {\r
  64             encodeDescBody(message.getMultipartRequestBody(), out);\r
  65         } else if (message.getMultipartRequestBody() instanceof MultipartRequestFlow) {\r
  66             encodeFlowBody(message.getMultipartRequestBody(), out);\r
  67         } else if (message.getMultipartRequestBody() instanceof MultipartRequestAggregate) {\r
  68             encodeAggregateBody(message.getMultipartRequestBody(), out);\r
  69         } else if (message.getMultipartRequestBody() instanceof MultipartRequestTable) {\r
  70             encodeTableBody(message.getMultipartRequestBody(), out);\r
  71         } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStats) {\r
  72             encodePortBody(message.getMultipartRequestBody(), out);\r
  73         } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueue) {\r
  74             encodeQueueBody(message.getMultipartRequestBody(), out);\r
  75         } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenter) {\r
  76             encodeExperimenterBody(message.getMultipartRequestBody(), out);\r
  77         }\r
  78     }\r
  79     \r
  80     @Override\r
  81     public int computeLength(MultipartRequestInput message) {\r
  82         return MESSAGE_LENGTH + computeBodyLength(message);\r
  83     }\r
  84     @Override\r
  85     public byte getMessageType() {\r
  86         return MESSAGE_TYPE;\r
  87     }\r
  88     \r
  89     /**\r
  90      * \r
  91      * @param message\r
  92      * @return length of MultipartRequestMessage\r
  93      */\r
  94     public int computeBodyLength(MultipartRequestInput message) {\r
  95         int length = 0;\r
  96         MultipartType type = message.getType();\r
  97         if (type.equals(MultipartType.OFPMPFLOW)) {\r
  98             length += FLOW_BODY_LENGTH;\r
  99         } else if (type.equals(MultipartType.OFPMPAGGREGATE)) {\r
 100             length += AGGREGATE_BODY_LENGTH;\r
 101         } else if (type.equals(MultipartType.OFPMPPORTSTATS)) {\r
 102             length += PORT_STATS_BODY_LENGTH;\r
 103         } else if (type.equals(MultipartType.OFPMPQUEUE)) {\r
 104             length += QUEUE_BODY_LENGTH;\r
 105         } else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {\r
 106             MultipartRequestExperimenter body = (MultipartRequestExperimenter) message.getMultipartRequestBody();\r
 107             length += EXPERIMENTER_BODY_LENGTH;\r
 108             if (body.getData() != null) {\r
 109                 length += body.getData().length;\r
 110             }\r
 111         }\r
 112         return length;\r
 113     }\r
 114     \r
 115     private static int createMultipartRequestFlagsBitmask(MultipartRequestFlags flags) {\r
 116         int multipartRequestFlagsBitmask = 0;\r
 117         Map<Integer, Boolean> multipartRequestFlagsMap = new HashMap<>();\r
 118         multipartRequestFlagsMap.put(0, flags.isOFPMPFREQMORE());\r
 119         multipartRequestFlagsBitmask = ByteBufUtils.fillBitMaskFromMap(multipartRequestFlagsMap);\r
 120         return multipartRequestFlagsBitmask;\r
 121     }\r
 122     \r
 123     /**\r
 124      * @param multipartRequestBody  \r
 125      * @param output \r
 126      */\r
 127     private void encodeDescBody(MultipartRequestBody multipartRequestBody,\r
 128             ByteBuf output) {\r
 129         // The body of MultiPartRequestDesc is empty\r
 130     }\r
 131 \r
 132     /**\r
 133      * @param multipartRequestBody\r
 134      * @param out\r
 135      */\r
 136     private void encodeTableBody(MultipartRequestBody multipartRequestBody,\r
 137             ByteBuf out) {\r
 138      // The body of MultiPartTable is empty\r
 139     }\r
 140     \r
 141     private static void encodeFlowBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 142         encodeFlowAndAggregateBody(multipartRequestBody, output);\r
 143     }\r
 144     \r
 145     private static void encodeAggregateBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 146         encodeFlowAndAggregateBody(multipartRequestBody, output);\r
 147     }\r
 148 \r
 149     private static void encodeFlowAndAggregateBody(\r
 150             MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 151         MultipartRequestFlow flow = (MultipartRequestFlow) multipartRequestBody;\r
 152         OF10MatchSerializer.encodeMatchV10(output, flow.getMatchV10());\r
 153         output.writeByte(flow.getTableId().shortValue());\r
 154         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_FLOW_BODY, output);\r
 155         output.writeShort(flow.getOutPort().intValue());\r
 156     }\r
 157     \r
 158     private static void encodePortBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 159         MultipartRequestPortStats portstats = (MultipartRequestPortStats) multipartRequestBody;\r
 160         output.writeShort(portstats.getPortNo().intValue());\r
 161         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_PORT_BODY, output);\r
 162     }\r
 163     \r
 164     private static void encodeQueueBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 165         MultipartRequestQueue queue = (MultipartRequestQueue) multipartRequestBody;\r
 166         output.writeShort(queue.getPortNo().intValue());\r
 167         ByteBufUtils.padBuffer(PADING_IN_QUEUE_BODY, output);\r
 168         output.writeInt(queue.getQueueId().intValue());\r
 169     }\r
 170     \r
 171     private static void encodeExperimenterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
 172         MultipartRequestExperimenter experimenter = (MultipartRequestExperimenter) multipartRequestBody;\r
 173         output.writeInt(experimenter.getExperimenter().intValue());\r
 174         output.writeBytes(experimenter.getData());\r
 175     }\r
 176     \r
 177 }\r