|
|
|
@@ -26,6 +26,7 @@ NR_EN_DC_STATUS_COMMAND = b"AT+QENDC\r\n" |
|
|
|
NR_SERIAL_RESPOND_TIME = 0.3 # s |
|
|
|
CMD_TIME_EPOCH = "date +%s" |
|
|
|
TIMEOUT_OFFSET = 10.0 |
|
|
|
WAIT_AFTER_IPERF = 5.0 |
|
|
|
|
|
|
|
|
|
|
|
class ProcessHandler: |
|
|
|
@@ -193,7 +194,7 @@ def is_tcp_probe_enabled(): |
|
|
|
|
|
|
|
|
|
|
|
def disable_tso(interface): |
|
|
|
os.system("ethtool -K {} tx off sg off tso off".format(interface)) |
|
|
|
os.system("ethtool -K {} tx off sg off tso off gro off".format(interface)) |
|
|
|
|
|
|
|
|
|
|
|
def enable_tcp_probe(): |
|
|
|
@@ -446,7 +447,7 @@ class Server: |
|
|
|
"--one-off", |
|
|
|
] |
|
|
|
subprocess.call(iperf_command) |
|
|
|
sleep(10) |
|
|
|
sleep(WAIT_AFTER_IPERF) |
|
|
|
processHandler.kill_all() |
|
|
|
congestion_control_index = (congestion_control_index + 1) % len( |
|
|
|
tcp_algo |
|
|
|
@@ -894,7 +895,7 @@ class Client: |
|
|
|
congestion_control_index = (congestion_control_index + 1) % len( |
|
|
|
tcp_algo |
|
|
|
) |
|
|
|
sleep(12) |
|
|
|
sleep(WAIT_AFTER_IPERF + 2) |
|
|
|
|
|
|
|
def cbr(self): |
|
|
|
bitrate = "1M" |