2 * Copyright IBM Corporation, 2013. 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.List;
13 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.Counter32;
14 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.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;
49 * Class is an utility class for converting group related statistics messages coming from switch to MD-SAL
52 * @author avishnoi@in.ibm.com
54 public class MeterStatsResponseConvertor {
57 * Method converts list of OF Meter Stats to SAL Meter Stats.
59 * @param allMeterStats
60 * @return List of MeterStats
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));
70 return convertedSALMeters;
75 * Method convert MeterStats message from library to MD SAL defined MeterStats
77 * @param meterStats MeterStats from library
78 * @return MeterStats -- MeterStats defined in MD-SAL
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) {
83 MeterStatsBuilder salMeterStats = new MeterStatsBuilder();
84 salMeterStats.setByteInCount(new Counter64(meterStats.getByteInCount()));
86 DurationBuilder time = new DurationBuilder();
87 time.setSecond(new Counter32(meterStats.getDurationSec()));
88 time.setNanosecond(new Counter32(meterStats.getDurationNsec()));
89 salMeterStats.setDuration(time.build());
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()));
96 List<MeterBandStats> allMeterBandStats = meterStats.getMeterBandStats();
98 MeterBandStatsBuilder meterBandStatsBuilder = new MeterBandStatsBuilder();
99 List<BandStat> listAllBandStats = new ArrayList<BandStat>();
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);
109 listAllBandStats.add(bandStatBuilder.build());
111 meterBandStatsBuilder.setBandStat(listAllBandStats);
112 salMeterStats.setMeterBandStats(meterBandStatsBuilder.build());
113 return salMeterStats.build();
117 * Method convert list of OF Meter config Stats to SAL Meter Config stats
119 * @param allMeterConfigs
120 * @return list of MeterConfigStats
122 public List<MeterConfigStats> toSALMeterConfigList(List<MeterConfig> allMeterConfigs) {
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()));
130 MeterBandHeadersBuilder meterBandHeadersBuilder = new MeterBandHeadersBuilder();
131 List<Bands> bands = meterConfig.getBands();
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>();
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());
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);
156 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
157 meterBandTypesBuilder.setFlags(new MeterBandType(true, false, false));
158 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
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());
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);
176 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
177 meterBandTypesBuilder.setFlags(new MeterBandType(false, true, false));
178 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
179 listBandHeaders.add(meterBandHeaderBuilder.build());
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());
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);
195 MeterBandTypesBuilder meterBandTypesBuilder = new MeterBandTypesBuilder();
196 meterBandTypesBuilder.setFlags(new MeterBandType(false, false, true));
197 meterBandHeaderBuilder.setMeterBandTypes(meterBandTypesBuilder.build());
199 listBandHeaders.add(meterBandHeaderBuilder.build());
204 meterBandHeadersBuilder.setMeterBandHeader(listBandHeaders);
205 meterConfigStatsBuilder.setMeterBandHeaders(meterBandHeadersBuilder.build());
206 listMeterConfigStats.add(meterConfigStatsBuilder.build());
209 return listMeterConfigStats;