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

   1 /*
   2  * Copyright (c) 2014 Pantheon Technologies s.r.o. and others. All rights reserved.
   3  *
   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
   7  */
   8
   9 package org.opendaylight.openflowjava.protocol.impl.serialization.match;
  10
  11 import static org.junit.Assert.assertEquals;
  12 import static org.junit.Assert.assertTrue;
  13 import io.netty.buffer.ByteBuf;
  14 import io.netty.buffer.PooledByteBufAllocator;
  15
  16 import org.junit.Test;
  17 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  18 import org.opendaylight.openflowjava.protocol.api.util.OxmMatchConstants;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.TcMatchEntry;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.TcMatchEntryBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.MplsTc;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.OpenflowBasicClass;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.grouping.MatchEntriesBuilder;
  24
  25 /**
  26  * @author michal.polkorab
  27  *
  28  */
  29 public class OxmMplsTcSerializerTest {
  30
  31     OxmMplsTcSerializer serializer = new OxmMplsTcSerializer();
  32
  33     /**
  34      * Test correct serialization
  35      */
  36     @Test
  37     public void testSerialize() {
  38         MatchEntriesBuilder builder = prepareMplsTcMatchEntry((short) 16);
  39
  40         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();
  41         serializer.serialize(builder.build(), buffer);
  42
  43         checkHeader(buffer, false);
  44         assertEquals("Wrong value", 16, buffer.readUnsignedByte());
  45         assertTrue("Unexpected data", buffer.readableBytes() == 0);
  46     }
  47
  48     /**
  49      * Test correct header serialization
  50      */
  51     @Test
  52     public void testSerializeHeader() {
  53         MatchEntriesBuilder builder = prepareMplsTcHeader(false);
  54
  55         ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer();
  56         serializer.serializeHeader(builder.build(), buffer);
  57
  58         checkHeader(buffer, false);
  59         assertTrue("Unexpected data", buffer.readableBytes() == 0);
  60     }
  61
  62     /**
  63      * Test correct oxm-class return value
  64      */
  65     @Test
  66     public void testGetOxmClassCode() {
  67         assertEquals("Wrong oxm-class", OxmMatchConstants.OPENFLOW_BASIC_CLASS, serializer.getOxmClassCode());
  68     }
  69
  70     /**
  71      * Test correct oxm-field return value
  72      */
  73     @Test
  74     public void getOxmFieldCode() {
  75         assertEquals("Wrong oxm-class", OxmMatchConstants.MPLS_TC, serializer.getOxmFieldCode());
  76     }
  77
  78     /**
  79      * Test correct value length return value
  80      */
  81     @Test
  82     public void testGetValueLength() {
  83         assertEquals("Wrong value length", EncodeConstants.SIZE_OF_BYTE_IN_BYTES, serializer.getValueLength());
  84     }
  85
  86     private static MatchEntriesBuilder prepareMplsTcMatchEntry(short value) {
  87         MatchEntriesBuilder builder = prepareMplsTcHeader(false);
  88         TcMatchEntryBuilder tcBuilder = new TcMatchEntryBuilder();
  89         tcBuilder.setTc(value);
  90         builder.addAugmentation(TcMatchEntry.class, tcBuilder.build());
  91         return builder;
  92     }
  93
  94     private static MatchEntriesBuilder prepareMplsTcHeader(boolean hasMask) {
  95         MatchEntriesBuilder builder = new MatchEntriesBuilder();
  96         builder.setOxmClass(OpenflowBasicClass.class);
  97         builder.setOxmMatchField(MplsTc.class);
  98         builder.setHasMask(hasMask);
  99         return builder;
 100     }
 101
 102     private static void checkHeader(ByteBuf buffer, boolean hasMask) {
 103         assertEquals("Wrong oxm-class", OxmMatchConstants.OPENFLOW_BASIC_CLASS, buffer.readUnsignedShort());
 104         short fieldAndMask = buffer.readUnsignedByte();
 105         assertEquals("Wrong oxm-field", OxmMatchConstants.MPLS_TC, fieldAndMask >>> 1);
 106         assertEquals("Wrong hasMask", hasMask, (fieldAndMask & 1) != 0);
 107         assertEquals("Wrong length", EncodeConstants.SIZE_OF_BYTE_IN_BYTES, buffer.readUnsignedByte());
 108     }
 109 }