private List<OFMeterBand> buildBands() { return bands.stream().map(b -> { switch (b.type()) { case DROP: OFMeterBandDrop.Builder dropBuilder = factory.meterBands().buildDrop(); if (burst) { dropBuilder.setBurstSize(b.burst()); } dropBuilder.setRate(b.rate()); return dropBuilder.build(); case REMARK: OFMeterBandDscpRemark.Builder remarkBand = factory.meterBands().buildDscpRemark(); if (burst) { remarkBand.setBurstSize(b.burst()); } remarkBand.setRate(b.rate()); remarkBand.setPrecLevel(b.dropPrecedence()); return remarkBand.build(); default: log.warn("Unknown band type {}", b.type()); return null; } }).filter(Objects::nonNull).collect(Collectors.toList()); }
private Band band(OFMeterBand ofMeterBand) { DefaultBand.Builder builder = DefaultBand.builder(); if (ofMeterBand instanceof OFMeterBandDrop) { OFMeterBandDrop ofMeterBandDrop = (OFMeterBandDrop) ofMeterBand; builder.ofType(Band.Type.DROP) .burstSize(ofMeterBandDrop.getBurstSize()) .withRate(ofMeterBandDrop.getRate()); } else if (ofMeterBand instanceof OFMeterBandDscpRemark) { OFMeterBandDscpRemark ofMeterBandDscpRemark = (OFMeterBandDscpRemark) ofMeterBand; builder.ofType(Band.Type.REMARK) .burstSize(ofMeterBandDscpRemark.getBurstSize()) .withRate(ofMeterBandDscpRemark.getRate()) .dropPrecedence(ofMeterBandDscpRemark.getPrecLevel()); } else if (ofMeterBand instanceof OFMeterBandExperimenter) { OFMeterBandExperimenter ofMeterBandExperimenter = (OFMeterBandExperimenter) ofMeterBand; builder.ofType(Band.Type.EXPERIMENTAL) .burstSize(ofMeterBandExperimenter.getBurstSize()) .withRate(ofMeterBandExperimenter.getRate()); } return builder.build(); }
/*** * Serializes Meter Config Reply * @author Naveen * @param meterConfigReplies * @param jGen * @throws IOException * @throws JsonProcessingException */ public static void serializeMeterConfigReply(List<OFMeterConfigStatsReply> meterConfigReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{ OFMeterConfigStatsReply meterConfigReply = meterConfigReplies.get(0); jGen.writeStringField("version", meterConfigReply.getVersion().toString()); //return the enum name jGen.writeFieldName("meterConfig"); jGen.writeStartArray(); for (OFMeterConfig config : meterConfigReply.getEntries()) { jGen.writeStartObject(); jGen.writeNumberField("meterId", config.getMeterId()); jGen.writeNumberField("flags", config.getFlags()); jGen.writeFieldName("meterBands"); jGen.writeStartArray(); for (OFMeterBand band : config.getEntries()) { jGen.writeStartObject(); short type = (short)band.getType(); jGen.writeNumberField("bandType",type); switch (type) { case OFMeterBandTypeSerializerVer13.DROP_VAL: OFMeterBandDrop bandDrop = (OFMeterBandDrop) band; jGen.writeNumberField("rate", bandDrop.getRate()); jGen.writeNumberField("burstSize", bandDrop.getBurstSize()); break; case OFMeterBandTypeSerializerVer13.DSCP_REMARK_VAL: OFMeterBandDscpRemark bandDscp = (OFMeterBandDscpRemark) band; jGen.writeNumberField("rate", bandDscp.getRate()); jGen.writeNumberField("burstSize", bandDscp.getBurstSize()); jGen.writeNumberField("precLevel", bandDscp.getPrecLevel()); break; case OFMeterBandTypeSerializerVer13.EXPERIMENTER_VAL: OFMeterBandExperimenter bandExp = (OFMeterBandExperimenter) band; jGen.writeNumberField("rate", bandExp.getRate()); jGen.writeNumberField("burstSize", bandExp.getBurstSize()); jGen.writeNumberField("experimenter", bandExp.getExperimenter()); break; default: // shouldn't ever get here break; }//end of Switch Case jGen.writeEndObject(); }//end of for loop jGen.writeEndArray(); jGen.writeEndObject(); }//end of for loop jGen.writeEndArray(); }
/*** * Serializes Meter Config Reply * @author Naveen * @param meterConfigReplies * @param jGen * @throws IOException * @throws JsonProcessingException */ public static void serializeMeterConfigReply(List<OFMeterConfigStatsReply> meterConfigReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{ OFMeterConfigStatsReply meterConfigReply = meterConfigReplies.get(0); jGen.writeStringField("version", meterConfigReply.getVersion().toString()); //return the enum name jGen.writeFieldName("meterConfig"); jGen.writeStartArray(); for(OFMeterBand band : meterConfigReply.getEntries()) { jGen.writeStartObject(); short type = (short)band.getType(); jGen.writeNumberField("bandType",type); switch (type) { case OFMeterBandTypeSerializerVer13.DROP_VAL: OFMeterBandDrop bandDrop = (OFMeterBandDrop) band; jGen.writeNumberField("rate", bandDrop.getRate()); jGen.writeNumberField("burstSize", bandDrop.getBurstSize()); break; case OFMeterBandTypeSerializerVer13.DSCP_REMARK_VAL: OFMeterBandDscpRemark bandDscp = (OFMeterBandDscpRemark) band; jGen.writeNumberField("rate", bandDscp.getRate()); jGen.writeNumberField("burstSize", bandDscp.getBurstSize()); jGen.writeNumberField("precLevel", bandDscp.getPrecLevel()); break; case OFMeterBandTypeSerializerVer13.EXPERIMENTER_VAL: OFMeterBandExperimenter bandExp = (OFMeterBandExperimenter) band; jGen.writeNumberField("rate", bandExp.getRate()); jGen.writeNumberField("burstSize", bandExp.getBurstSize()); jGen.writeNumberField("experimenter", bandExp.getExperimenter()); break; default: // shouldn't ever get here break; }//end of Switch Case jGen.writeEndObject(); }//end of for loop jGen.writeEndArray(); }