openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/factories/QueueGetConfigReplyMessageFactory.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
   2 package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;\r
   3 \r
   4 import io.netty.buffer.ByteBuf;\r
   5 \r
   6 import java.util.ArrayList;\r
   7 import java.util.List;\r
   8 \r
   9 import org.opendaylight.openflowjava.protocol.impl.deserialization.OFDeserializer;\r
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterQueuePropertyBuilder;\r
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.RateQueueProperty;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.RateQueuePropertyBuilder;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueId;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueProperties;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigOutput;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigOutputBuilder;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.get.config.reply.Queues;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.get.config.reply.QueuesBuilder;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.property.header.QueueProperty;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.property.header.QueuePropertyBuilder;\r
  22 \r
  23 /**\r
  24  * @author timotej.kubas\r
  25  * @author michal.polkorab\r
  26  */\r
  27 public class QueueGetConfigReplyMessageFactory implements OFDeserializer<GetQueueConfigOutput> {\r
  28 \r
  29     private static final byte PADDING_IN_QUEUE_GET_CONFIG_REPLY_HEADER = 4;\r
  30     private static final byte PADDING_IN_PACKET_QUEUE_HEADER = 6;\r
  31     private static final byte PADDING_IN_QUEUE_PROPERTY_HEADER = 4;\r
  32     private static final int PADDING_IN_RATE_QUEUE_PROPERTY = 6;\r
  33     private static final int PADDING_IN_EXPERIMENTER_QUEUE_PROPERTY = 4;\r
  34     private static final byte PACKET_QUEUE_LENGTH = 16;\r
  35 \r
  36     private static QueueGetConfigReplyMessageFactory instance;\r
  37     \r
  38     private QueueGetConfigReplyMessageFactory() {\r
  39         // singleton\r
  40     }\r
  41     \r
  42     /**\r
  43      * \r
  44      * @return singleton factory\r
  45      */\r
  46     public static synchronized QueueGetConfigReplyMessageFactory getInstance(){\r
  47         \r
  48         if(instance == null){\r
  49             instance = new QueueGetConfigReplyMessageFactory();\r
  50         }\r
  51         return instance;\r
  52     }\r
  53     \r
  54     @Override\r
  55     public GetQueueConfigOutput bufferToMessage(ByteBuf rawMessage, short version) {\r
  56         GetQueueConfigOutputBuilder builder = new GetQueueConfigOutputBuilder();\r
  57         builder.setVersion(version);\r
  58         builder.setXid((rawMessage.readUnsignedInt()));\r
  59         builder.setPort(new PortNumber(rawMessage.readUnsignedInt()));\r
  60         rawMessage.skipBytes(PADDING_IN_QUEUE_GET_CONFIG_REPLY_HEADER);\r
  61         builder.setQueues(createQueuesList(rawMessage));\r
  62         return builder.build();\r
  63     }\r
  64     \r
  65     private static List<Queues> createQueuesList(ByteBuf input){\r
  66         List<Queues> queuesList = new ArrayList<>();\r
  67         while (input.readableBytes() > 0) {\r
  68             QueuesBuilder queueBuilder = new QueuesBuilder();\r
  69             queueBuilder.setQueueId(new QueueId(input.readUnsignedInt()));\r
  70             queueBuilder.setPort(new PortNumber(input.readUnsignedInt()));\r
  71             int length = input.readUnsignedShort();\r
  72             input.skipBytes(PADDING_IN_PACKET_QUEUE_HEADER);\r
  73             queueBuilder.setQueueProperty(createPropertiesList(input, length - PACKET_QUEUE_LENGTH));\r
  74             queuesList.add(queueBuilder.build());\r
  75         } \r
  76         return queuesList;\r
  77     }\r
  78     \r
  79     private static List<QueueProperty> createPropertiesList(ByteBuf input, int length){\r
  80         int propertiesLength = length;\r
  81         List<QueueProperty> propertiesList = new ArrayList<>();\r
  82         while (propertiesLength > 0) {\r
  83             QueuePropertyBuilder propertiesBuilder = new QueuePropertyBuilder();\r
  84             QueueProperties property = QueueProperties.forValue(input.readUnsignedShort());\r
  85             propertiesBuilder.setProperty(property);\r
  86             int currentPropertyLength = input.readUnsignedShort();\r
  87             propertiesLength -= currentPropertyLength;\r
  88             input.skipBytes(PADDING_IN_QUEUE_PROPERTY_HEADER);\r
  89             if (property.equals(QueueProperties.OFPQTMINRATE) || property.equals(QueueProperties.OFPQTMAXRATE)) {\r
  90                 RateQueuePropertyBuilder rateBuilder = new RateQueuePropertyBuilder();\r
  91                 rateBuilder.setRate(input.readUnsignedShort());\r
  92                 propertiesBuilder.addAugmentation(RateQueueProperty.class, rateBuilder.build());\r
  93                 input.skipBytes(PADDING_IN_RATE_QUEUE_PROPERTY);\r
  94             } else if (property.equals(QueueProperties.OFPQTEXPERIMENTER)) {\r
  95                 ExperimenterQueuePropertyBuilder expBuilder = new ExperimenterQueuePropertyBuilder();\r
  96                 expBuilder.setExperimenter(input.readUnsignedInt());\r
  97                 input.skipBytes(PADDING_IN_EXPERIMENTER_QUEUE_PROPERTY);\r
  98                 expBuilder.setData(input.readBytes(currentPropertyLength\r
  99                         - Integer.SIZE / Byte.SIZE - PADDING_IN_EXPERIMENTER_QUEUE_PROPERTY).array());\r
 100                 propertiesBuilder.addAugmentation(RateQueueProperty.class, expBuilder.build());\r
 101             }\r
 102             propertiesList.add(propertiesBuilder.build());\r
 103         }\r
 104         return propertiesList;\r
 105     }\r
 106 \r
 107 }\r