openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/serialization/match/OxmMetadataSerializerTest.java

   1 /*\r
   2  * Copyright (c) 2014 Pantheon Technologies s.r.o. and others. All rights reserved.\r
   3  *\r
   4  * This program and the accompanying materials are made available under the\r
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html\r
   7  */\r
   8 \r
   9 package org.opendaylight.openflowjava.protocol.impl.serialization.match;\r
  10 \r
  11 import static org.junit.Assert.assertEquals;\r
  12 import static org.junit.Assert.assertTrue;\r
  13 import io.netty.buffer.ByteBuf;\r
  14 import io.netty.buffer.PooledByteBufAllocator;\r
  15 \r
  16 import org.junit.Assert;\r
  17 import org.junit.Test;\r
  18 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
  19 import org.opendaylight.openflowjava.protocol.api.util.OxmMatchConstants;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaskMatchEntry;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MaskMatchEntryBuilder;\r
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MetadataMatchEntry;\r
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.MetadataMatchEntryBuilder;\r
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.Metadata;\r
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OpenflowBasicClass;\r
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.grouping.MatchEntriesBuilder;\r
  27 \r
  28 /**\r
  29  * @author michal.polkorab\r
  30  *\r
  31  */\r
  32 public class OxmMetadataSerializerTest {\r
  33 \r
  34     OxmMetadataSerializer serializer = new OxmMetadataSerializer();\r
  35 \r
  36     /**\r
  37      * Test correct serialization\r
  38      */\r
  39     @Test\r
  40     public void testSerializeWithoutMask() {\r
  41         MatchEntriesBuilder builder = prepareMatchEntry(false, new byte[]{0, 1, 2, 3, 4, 5, 6, 7});\r
  42         \r
  43         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();\r
  44         serializer.serialize(builder.build(), buffer);\r
  45 \r
  46         checkHeader(buffer, false);\r
  47         byte[] address = new byte[8];\r
  48         buffer.readBytes(address);\r
  49         Assert.assertArrayEquals("Wrong address", new byte[]{0, 1, 2, 3, 4, 5, 6, 7}, address);\r
  50         assertTrue("Unexpected data", buffer.readableBytes() == 0);\r
  51     }\r
  52 \r
  53     /**\r
  54      * Test correct serialization\r
  55      */\r
  56     @Test\r
  57     public void testSerializeWithMask() {\r
  58         MatchEntriesBuilder builder = prepareMatchEntry(true, new byte[]{8, 9, 10, 11, 12, 13, 14, 15});\r
  59         \r
  60         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();\r
  61         serializer.serialize(builder.build(), buffer);\r
  62 \r
  63         checkHeader(buffer, true);\r
  64         \r
  65         byte[] address = new byte[8];\r
  66         buffer.readBytes(address);\r
  67         Assert.assertArrayEquals("Wrong address", new byte[]{8, 9, 10, 11, 12, 13, 14, 15}, address);\r
  68         byte[] tmp = new byte[8];\r
  69         buffer.readBytes(tmp);\r
  70         Assert.assertArrayEquals("Wrong mask", new byte[]{30, 30, 25, 25, 15, 15, 0, 0}, tmp);\r
  71         assertTrue("Unexpected data", buffer.readableBytes() == 0);\r
  72     }\r
  73 \r
  74     /**\r
  75      * Test correct header serialization\r
  76      */\r
  77     @Test\r
  78     public void testSerializeHeaderWithoutMask() {\r
  79         MatchEntriesBuilder builder = prepareHeader(false);\r
  80         \r
  81         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();\r
  82         serializer.serializeHeader(builder.build(), buffer);\r
  83 \r
  84         checkHeader(buffer, false);\r
  85         assertTrue("Unexpected data", buffer.readableBytes() == 0);\r
  86     }\r
  87 \r
  88     /**\r
  89      * Test correct header serialization\r
  90      */\r
  91     @Test\r
  92     public void testSerializeHeaderWithMask() {\r
  93         MatchEntriesBuilder builder = prepareHeader(true);\r
  94         \r
  95         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();\r
  96         serializer.serializeHeader(builder.build(), buffer);\r
  97 \r
  98         checkHeader(buffer, true);\r
  99         assertTrue("Unexpected data", buffer.readableBytes() == 0);\r
 100     }\r
 101 \r
 102     /**\r
 103      * Test correct oxm-class return value\r
 104      */\r
 105     @Test\r
 106     public void testGetOxmClassCode() {\r
 107         assertEquals("Wrong oxm-class", OxmMatchConstants.OPENFLOW_BASIC_CLASS, serializer.getOxmClassCode());\r
 108     }\r
 109 \r
 110     /**\r
 111      * Test correct oxm-field return value\r
 112      */\r
 113     @Test\r
 114     public void getOxmFieldCode() {\r
 115         assertEquals("Wrong oxm-class", OxmMatchConstants.METADATA, serializer.getOxmFieldCode());\r
 116     }\r
 117 \r
 118     /**\r
 119      * Test correct value length return value\r
 120      */\r
 121     @Test\r
 122     public void testGetValueLength() {\r
 123         assertEquals("Wrong value length", EncodeConstants.SIZE_OF_LONG_IN_BYTES, serializer.getValueLength());\r
 124     }\r
 125 \r
 126     private static MatchEntriesBuilder prepareMatchEntry(boolean hasMask, byte[] value) {\r
 127         MatchEntriesBuilder builder = prepareHeader(hasMask);\r
 128         if (hasMask) {\r
 129             MaskMatchEntryBuilder maskBuilder = new MaskMatchEntryBuilder();\r
 130             maskBuilder.setMask(new byte[]{30, 30, 25, 25, 15, 15, 0, 0});\r
 131             builder.addAugmentation(MaskMatchEntry.class, maskBuilder.build());\r
 132         }\r
 133         MetadataMatchEntryBuilder metadataBuilder = new MetadataMatchEntryBuilder();\r
 134         metadataBuilder.setMetadata(value);\r
 135         builder.addAugmentation(MetadataMatchEntry.class, metadataBuilder.build());\r
 136         return builder;\r
 137     }\r
 138 \r
 139     private static MatchEntriesBuilder prepareHeader(boolean hasMask) {\r
 140         MatchEntriesBuilder builder = new MatchEntriesBuilder();\r
 141         builder.setOxmClass(OpenflowBasicClass.class);\r
 142         builder.setOxmMatchField(Metadata.class);\r
 143         builder.setHasMask(hasMask);\r
 144         return builder;\r
 145     }\r
 146 \r
 147     private static void checkHeader(ByteBuf buffer, boolean hasMask) {\r
 148         assertEquals("Wrong oxm-class", OxmMatchConstants.OPENFLOW_BASIC_CLASS, buffer.readUnsignedShort());\r
 149         short fieldAndMask = buffer.readUnsignedByte();\r
 150         assertEquals("Wrong oxm-field", OxmMatchConstants.METADATA, fieldAndMask >>> 1);\r
 151         assertEquals("Wrong hasMask", hasMask, (fieldAndMask & 1) != 0);\r
 152         if (hasMask) {\r
 153             assertEquals("Wrong length", 2 * EncodeConstants.SIZE_OF_LONG_IN_BYTES, buffer.readUnsignedByte());\r
 154         } else {\r
 155             assertEquals("Wrong length", EncodeConstants.SIZE_OF_LONG_IN_BYTES, buffer.readUnsignedByte());\r
 156         }\r
 157     }\r
 158 }