openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/MeterStatsResponseConvertor.java

   1 /*
   2  * Copyright (c) 2013, 2015 IBM Corporation 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.openflowplugin.openflow.md.core.sal.convertor;
  10
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter32;
  14 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter64;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.BandId;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterBandType;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterFlags;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterId;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.DropBuilder;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.DscpRemarkBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.ExperimenterBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.MeterBandHeadersBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStats;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStatsBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStatsKey;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeader;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeaderBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeaderKey;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.meter.band.header.MeterBandTypesBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.DurationBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.MeterBandStatsBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.meter.band.stats.BandStat;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.meter.band.stats.BandStatBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.meter.band.stats.BandStatKey;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply.MeterStats;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply.MeterStatsBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.statistics.reply.MeterStatsKey;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDropCase;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemarkCase;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterCase;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.drop._case.MeterBandDrop;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.dscp.remark._case.MeterBandDscpRemark;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.experimenter._case.MeterBandExperimenter;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.meter.stats.MeterBandStats;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.MeterConfig;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.meter.config._case.multipart.reply.meter.config.meter.config.Bands;
  47
  48 /**
  49  * Class is an utility class for converting group related statistics messages coming from switch to MD-SAL
  50  * messages.
  51  *
  52  * @author avishnoi@in.ibm.com
  53  */
  54 public class MeterStatsResponseConvertor {
  55
  56     /**
  57      * Method converts list of OF Meter Stats to SAL Meter Stats.
  58      *
  59      * @param allMeterStats all meter stats
  60      * @return List of MeterStats
  61      */
  62     public List<MeterStats> toSALMeterStatsList(
  63             List<org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply
  64                     .multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStats> allMeterStats) {
  65         List<MeterStats> convertedSALMeters = new ArrayList<MeterStats>();
  66         for (org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.
  67                 multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStats meter : allMeterStats) {
  68             convertedSALMeters.add(toSALMeterStats(meter));
  69         }
  70         return convertedSALMeters;
  71
  72     }
  73
  74     /**
  75      * Method convert MeterStats message from library to MD SAL defined MeterStats
  76      *
  77      * @param meterStats MeterStats from library
  78      * @return MeterStats -- MeterStats defined in MD-SAL
  79      */
  80     public MeterStats toSALMeterStats(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply
  81                                               .multipart.reply.body.multipart.reply.meter._case.multipart.reply.meter.MeterStats meterStats) {
  82
  83         MeterStatsBuilder salMeterStats = new MeterStatsBuilder();
  84         salMeterStats.setByteInCount(new Counter64(meterStats.getByteInCount()));
  85
  86         DurationBuilder time = new DurationBuilder();
  87         time.setSecond(new Counter32(meterStats.getDurationSec()));
  88         time.setNanosecond(new Counter32(meterStats.getDurationNsec()));
  89         salMeterStats.setDuration(time.build());
  90
  91         salMeterStats.setFlowCount(new Counter32(meterStats.getFlowCount()));
  92         salMeterStats.setMeterId(new MeterId(meterStats.getMeterId().getValue()));
  93         salMeterStats.setPacketInCount(new Counter64(meterStats.getPacketInCount()));
  94         salMeterStats.setKey(new MeterStatsKey(salMeterStats.getMeterId()));
  95
  96         List<MeterBandStats> allMeterBandStats = meterStats.getMeterBandStats();
  97
  98         MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();
  99         List<BandStat> listAllBandStats = new ArrayList<BandStat>();
 100         int bandKey = 0;
 101         for (MeterBandStats meterBandStats : allMeterBandStats) {
 102             BandStatBuilder bandStatBuilder = new BandStatBuilder();
 103             bandStatBuilder.setByteBandCount(new Counter64(meterBandStats.getByteBandCount()));
 104             bandStatBuilder.setPacketBandCount(new Counter64(meterBandStats.getPacketBandCount()));
 105             BandId bandId = new BandId((long) bandKey);
 106             bandStatBuilder.setKey(new BandStatKey(bandId));
 107             bandStatBuilder.setBandId(bandId);
 108             bandKey++;
 109             listAllBandStats.add(bandStatBuilder.build());
 110         }
 111         meterBandStatsBuilder.setBandStat(listAllBandStats);
 112         salMeterStats.setMeterBandStats(meterBandStatsBuilder.build());
 113         return salMeterStats.build();
 114     }
 115
 116     /**
 117      * Method convert list of OF Meter config Stats to SAL Meter Config stats
 118      *
 119      * @param allMeterConfigs all meter configs
 120      * @return list of MeterConfigStats
 121      */
 122     public List<MeterConfigStats> toSALMeterConfigList(List<MeterConfig> allMeterConfigs) {
 123
 124         List<MeterConfigStats> listMeterConfigStats = new ArrayList<MeterConfigStats>();
 125         for (MeterConfig meterConfig : allMeterConfigs) {
 126             MeterConfigStatsBuilder meterConfigStatsBuilder = new MeterConfigStatsBuilder();
 127             meterConfigStatsBuilder.setMeterId(new MeterId(meterConfig.getMeterId().getValue()));
 128             meterConfigStatsBuilder.setKey(new MeterConfigStatsKey(meterConfigStatsBuilder.getMeterId()));
 129
 130             MeterBandHeadersBuilder meterBandHeadersBuilder = new MeterBandHeadersBuilder();
 131             List<Bands> bands = meterConfig.getBands();
 132
 133             MeterFlags meterFlags = new MeterFlags(meterConfig.getFlags().isOFPMFBURST(),
 134                     meterConfig.getFlags().isOFPMFKBPS(),
 135                     meterConfig.getFlags().isOFPMFPKTPS(),
 136                     meterConfig.getFlags().isOFPMFSTATS());
 137             meterConfigStatsBuilder.setFlags(meterFlags);
 138             List<MeterBandHeader> listBandHeaders = new ArrayList<MeterBandHeader>();
 139             int bandKey = 0;
 140             for (Bands band : bands) {
 141                 MeterBandHeaderBuilder meterBandHeaderBuilder = new MeterBandHeaderBuilder();
 142                 if (band.getMeterBand() instanceof MeterBandDropCase) {
 143                     MeterBandDropCase dropCaseBand = (MeterBandDropCase) band.getMeterBand();
 144                     MeterBandDrop dropBand = dropCaseBand.getMeterBandDrop();
 145                     DropBuilder dropBuilder = new DropBuilder();
 146                     dropBuilder.setDropBurstSize(dropBand.getBurstSize());
 147                     dropBuilder.setDropRate(dropBand.getRate());
 148                     meterBandHeaderBuilder.setBandType(dropBuilder.build());
 149
 150                     meterBandHeaderBuilder.setBandBurstSize(dropBand.getBurstSize());
 151                     meterBandHeaderBuilder.setBandRate(dropBand.getRate());
 152                     BandId bandId = new BandId((long) bandKey);
 153                     meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
 154                     meterBandHeaderBuilder.setBandId(bandId);
 155
 156                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 157                     meterBandTypesBuilder.setFlags(new MeterBandType(true, false, false));
 158                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 159
 160                     listBandHeaders.add(meterBandHeaderBuilder.build());
 161                 } else if (band.getMeterBand() instanceof MeterBandDscpRemarkCase) {
 162                     MeterBandDscpRemarkCase dscpRemarkCaseBand = (MeterBandDscpRemarkCase) band.getMeterBand();
 163                     MeterBandDscpRemark dscpRemarkBand = dscpRemarkCaseBand.getMeterBandDscpRemark();
 164                     DscpRemarkBuilder dscpRemarkBuilder = new DscpRemarkBuilder();
 165                     dscpRemarkBuilder.setDscpRemarkBurstSize(dscpRemarkBand.getBurstSize());
 166                     dscpRemarkBuilder.setDscpRemarkRate(dscpRemarkBand.getRate());
 167                     dscpRemarkBuilder.setPrecLevel(dscpRemarkBand.getPrecLevel());
 168                     meterBandHeaderBuilder.setBandType(dscpRemarkBuilder.build());
 169
 170                     meterBandHeaderBuilder.setBandBurstSize(dscpRemarkBand.getBurstSize());
 171                     meterBandHeaderBuilder.setBandRate(dscpRemarkBand.getRate());
 172                     BandId bandId = new BandId((long) bandKey);
 173                     meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
 174                     meterBandHeaderBuilder.setBandId(bandId);
 175
 176                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 177                     meterBandTypesBuilder.setFlags(new MeterBandType(false, true, false));
 178                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 179                     listBandHeaders.add(meterBandHeaderBuilder.build());
 180
 181                 } else if (band.getMeterBand() instanceof MeterBandExperimenterCase) {
 182                     MeterBandExperimenterCase experimenterCaseBand = (MeterBandExperimenterCase) band.getMeterBand();
 183                     MeterBandExperimenter experimenterBand = experimenterCaseBand.getMeterBandExperimenter();
 184                     ExperimenterBuilder experimenterBuilder = new ExperimenterBuilder();
 185                     experimenterBuilder.setExperimenterBurstSize(experimenterBand.getBurstSize());
 186                     experimenterBuilder.setExperimenterRate(experimenterBand.getRate());
 187                     meterBandHeaderBuilder.setBandType(experimenterBuilder.build());
 188
 189                     meterBandHeaderBuilder.setBandBurstSize(experimenterBand.getBurstSize());
 190                     meterBandHeaderBuilder.setBandRate(experimenterBand.getRate());
 191                     BandId bandId = new BandId((long) bandKey);
 192                     meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
 193                     meterBandHeaderBuilder.setBandId(bandId);
 194
 195                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 196                     meterBandTypesBuilder.setFlags(new MeterBandType(false, false, true));
 197                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 198
 199                     listBandHeaders.add(meterBandHeaderBuilder.build());
 200
 201                 }
 202                 bandKey++;
 203             }
 204             meterBandHeadersBuilder.setMeterBandHeader(listBandHeaders);
 205             meterConfigStatsBuilder.setMeterBandHeaders(meterBandHeadersBuilder.build());
 206             listMeterConfigStats.add(meterConfigStatsBuilder.build());
 207         }
 208
 209         return listMeterConfigStats;
 210     }
 211 }