openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/MeterModInputMessageFactory.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.List;\r
   8 import java.util.Map;\r
   9 \r
  10 import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
  11 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;\r
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MeterBandCommons;\r
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MeterModInput;\r
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.MeterBand;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDrop;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemark;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenter;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.mod.Bands;\r
  20 \r
  21 /**\r
  22  * @author timotej.kubas\r
  23  * @author michal.polkorab\r
  24  */\r
  25 public class MeterModInputMessageFactory implements OFSerializer<MeterModInput> {\r
  26     private static final byte MESSAGE_TYPE = 29;\r
  27     private static final int MESSAGE_LENGTH = 16;\r
  28     private static final short LENGTH_OF_METER_BANDS = 16;\r
  29     private static final short PADDING_IN_METER_BAND_DROP = 4;\r
  30     private static final short PADDING_IN_METER_BAND_DSCP_REMARK = 3;\r
  31     private static MeterModInputMessageFactory instance;\r
  32     \r
  33     private MeterModInputMessageFactory() {\r
  34         // singleton\r
  35     }\r
  36     \r
  37     /**\r
  38      * @return singleton factory\r
  39      */\r
  40     public static synchronized MeterModInputMessageFactory getInstance() {\r
  41         if (instance == null) {\r
  42             instance = new MeterModInputMessageFactory();\r
  43         }\r
  44         return instance;\r
  45     }\r
  46     \r
  47     @Override\r
  48     public void messageToBuffer(short version, ByteBuf out,\r
  49             MeterModInput message) {\r
  50         ByteBufUtils.writeOFHeader(instance, message, out);\r
  51         out.writeShort(message.getCommand().getIntValue());\r
  52         out.writeShort(createMeterFlagsBitmask(message.getFlags()));\r
  53         out.writeInt(message.getMeterId().getValue().intValue());\r
  54         encodeBands(message.getBands(), out);\r
  55     }\r
  56 \r
  57     @Override\r
  58     public int computeLength(MeterModInput message) {\r
  59         int length = MESSAGE_LENGTH;\r
  60         if (message.getBands() != null) {\r
  61             length += message.getBands().size() * LENGTH_OF_METER_BANDS;\r
  62         }\r
  63         return length;\r
  64     }\r
  65 \r
  66     @Override\r
  67     public byte getMessageType() {\r
  68         return MESSAGE_TYPE;\r
  69     }\r
  70 \r
  71     private static int createMeterFlagsBitmask(MeterFlags flags) {\r
  72         int meterFlagBitmask = 0;\r
  73         Map<Integer, Boolean> meterModFlagsMap = new HashMap<>();\r
  74         meterModFlagsMap.put(0, flags.isOFPMFKBPS());\r
  75         meterModFlagsMap.put(1, flags.isOFPMFPKTPS());\r
  76         meterModFlagsMap.put(2, flags.isOFPMFBURST());\r
  77         meterModFlagsMap.put(3, flags.isOFPMFSTATS());\r
  78         \r
  79         meterFlagBitmask = ByteBufUtils.fillBitMaskFromMap(meterModFlagsMap);\r
  80         return meterFlagBitmask;\r
  81     }\r
  82     \r
  83     private static void encodeBands(List<Bands> bands, ByteBuf outBuffer) {\r
  84         if (bands != null) {\r
  85             for (Bands currentBand : bands) {\r
  86                 MeterBand meterBand = currentBand.getMeterBand();\r
  87                 writeBandCommonFields((MeterBandCommons) meterBand, outBuffer);\r
  88                 if (meterBand instanceof MeterBandDrop) {\r
  89                     ByteBufUtils.padBuffer(PADDING_IN_METER_BAND_DROP, outBuffer);\r
  90                 } else if (meterBand instanceof MeterBandDscpRemark) {\r
  91                     MeterBandDscpRemark dscpRemarkBand = (MeterBandDscpRemark) meterBand;\r
  92                     outBuffer.writeByte(dscpRemarkBand.getPrecLevel());\r
  93                     ByteBufUtils.padBuffer(PADDING_IN_METER_BAND_DSCP_REMARK, outBuffer);\r
  94                 } else if (meterBand instanceof MeterBandExperimenter) {\r
  95                     MeterBandExperimenter experimenterBand = (MeterBandExperimenter) meterBand;\r
  96                     outBuffer.writeInt(experimenterBand.getExperimenter().intValue());\r
  97                 }\r
  98             }\r
  99         }\r
 100     }\r
 101     \r
 102     private static void writeBandCommonFields(MeterBandCommons meterBand, ByteBuf outBuffer) {\r
 103         outBuffer.writeShort(meterBand.getType().getIntValue());\r
 104         outBuffer.writeShort(LENGTH_OF_METER_BANDS);\r
 105         outBuffer.writeInt(meterBand.getRate().intValue());\r
 106         outBuffer.writeInt(meterBand.getBurstSize().intValue());\r
 107     }\r
 108     \r
 109 }\r