2 * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.openflowjava.protocol.impl.serialization.factories;
11 import io.netty.buffer.ByteBuf;
12 import io.netty.buffer.UnpooledByteBufAllocator;
14 import java.util.ArrayList;
15 import java.util.List;
17 import org.junit.Assert;
18 import org.junit.Before;
19 import org.junit.Test;
20 import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;
21 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
22 import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey;
23 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
24 import org.opendaylight.openflowjava.protocol.impl.serialization.SerializerRegistryImpl;
25 import org.opendaylight.openflowjava.protocol.impl.util.BufferHelper;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowRemovedReason;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PacketInReason;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortReason;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetAsyncInput;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetAsyncInputBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.FlowRemovedMask;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.FlowRemovedMaskBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PacketInMask;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PacketInMaskBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMask;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMaskBuilder;
39 * @author timotej.kubas
40 * @author michal.polkorab
42 public class SetAsyncInputMessageFactoryTest {
44 private SerializerRegistry registry;
45 private OFSerializer<SetAsyncInput> setAsyncFactory;
48 * Initializes serializer registry and stores correct factory in field
51 public void startUp() {
52 registry = new SerializerRegistryImpl();
54 setAsyncFactory = registry.getSerializer(
55 new MessageTypeKey<>(EncodeConstants.OF13_VERSION_ID, SetAsyncInput.class));
60 * Testing of {@link SetAsyncInputMessageFactory} for correct translation from POJO
63 public void testSetAsyncInputMessage() throws Exception {
64 SetAsyncInputBuilder builder = new SetAsyncInputBuilder();
65 BufferHelper.setupHeader(builder, EncodeConstants.OF13_VERSION_ID);
66 builder.setPacketInMask(createPacketInMask());
67 builder.setPortStatusMask(createPortStatusMask());
68 builder.setFlowRemovedMask(createFlowRemowedMask());
69 SetAsyncInput message = builder.build();
71 ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();
72 setAsyncFactory.serialize(message, out);
74 BufferHelper.checkHeaderV13(out,(byte) 28, 32);
75 Assert.assertEquals("Wrong packetInMask", 7, out.readUnsignedInt());
76 Assert.assertEquals("Wrong packetInMask", 0, out.readUnsignedInt());
77 Assert.assertEquals("Wrong portStatusMask", 7, out.readUnsignedInt());
78 Assert.assertEquals("Wrong portStatusMask", 0, out.readUnsignedInt());
79 Assert.assertEquals("Wrong flowRemovedMask", 15, out.readUnsignedInt());
80 Assert.assertEquals("Wrong flowRemovedMask", 0, out.readUnsignedInt());
84 private static List<PacketInMask> createPacketInMask() {
85 List<PacketInMask> masks = new ArrayList<>();
86 PacketInMaskBuilder builder;
87 // OFPCR_ROLE_EQUAL or OFPCR_ROLE_MASTER
88 builder = new PacketInMaskBuilder();
89 List<PacketInReason> packetInReasonList = new ArrayList<>();
90 packetInReasonList.add(PacketInReason.OFPRNOMATCH);
91 packetInReasonList.add(PacketInReason.OFPRACTION);
92 packetInReasonList.add(PacketInReason.OFPRINVALIDTTL);
93 builder.setMask(packetInReasonList);
94 masks.add(builder.build());
96 builder = new PacketInMaskBuilder();
97 packetInReasonList = new ArrayList<>();
98 builder.setMask(packetInReasonList);
99 masks.add(builder.build());
103 private static List<PortStatusMask> createPortStatusMask() {
104 List<PortStatusMask> masks = new ArrayList<>();
105 PortStatusMaskBuilder builder;
106 builder = new PortStatusMaskBuilder();
107 // OFPCR_ROLE_EQUAL or OFPCR_ROLE_MASTER
108 List<PortReason> portReasonList = new ArrayList<>();
109 portReasonList.add(PortReason.OFPPRADD);
110 portReasonList.add(PortReason.OFPPRDELETE);
111 portReasonList.add(PortReason.OFPPRMODIFY);
112 builder.setMask(portReasonList);
113 masks.add(builder.build());
115 builder = new PortStatusMaskBuilder();
116 portReasonList = new ArrayList<>();
117 builder.setMask(portReasonList);
118 masks.add(builder.build());
122 private static List<FlowRemovedMask> createFlowRemowedMask() {
123 List<FlowRemovedMask> masks = new ArrayList<>();
124 FlowRemovedMaskBuilder builder;
125 // OFPCR_ROLE_EQUAL or OFPCR_ROLE_MASTER
126 builder = new FlowRemovedMaskBuilder();
127 List<FlowRemovedReason> flowRemovedReasonList = new ArrayList<>();
128 flowRemovedReasonList.add(FlowRemovedReason.OFPRRIDLETIMEOUT);
129 flowRemovedReasonList.add(FlowRemovedReason.OFPRRHARDTIMEOUT);
130 flowRemovedReasonList.add(FlowRemovedReason.OFPRRDELETE);
131 flowRemovedReasonList.add(FlowRemovedReason.OFPRRGROUPDELETE);
132 builder.setMask(flowRemovedReasonList);
133 masks.add(builder.build());
135 builder = new FlowRemovedMaskBuilder();
136 flowRemovedReasonList = new ArrayList<>();
137 builder.setMask(flowRemovedReasonList);
138 masks.add(builder.build());
144 * Testing of {@link SetAsyncInputMessageFactory} for correct translation from POJO
147 public void testSetAsyncInputWithNullMasks() throws Exception {
148 SetAsyncInputBuilder builder = new SetAsyncInputBuilder();
149 BufferHelper.setupHeader(builder, EncodeConstants.OF13_VERSION_ID);
150 builder.setPacketInMask(null);
151 builder.setPortStatusMask(null);
152 builder.setFlowRemovedMask(null);
153 SetAsyncInput message = builder.build();
155 ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();
156 setAsyncFactory.serialize(message, out);
158 BufferHelper.checkHeaderV13(out,(byte) 28, 8);
159 Assert.assertTrue("Unexpected data", out.readableBytes() == 0);