Skip to content

Commit

Permalink
Parallel fix for TCP
Browse files Browse the repository at this point in the history
  • Loading branch information
Neil Tallim committed Sep 8, 2022
1 parent fcb8da9 commit 0d604e1
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions src/stream/tcp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -511,6 +511,7 @@ pub mod sender {


let interval_duration = Duration::from_secs_f32(self.send_interval);
let mut interval_iteration = 0;
let bytes_to_send = ((self.test_definition.bandwidth as f32) * super::INTERVAL.as_secs_f32()) as i64;
let mut bytes_to_send_remaining = bytes_to_send;
let bytes_to_send_per_interval_slice = ((bytes_to_send as f32) * self.send_interval) as i64;
Expand Down Expand Up @@ -567,10 +568,12 @@ pub mod sender {
sleep(super::INTERVAL - elapsed_time);
}
} else if bytes_to_send_per_interval_slice_remaining <= 0 { // interval subsection exhausted
interval_iteration += 1;
bytes_to_send_per_interval_slice_remaining = bytes_to_send_per_interval_slice;
let elapsed_time = cycle_start.elapsed();
if interval_duration > elapsed_time {
sleep(interval_duration - elapsed_time);
let interval_endtime = interval_iteration * interval_duration;
if interval_endtime > elapsed_time {
sleep(interval_endtime - elapsed_time);
}
}
self.remaining_duration -= packet_start.elapsed().as_secs_f32();
Expand Down

0 comments on commit 0d604e1

Please sign in to comment.