openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/PortModInputMessageFactoryTest.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
   2 package org.opendaylight.openflowjava.protocol.impl.serialization.factories;\r
   3 \r
   4 import io.netty.buffer.ByteBuf;\r
   5 import io.netty.buffer.UnpooledByteBufAllocator;\r
   6 import junit.framework.Assert;\r
   7 \r
   8 import org.junit.Test;\r
   9 import org.opendaylight.openflowjava.protocol.impl.deserialization.factories.HelloMessageFactoryTest;\r
  10 import org.opendaylight.openflowjava.protocol.impl.util.BufferHelper;\r
  11 import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;\r
  12 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;\r
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeatures;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInput;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInputBuilder;\r
  18 \r
  19 /**\r
  20  * @author timotej.kubas\r
  21  * @author michal.polkorab\r
  22  */\r
  23 public class PortModInputMessageFactoryTest {\r
  24     private static final byte MESSAGE_TYPE = 16;\r
  25     private static final byte PADDING_IN_PORT_MOD_MESSAGE_01 = 4;\r
  26     private static final byte PADDING_IN_PORT_MOD_MESSAGE_02 = 2;\r
  27     private static final byte PADDING_IN_PORT_MOD_MESSAGE_03 = 4;\r
  28     private static final int MESSAGE_LENGTH = 40;\r
  29     \r
  30     /**\r
  31      * Testing of {@link PortModInputMessageFactory} for correct translation from POJO\r
  32      * @throws Exception \r
  33      */\r
  34     @Test\r
  35     public void testPortModInput() throws Exception {\r
  36         PortModInputBuilder builder = new PortModInputBuilder();\r
  37         BufferHelper.setupHeader(builder, EncodeConstants.OF13_VERSION_ID);\r
  38         builder.setPortNo(new PortNumber(9L));\r
  39         builder.setHwAddress(new MacAddress("08002700B0EB"));\r
  40         builder.setConfig(new PortConfig(true, false, true, false));\r
  41         builder.setMask(new PortConfig(false, true, false, true));\r
  42         builder.setAdvertise(new PortFeatures(true, false, false, false,\r
  43                                               false, false, false, true, \r
  44                                               false, false, false, false, \r
  45                                               false, false, false, false));\r
  46         PortModInput message = builder.build();\r
  47         \r
  48         ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
  49         PortModInputMessageFactory factory = PortModInputMessageFactory.getInstance();\r
  50         factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
  51         \r
  52         BufferHelper.checkHeaderV13(out, MESSAGE_TYPE, MESSAGE_LENGTH);\r
  53         Assert.assertEquals("Wrong PortNo", message.getPortNo().getValue().longValue(), out.readUnsignedInt());\r
  54         out.skipBytes(PADDING_IN_PORT_MOD_MESSAGE_01);\r
  55         Assert.assertEquals("Wrong MacAddress", message.getHwAddress().getValue(), new MacAddress(makeMacAddress(out)).getValue());\r
  56         out.skipBytes(PADDING_IN_PORT_MOD_MESSAGE_02);\r
  57         Assert.assertEquals("Wrong config", message.getConfig(), createPortConfig(out.readInt()));\r
  58         Assert.assertEquals("Wrong mask", message.getMask(), createPortConfig(out.readInt()));\r
  59         Assert.assertEquals("Wrong advertise", message.getAdvertise(), createPortFeatures(out.readInt()));\r
  60         out.skipBytes(PADDING_IN_PORT_MOD_MESSAGE_03);\r
  61     }\r
  62 \r
  63     private static PortConfig createPortConfig(long input){\r
  64         final Boolean _portDown   = ((input) & (1<<0)) > 0;\r
  65         final Boolean _noRecv    = ((input) & (1<<2)) > 0;\r
  66         final Boolean _noFwd       = ((input) & (1<<5)) > 0;\r
  67         final Boolean _noPacketIn = ((input) & (1<<6)) > 0;\r
  68         return new PortConfig(_noFwd, _noPacketIn, _noRecv, _portDown);\r
  69     }\r
  70     \r
  71     private static PortFeatures createPortFeatures(long input){\r
  72         final Boolean _10mbHd = ((input) & (1<<0)) > 0;\r
  73         final Boolean _10mbFd = ((input) & (1<<1)) > 0;\r
  74         final Boolean _100mbHd = ((input) & (1<<2)) > 0;\r
  75         final Boolean _100mbFd = ((input) & (1<<3)) > 0;\r
  76         final Boolean _1gbHd = ((input) & (1<<4)) > 0;\r
  77         final Boolean _1gbFd = ((input) & (1<<5)) > 0;\r
  78         final Boolean _10gbFd = ((input) & (1<<6)) > 0;\r
  79         final Boolean _40gbFd = ((input) & (1<<7)) > 0;\r
  80         final Boolean _100gbFd = ((input) & (1<<8)) > 0;\r
  81         final Boolean _1tbFd = ((input) & (1<<9)) > 0;\r
  82         final Boolean _other = ((input) & (1<<10)) > 0;\r
  83         final Boolean _copper = ((input) & (1<<11)) > 0;\r
  84         final Boolean _fiber = ((input) & (1<<12)) > 0;\r
  85         final Boolean _autoneg = ((input) & (1<<13)) > 0;\r
  86         final Boolean _pause = ((input) & (1<<14)) > 0;\r
  87         final Boolean _pauseAsym = ((input) & (1<<15)) > 0;\r
  88         return new PortFeatures(_100gbFd, _100mbFd,  _100mbHd, _10gbFd, _10mbFd, _10mbHd, \r
  89                 _1gbFd, _1gbHd, _1tbFd, _40gbFd, _autoneg, _copper, _fiber, _other, _pause, _pauseAsym);\r
  90     }\r
  91     \r
  92     private static String makeMacAddress(ByteBuf input) {\r
  93         final int macAddressLength = 6;\r
  94         StringBuffer macToString = new StringBuffer();\r
  95         \r
  96         for(int i=0; i<macAddressLength; i++){\r
  97             short mac = 0;\r
  98             mac = input.readUnsignedByte();\r
  99             macToString.append(String.format("%02X", mac));\r
 100         }\r
 101         return macToString.toString();\r
 102     }\r
 103 }\r