Adds iperf timeout for bandwith measurements.
This commit is contained in:
@@ -803,10 +803,11 @@ class Client:
|
|||||||
tcp_algo[congestion_control_index],
|
tcp_algo[congestion_control_index],
|
||||||
]
|
]
|
||||||
is_measurement_done = False
|
is_measurement_done = False
|
||||||
while not is_measurement_done:
|
iperf_return = 0
|
||||||
|
while not is_measurement_done or iperf_return != 0:
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
subprocess.call(iperf_command, timeout=float(time) + TIMEOUT_OFFSET)
|
iperf_return = subprocess.call(iperf_command, timeout=float(time) + TIMEOUT_OFFSET)
|
||||||
is_measurement_done = True
|
is_measurement_done = True
|
||||||
except:
|
except:
|
||||||
print_message("iPerf timed out. Retry...")
|
print_message("iPerf timed out. Retry...")
|
||||||
@@ -868,10 +869,11 @@ class Client:
|
|||||||
)
|
)
|
||||||
sleep(2)
|
sleep(2)
|
||||||
is_measurement_done = False
|
is_measurement_done = False
|
||||||
while not is_measurement_done:
|
iperf_return = 0
|
||||||
|
while not is_measurement_done or iperf_return != 0:
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
subprocess.call(iperf_command, timeout=float(time) + TIMEOUT_OFFSET)
|
iperf_return = subprocess.call(iperf_command, timeout=float(time) + TIMEOUT_OFFSET)
|
||||||
is_measurement_done = True
|
is_measurement_done = True
|
||||||
except:
|
except:
|
||||||
print_message("iPerf timed out. Retry...")
|
print_message("iPerf timed out. Retry...")
|
||||||
|
|||||||
Reference in New Issue
Block a user