2 * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.
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
9 package org.opendaylight.openflowplugin.openflow.md.core.sal.convertor;
11 import java.util.ArrayList;
12 import java.util.Collection;
13 import java.util.Collections;
14 import java.util.List;
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.binding.DataContainer;
44 * Converts list of OF library config meter stats to MD-SAL config meter stats.
49 * VersionConvertorData data = new VersionConvertorData(version);
50 * Optional<List<MeterConfigStats>> salMeterConfigStats = convertorManager.convert(ofMeterConfigStats, data);
54 public class MeterConfigStatsResponseConvertor extends Convertor<List<MeterConfig>, List<MeterConfigStats>, VersionConvertorData> {
56 private static final Set<Class<?>> TYPES = Collections.singleton(MeterConfig.class);
59 public Collection<Class<?>> getTypes() {
64 public List<MeterConfigStats> convert(List<MeterConfig> source, VersionConvertorData data) {
65 List<MeterConfigStats> listMeterConfigStats = new ArrayList<>();
67 for (MeterConfig meterConfig : source) {
68 MeterConfigStatsBuilder meterConfigStatsBuilder = new MeterConfigStatsBuilder();
69 meterConfigStatsBuilder.setMeterId(new MeterId(meterConfig.getMeterId().getValue()));
70 meterConfigStatsBuilder.setKey(new MeterConfigStatsKey(meterConfigStatsBuilder.getMeterId()));
71 MeterBandHeadersBuilder meterBandHeadersBuilder = new MeterBandHeadersBuilder();
72 List<Bands> bands = meterConfig.getBands();
74 MeterFlags meterFlags = new MeterFlags(meterConfig.getFlags().isOFPMFBURST(),
75 meterConfig.getFlags().isOFPMFKBPS(),
76 meterConfig.getFlags().isOFPMFPKTPS(),
77 meterConfig.getFlags().isOFPMFSTATS());
79 meterConfigStatsBuilder.setFlags(meterFlags);
80 List<MeterBandHeader> listBandHeaders = new ArrayList<>();
83 for (Bands band : bands) {
84 MeterBandHeaderBuilder meterBandHeaderBuilder = new MeterBandHeaderBuilder();
85 if (band.getMeterBand() instanceof MeterBandDropCase) {
86 MeterBandDropCase dropCaseBand = (MeterBandDropCase) band.getMeterBand();
87 MeterBandDrop dropBand = dropCaseBand.getMeterBandDrop();
88 DropBuilder dropBuilder = new DropBuilder();
89 dropBuilder.setDropBurstSize(dropBand.getBurstSize());
90 dropBuilder.setDropRate(dropBand.getRate());
91 meterBandHeaderBuilder.setBandType(dropBuilder.build());
93 meterBandHeaderBuilder.setBandBurstSize(dropBand.getBurstSize());
94 meterBandHeaderBuilder.setBandRate(dropBand.getRate());
95 BandId bandId = new BandId((long) bandKey);
96 meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
97 meterBandHeaderBuilder.setBandId(bandId);
99 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
100 meterBandTypesBuilder.setFlags(new MeterBandType(true, false, false));
101 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
103 listBandHeaders.add(meterBandHeaderBuilder.build());
104 } else if (band.getMeterBand() instanceof MeterBandDscpRemarkCase) {
105 MeterBandDscpRemarkCase dscpRemarkCaseBand = (MeterBandDscpRemarkCase) band.getMeterBand();
106 MeterBandDscpRemark dscpRemarkBand = dscpRemarkCaseBand.getMeterBandDscpRemark();
107 DscpRemarkBuilder dscpRemarkBuilder = new DscpRemarkBuilder();
108 dscpRemarkBuilder.setDscpRemarkBurstSize(dscpRemarkBand.getBurstSize());
109 dscpRemarkBuilder.setDscpRemarkRate(dscpRemarkBand.getRate());
110 dscpRemarkBuilder.setPrecLevel(dscpRemarkBand.getPrecLevel());
111 meterBandHeaderBuilder.setBandType(dscpRemarkBuilder.build());
113 meterBandHeaderBuilder.setBandBurstSize(dscpRemarkBand.getBurstSize());
114 meterBandHeaderBuilder.setBandRate(dscpRemarkBand.getRate());
115 BandId bandId = new BandId((long) bandKey);
116 meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
117 meterBandHeaderBuilder.setBandId(bandId);
119 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
120 meterBandTypesBuilder.setFlags(new MeterBandType(false, true, false));
121 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
122 listBandHeaders.add(meterBandHeaderBuilder.build());
124 } else if (band.getMeterBand() instanceof MeterBandExperimenterCase) {
125 MeterBandExperimenterCase experimenterCaseBand = (MeterBandExperimenterCase) band.getMeterBand();
126 MeterBandExperimenter experimenterBand = experimenterCaseBand.getMeterBandExperimenter();
127 ExperimenterBuilder experimenterBuilder = new ExperimenterBuilder();
128 experimenterBuilder.setExperimenterBurstSize(experimenterBand.getBurstSize());
129 experimenterBuilder.setExperimenterRate(experimenterBand.getRate());
130 meterBandHeaderBuilder.setBandType(experimenterBuilder.build());
132 meterBandHeaderBuilder.setBandBurstSize(experimenterBand.getBurstSize());
133 meterBandHeaderBuilder.setBandRate(experimenterBand.getRate());
134 BandId bandId = new BandId((long) bandKey);
135 meterBandHeaderBuilder.setKey(new MeterBandHeaderKey(bandId));
136 meterBandHeaderBuilder.setBandId(bandId);
138 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
139 meterBandTypesBuilder.setFlags(new MeterBandType(false, false, true));
140 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
142 listBandHeaders.add(meterBandHeaderBuilder.build());
149 meterBandHeadersBuilder.setMeterBandHeader(listBandHeaders);
150 meterConfigStatsBuilder.setMeterBandHeaders(meterBandHeadersBuilder.build());
151 listMeterConfigStats.add(meterConfigStatsBuilder.build());
154 return listMeterConfigStats;