b9e0f6ed0076b1466d2f3989a92a41a247d906bf
[openflowjava.git] / openflow-protocol-impl / src / test / java / org / opendaylight / openflowjava / protocol / impl / deserialization / factories / QueueGetConfigReplyMessageFactoryMultiTest.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.junit.Assert;\r
10 import org.junit.Test;\r
11 import org.opendaylight.openflowjava.protocol.impl.util.BufferHelper;\r
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueId;\r
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueProperty;\r
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigOutput;\r
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.packet.queue.Properties;\r
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.packet.queue.PropertiesBuilder;\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 \r
21 /**\r
22  * @author timotej.kubas\r
23  * @author michal.polkorab\r
24  */\r
25 public class QueueGetConfigReplyMessageFactoryMultiTest {\r
26 \r
27     /**\r
28      * Testing of {@link QueueGetConfigReplyMessageFactory} for correct\r
29      * translation into POJO\r
30      */\r
31     @Test\r
32     public void test() {\r
33         ByteBuf bb = BufferHelper.buildBuffer("00 01 02 03 " + // port\r
34                 "00 00 00 00 " + // padding\r
35                 "00 00 00 01 " + // queueId\r
36                 "00 00 00 01 " + // port\r
37                 "00 00 00 00 00 00 00 00 " + // pad\r
38                 "00 01 " + // property\r
39                 "00 00 00 00 00 00 " + // pad\r
40                 "00 00 00 02 " + // queueId\r
41                 "00 00 00 02 " + // port\r
42                 "00 00 00 00 00 00 00 00 " + // pad\r
43                 "00 01 " + // property\r
44                 "00 00 00 00 00 00 " + // pad\r
45                 "00 00 00 03 " + // queueId\r
46                 "00 00 00 03 " + // port\r
47                 "00 00 00 00 00 00 00 00 " + // pad\r
48                 "00 01 " + // property\r
49                 "00 00 00 00 00 00" // pad\r
50         );\r
51 \r
52         GetQueueConfigOutput builtByFactory = BufferHelper.decodeV13(\r
53                 QueueGetConfigReplyMessageFactory.getInstance(), bb);\r
54 \r
55         BufferHelper.checkHeaderV13(builtByFactory);\r
56         Assert.assertEquals("Wrong port", 66051L, builtByFactory.getPort().getValue().longValue());\r
57         Assert.assertEquals("Wrong queues", builtByFactory.getQueues(),\r
58                 createQueuesList());\r
59     }\r
60 \r
61     private static List<Queues> createQueuesList() {\r
62         List<Queues> queuesList = new ArrayList<>();\r
63         QueuesBuilder qb = new QueuesBuilder();\r
64         for (int i = 1; i <= 3; i++) {\r
65             qb.setQueueId(new QueueId((long) i));\r
66             qb.setPort(new PortNumber((long) i));\r
67             qb.setProperties(createPropertiesList());\r
68             queuesList.add(qb.build());\r
69         }\r
70         return queuesList;\r
71     }\r
72 \r
73     private static List<Properties> createPropertiesList() {\r
74         List<Properties> propertiesList = new ArrayList<>();\r
75         PropertiesBuilder pb = new PropertiesBuilder();\r
76         pb.setProperty(QueueProperty.values()[1]);\r
77         propertiesList.add(pb.build());\r
78         return propertiesList;\r
79     }\r
80 \r
81 }\r