- pps_sut_tx = None
- pps_rx = delta_rx/single_core_measurement_duration/1000000
- RapidLog.info(self.report_result(flow_number, size,
- speed, pps_req_tx, pps_tx, pps_sut_tx, pps_rx,
- lat_avg_sample, sample_percentile, percentile_max,
- lat_max_sample, delta_dp_tx, delta_dp_rx,
- tot_dp_drop, single_core_measurement_duration))
- variables = {
- 'Flows': flow_number,
- 'Size': size,
- 'RequestedSpeed': self.get_pps(speed,size),
- 'CoreGenerated': pps_req_tx,
- 'SentByNIC': pps_tx,
- 'FwdBySUT': pps_sut_tx,
- 'RevByCore': pps_rx,
- 'AvgLatency': lat_avg_sample,
- 'PCTLatency': sample_percentile,
- 'MaxLatency': lat_max_sample,
- 'PacketsSent': delta_dp_tx,
- 'PacketsReceived': delta_dp_rx,
- 'PacketsLost': tot_dp_drop,
- 'bucket_size': bucket_size,
- 'buckets': buckets}
-
- self.post_data('rapid_flowsizetest', variables)
+ time_loop_data['pps_sut_tx'] = None
+ time_loop_data['pps_rx'] = delta_rx/time_loop_data['actual_duration']/1000000
+ time_loop_data['abs_tx'] = delta_dp_tx
+ time_loop_data['abs_rx'] = delta_dp_rx
+ time_loop_prefix = {'speed' : '',
+ 'lat_avg' : '',
+ 'lat_perc' : '',
+ 'lat_max' : '',
+ 'abs_drop_rate' : '',
+ 'drop_rate' : ''}
+ RapidLog.info(self.report_result(flow_number, size, time_loop_data,
+ time_loop_prefix))
+ time_loop_data['test'] = self.test['testname']
+ time_loop_data['environment_file'] = self.test['environment_file']
+ time_loop_data['Flows'] = flow_number
+ time_loop_data['Size'] = size
+ time_loop_data['RequestedSpeed'] = RapidTest.get_pps(speed, size)
+ _ = self.post_data(time_loop_data)