openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/OF10PortModInputMessageFactory.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 \r
   6 import java.util.HashMap;\r
   7 import java.util.Map;\r
   8 \r
   9 import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
  10 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfigV10;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortFeaturesV10;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInput;\r
  14 \r
  15 /**\r
  16  * Translates PortMod messages\r
  17  * @author michal.polkorab\r
  18  */\r
  19 public class OF10PortModInputMessageFactory implements OFSerializer<PortModInput> {\r
  20 \r
  21     private static final byte MESSAGE_TYPE = 15;\r
  22     private static final byte PADDING_IN_PORT_MOD_MESSAGE = 4;\r
  23     private static final int MESSAGE_LENGTH = 32;\r
  24     \r
  25     private static OF10PortModInputMessageFactory instance;\r
  26     \r
  27     private OF10PortModInputMessageFactory() {\r
  28         // singleton\r
  29     }\r
  30     \r
  31     /**\r
  32      * @return singleton factory\r
  33      */\r
  34     public static synchronized OF10PortModInputMessageFactory getInstance() {\r
  35         if (instance == null) {\r
  36             instance = new OF10PortModInputMessageFactory();\r
  37         }\r
  38         return instance;\r
  39     }\r
  40     \r
  41     @Override\r
  42     public void messageToBuffer(short version, ByteBuf out, PortModInput message) {\r
  43         ByteBufUtils.writeOFHeader(instance, message, out);\r
  44         out.writeShort(message.getPortNo().getValue().intValue());\r
  45         out.writeBytes(ByteBufUtils.hexStringToBytes(message.getHwAddress().getValue(), false));\r
  46         out.writeInt(createPortConfigBitmask(message.getConfigV10()));\r
  47         out.writeInt(createPortConfigBitmask(message.getMaskV10()));\r
  48         out.writeInt(createPortFeaturesBitmask(message.getAdvertiseV10()));\r
  49         ByteBufUtils.padBuffer(PADDING_IN_PORT_MOD_MESSAGE, out);\r
  50     }\r
  51 \r
  52     @Override\r
  53     public int computeLength(PortModInput message) {\r
  54         return MESSAGE_LENGTH;\r
  55     }\r
  56 \r
  57     @Override\r
  58     public byte getMessageType() {\r
  59         return MESSAGE_TYPE;\r
  60     }\r
  61    \r
  62     \r
  63     /**\r
  64      * @param config\r
  65      * @return port config bitmask \r
  66      */\r
  67     private static int createPortConfigBitmask(PortConfigV10 config) {\r
  68         int configBitmask = 0;\r
  69         Map<Integer, Boolean> portConfigMap = new HashMap<>();\r
  70         portConfigMap.put(0, config.isPortDown());\r
  71         portConfigMap.put(1, config.isNoStp());\r
  72         portConfigMap.put(2, config.isNoRecv());\r
  73         portConfigMap.put(3, config.isNoRecvStp());\r
  74         portConfigMap.put(4, config.isNoFlood());\r
  75         portConfigMap.put(5, config.isNoFwd());\r
  76         portConfigMap.put(6, config.isNoPacketIn());\r
  77         \r
  78         configBitmask = ByteBufUtils.fillBitMaskFromMap(portConfigMap);\r
  79         return configBitmask;\r
  80     }\r
  81     \r
  82     private static int createPortFeaturesBitmask(PortFeaturesV10 feature) {\r
  83         int configBitmask = 0;\r
  84         Map<Integer, Boolean> portFeaturesMap = new HashMap<>();\r
  85         portFeaturesMap.put(0, feature.is_10mbHd());\r
  86         portFeaturesMap.put(1, feature.is_10mbFd());\r
  87         portFeaturesMap.put(2, feature.is_100mbHd());\r
  88         portFeaturesMap.put(3, feature.is_100mbFd());\r
  89         portFeaturesMap.put(4, feature.is_1gbHd());\r
  90         portFeaturesMap.put(5, feature.is_1gbFd());\r
  91         portFeaturesMap.put(6, feature.is_10gbFd());\r
  92         portFeaturesMap.put(7, feature.isCopper());\r
  93         portFeaturesMap.put(8, feature.isFiber());\r
  94         portFeaturesMap.put(9, feature.isAutoneg());\r
  95         portFeaturesMap.put(10, feature.isPause());\r
  96         portFeaturesMap.put(11, feature.isPauseAsym());\r
  97         configBitmask = ByteBufUtils.fillBitMaskFromMap(portFeaturesMap);\r
  98         return configBitmask;\r
  99     }\r
 100 }\r