lab/mininet-sample
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

let's try something else to disable mptcp on specific clients

Browse Source
This commit is contained in:
Quentin De Coninck 2020-07-07 17:27:12 +02:00
parent d78e7c1dee
commit decc3fdcdf
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
experiments/iperf_scenario.py
View File

@ -54,16 +54,12 @@ class IPerfScenario(Experiment):
super(IPerfScenario, self).clean() super(IPerfScenario, self).clean()
def run(self): def run(self):
self.topo.command_to(self.topo_config.router, "tcpdump -i any -w router.pcap &")
self.topo.command_to(self.topo_config.router, "tcpdump -i any -w router.pcap &")
# First run servers # First run servers
for l, s in enumerate(self.topo_config.servers): for l, s in enumerate(self.topo_config.servers):
self.topo.command_to(s, self.get_server_cmd(server_id=l)) self.topo.command_to(s, self.get_server_cmd(server_id=l))
# Disable MPTCP on all congestion clients
for c in self.topo_config.clients[1:]:
self.topo.command_to(c, "sysctl -w net.mptcp.mptcp_enabled=0")
# And set nb of subflows for fullmesh # And set nb of subflows for fullmesh
self.topo.command_to(self.topo_config.client, "echo {} > /sys/module/mptcp_fullmesh/parameters/num_subflows".format(self.fm_subflows)) self.topo.command_to(self.topo_config.client, "echo {} > /sys/module/mptcp_fullmesh/parameters/num_subflows".format(self.fm_subflows))
@ -75,8 +71,14 @@ class IPerfScenario(Experiment):
self.topo.command_to(self.topo_config.clients[1], cmd) self.topo.command_to(self.topo_config.clients[1], cmd)
cmd = "sleep 20 && {} &".format(self.get_client_iperf_cmd(self.topo_config.get_server_ip(interface_index=2), 20, 2)) cmd = "sleep 20 && {} &".format(self.get_client_iperf_cmd(self.topo_config.get_server_ip(interface_index=2), 20, 2))
self.topo.command_to(self.topo_config.clients[2], cmd) self.topo.command_to(self.topo_config.clients[2], cmd)
cmd = self.get_client_iperf_cmd(self.topo_config.get_server_ip(), 50, 0) cmd = "{} &".format(self.get_client_iperf_cmd(self.topo_config.get_server_ip(), 50, 0))
self.topo.command_to(self.topo_config.client, cmd) self.topo.command_to(self.topo_config.client, cmd)
self.topo.command_to(self.topo_config.client, "sleep 2") self.topo.command_to(self.topo_config.client, "sleep 2")
# This is hacky
self.topo.command_global("sysctl -w net.mptcp.mptcp_enabled=0")
self.topo.command_to(self.topo_config.client, "sleep 50")
self.topo.command_to(self.topo_config.client, "echo 1 > /sys/module/mptcp_fullmesh/parameters/num_subflows") self.topo.command_to(self.topo_config.client, "echo 1 > /sys/module/mptcp_fullmesh/parameters/num_subflows")