'stop_date': self.stop,
'Flows': flow_number,
'Size': size,
- 'RequestedSpeed': RapidTest.get_pps(speed,size),
+ 'RequestedSpeed': RapidTest.get_pps(endspeed,size),
'CoreGenerated': endpps_req_tx,
'SentByNIC': endpps_tx,
'FwdBySUT': endpps_sut_tx,
'MaxLatency': endlat_max,
'PacketsSent': endabs_tx,
'PacketsReceived': endabs_rx,
- 'PacketsLost': abs_dropped,
+ 'PacketsLost': endabs_dropped,
'bucket_size': bucket_size,
'buckets': endbuckets}
self.post_data('rapid_flowsizetest', variables)
log.debug('\n---------\nLog closed on %s.\n---------\n' % time.asctime())
# Roll over on application start
- log.handlers[0].doRollover()
+ file_handler.doRollover()
# Add timestamp
log.debug('\n---------\nLog started on %s.\n---------\n' % time.asctime())
RapidLog.info(self.report_result(flow_number,size,speed,None,None,None,None,lat_avg,sample_percentile,percentile_max,lat_max, dp_tx, dp_rx , None, None))
tot_rx = tot_non_dp_rx = tot_tx = tot_non_dp_tx = tot_drop = 0
lat_avg = used_avg = 0
- buckets_total = [0] * 128
- tot_lat_samples = 0
+ buckets_total = [buckets[i] for i in range(len(buckets))]
+ tot_lat_samples = sum(buckets)
tot_lat_measurement_duration = float(0)
tot_core_measurement_duration = float(0)
tot_sut_core_measurement_duration = float(0)