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

   1 /*
   2  * Copyright (c) 2016 Cisco Systems, Inc. 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.Collection;
  13 import java.util.Collections;
  14 import java.util.List;
  15 import java.util.Set;
  16 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.Convertor;
  17 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionConvertorData;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.BandId;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterBandType;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterFlags;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterId;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.DropBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.DscpRemarkBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.band.type.band.type.ExperimenterBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.MeterBandHeadersBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStats;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStatsBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.config.stats.reply.MeterConfigStatsKey;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeader;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeaderBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.MeterBandHeaderKey;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.meter.meter.band.headers.meter.band.header.MeterBandTypesBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDropCase;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandDscpRemarkCase;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterCase;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.drop._case.MeterBandDrop;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.dscp.remark._case.MeterBandDscpRemark;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.meter.band.experimenter._case.MeterBandExperimenter;
  39 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;
  40 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;
  41 import org.opendaylight.yangtools.yang.common.Uint32;
  42
  43 /**
  44  * Converts list of OF library config meter stats to MD-SAL config meter stats.
  45  *
  46  * <p>
  47  * Example usage:
  48  * <pre>
  49  * {@code
  50  * VersionConvertorData data = new VersionConvertorData(version);
  51  * Optional<List<MeterConfigStats>> salMeterConfigStats = convertorManager.convert(ofMeterConfigStats, data);
  52  * }
  53  * </pre>
  54  */
  55 public class MeterConfigStatsResponseConvertor extends Convertor<List<MeterConfig>, List<MeterConfigStats>,
  56         VersionConvertorData> {
  57
  58     private static final Set<Class<?>> TYPES = Collections.singleton(MeterConfig.class);
  59
  60     @Override
  61     public Collection<Class<?>> getTypes() {
  62         return TYPES;
  63     }
  64
  65     @Override
  66     public List<MeterConfigStats> convert(final List<MeterConfig> source, final VersionConvertorData data) {
  67         List<MeterConfigStats> listMeterConfigStats = new ArrayList<>();
  68
  69         for (MeterConfig meterConfig : source) {
  70             MeterConfigStatsBuilder meterConfigStatsBuilder = new MeterConfigStatsBuilder();
  71             meterConfigStatsBuilder.setMeterId(new MeterId(meterConfig.getMeterId().getValue()));
  72             meterConfigStatsBuilder.withKey(new MeterConfigStatsKey(meterConfigStatsBuilder.getMeterId()));
  73             MeterBandHeadersBuilder meterBandHeadersBuilder = new MeterBandHeadersBuilder();
  74
  75             MeterFlags meterFlags = new MeterFlags(meterConfig.getFlags().isOFPMFBURST(),
  76                     meterConfig.getFlags().isOFPMFKBPS(),
  77                     meterConfig.getFlags().isOFPMFPKTPS(),
  78                     meterConfig.getFlags().isOFPMFSTATS());
  79
  80             meterConfigStatsBuilder.setFlags(meterFlags);
  81             List<MeterBandHeader> listBandHeaders = new ArrayList<>();
  82             int bandKey = 0;
  83
  84             for (Bands band : meterConfig.nonnullBands()) {
  85                 MeterBandHeaderBuilder meterBandHeaderBuilder = new MeterBandHeaderBuilder();
  86                 if (band.getMeterBand() instanceof MeterBandDropCase) {
  87                     MeterBandDropCase dropCaseBand = (MeterBandDropCase) band.getMeterBand();
  88                     MeterBandDrop dropBand = dropCaseBand.getMeterBandDrop();
  89                     DropBuilder dropBuilder = new DropBuilder();
  90                     dropBuilder.setDropBurstSize(dropBand.getBurstSize());
  91                     dropBuilder.setDropRate(dropBand.getRate());
  92                     meterBandHeaderBuilder.setBandType(dropBuilder.build());
  93
  94                     meterBandHeaderBuilder.setBandBurstSize(dropBand.getBurstSize());
  95                     meterBandHeaderBuilder.setBandRate(dropBand.getRate());
  96                     BandId bandId = new BandId(Uint32.valueOf(bandKey));
  97                     meterBandHeaderBuilder.withKey(new MeterBandHeaderKey(bandId));
  98                     meterBandHeaderBuilder.setBandId(bandId);
  99
 100                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 101                     meterBandTypesBuilder.setFlags(new MeterBandType(true, false, false));
 102                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 103
 104                     listBandHeaders.add(meterBandHeaderBuilder.build());
 105                 } else if (band.getMeterBand() instanceof MeterBandDscpRemarkCase) {
 106                     MeterBandDscpRemarkCase dscpRemarkCaseBand = (MeterBandDscpRemarkCase) band.getMeterBand();
 107                     MeterBandDscpRemark dscpRemarkBand = dscpRemarkCaseBand.getMeterBandDscpRemark();
 108                     DscpRemarkBuilder dscpRemarkBuilder = new DscpRemarkBuilder();
 109                     dscpRemarkBuilder.setDscpRemarkBurstSize(dscpRemarkBand.getBurstSize());
 110                     dscpRemarkBuilder.setDscpRemarkRate(dscpRemarkBand.getRate());
 111                     dscpRemarkBuilder.setPrecLevel(dscpRemarkBand.getPrecLevel());
 112                     meterBandHeaderBuilder.setBandType(dscpRemarkBuilder.build());
 113
 114                     meterBandHeaderBuilder.setBandBurstSize(dscpRemarkBand.getBurstSize());
 115                     meterBandHeaderBuilder.setBandRate(dscpRemarkBand.getRate());
 116                     BandId bandId = new BandId(Uint32.valueOf(bandKey));
 117                     meterBandHeaderBuilder.withKey(new MeterBandHeaderKey(bandId));
 118                     meterBandHeaderBuilder.setBandId(bandId);
 119
 120                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 121                     meterBandTypesBuilder.setFlags(new MeterBandType(false, true, false));
 122                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 123                     meterBandHeaderBuilder.withKey(new MeterBandHeaderKey(bandId));
 124                     listBandHeaders.add(meterBandHeaderBuilder.build());
 125
 126                 } else if (band.getMeterBand() instanceof MeterBandExperimenterCase) {
 127                     MeterBandExperimenterCase experimenterCaseBand = (MeterBandExperimenterCase) band.getMeterBand();
 128                     MeterBandExperimenter experimenterBand = experimenterCaseBand.getMeterBandExperimenter();
 129                     ExperimenterBuilder experimenterBuilder = new ExperimenterBuilder();
 130                     experimenterBuilder.setExperimenterBurstSize(experimenterBand.getBurstSize());
 131                     experimenterBuilder.setExperimenterRate(experimenterBand.getRate());
 132                     meterBandHeaderBuilder.setBandType(experimenterBuilder.build());
 133
 134                     meterBandHeaderBuilder.setBandBurstSize(experimenterBand.getBurstSize());
 135                     meterBandHeaderBuilder.setBandRate(experimenterBand.getRate());
 136                     BandId bandId = new BandId(Uint32.valueOf(bandKey));
 137                     meterBandHeaderBuilder.withKey(new MeterBandHeaderKey(bandId));
 138                     meterBandHeaderBuilder.setBandId(bandId);
 139
 140                     MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
 141                     meterBandTypesBuilder.setFlags(new MeterBandType(false, false, true));
 142                     meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
 143                     meterBandHeaderBuilder.withKey(new MeterBandHeaderKey(bandId));
 144
 145                     listBandHeaders.add(meterBandHeaderBuilder.build());
 146
 147                 }
 148                 bandKey++;
 149             }
 150
 151             meterBandHeadersBuilder.setMeterBandHeader(listBandHeaders);
 152             meterConfigStatsBuilder.setMeterBandHeaders(meterBandHeadersBuilder.build());
 153             listMeterConfigStats.add(meterConfigStatsBuilder.build());
 154         }
 155
 156         return listMeterConfigStats;
 157     }
 158 }