1. 包列表
  2. 类列表
  3. org.projectfloodlight.openflow.protocol.OFMeterBandStats

Java 类org.projectfloodlight.openflow.protocol.OFMeterBandStats 实例源码

项目：athena    文件：OpenFlowMeterProvider.java    
private Collection<Band> buildBands(List<OFMeterBandStats> bandStats) {
    return bandStats.stream().map(stat -> {
        DefaultBand band = DefaultBand.builder().build();
        band.setBytes(stat.getByteBandCount().getValue());
        band.setPackets(stat.getPacketBandCount().getValue());
        return band;
    }).collect(Collectors.toSet());
}
项目：fresco_floodlight    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：iTAP-controller    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：SDN-Multicast    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：arscheduler    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：floodlight1.2-delay    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：floodlight-hardware    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：ACAMPController    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：fast-failover-demo    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：floodlightLB    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：DSC    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：floodlight    文件：StatsReplySerializer.java    
/***
 * Serializes the Meter Statistics Reply
 * @author Naveen
 * @param meterReplies
 * @param jGen
 * @throws IOException
 * @throws JsonProcessingException
 */
public static void serializeMeterReply(List<OFMeterStatsReply> meterReplies, JsonGenerator jGen) throws IOException, JsonProcessingException{
    OFMeterStatsReply meterReply = meterReplies.get(0); // we will get only one meterReply and it will contains many OFMeterStatsEntry ?
    jGen.writeStringField("version", meterReply.getVersion().toString()); //return the enum name
    jGen.writeFieldName("meter");
    jGen.writeStartArray();
    for(OFMeterStats entry : meterReply.getEntries()) {
        jGen.writeStartObject();
        jGen.writeNumberField("meterId",entry.getMeterId());                        
        jGen.writeNumberField("flowCount", entry.getFlowCount());
        jGen.writeNumberField("packetInCount", entry.getPacketInCount().getValue());
        jGen.writeNumberField("byteInCount", entry.getByteInCount().getValue());
        jGen.writeFieldName("meterBandStats");
        jGen.writeStartArray();
        for(OFMeterBandStats bandStats : entry.getBandStats()) {
            jGen.writeStartObject();
            jGen.writeNumberField("packetBandCount", bandStats.getPacketBandCount().getValue());
            jGen.writeNumberField("byteBandCount", bandStats.getByteBandCount().getValue());
            jGen.writeEndObject();
        }//End of for loop - bandStats
        jGen.writeEndArray();          

        jGen.writeNumberField("durationSec", entry.getDurationSec());
        jGen.writeNumberField("durationNsec", entry.getDurationNsec());            
        jGen.writeEndObject();
    }//End of for loop - MeterStats
    jGen.writeEndArray();
}
项目：onos    文件：OpenFlowMeterProvider.java    
private Collection<Band> buildBands(List<OFMeterBandStats> bandStats) {
    return bandStats.stream().map(stat -> {
        DefaultBand band = ((DefaultBand.Builder) DefaultBand.builder().ofType(DefaultBand.Type.DROP)).build();
        band.setBytes(stat.getByteBandCount().getValue());
        band.setPackets(stat.getPacketBandCount().getValue());
        return band;
    }).collect(Collectors.toList());
}