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

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