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

tc replace instead of tc change

Browse Source
This commit is contained in:
Quentin De Coninck 2020-08-05 14:36:55 +02:00
parent 06825ad36b
commit 7faea31e8c
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/topo.py
View File

@ -84,25 +84,25 @@ class LinkCharacteristics(object):
def build_delete_tc_cmd(self, ifname): def build_delete_tc_cmd(self, ifname):
return "tc qdisc del dev {} root; tc qdisc del dev {} ingress ".format(ifname, ifname) return "tc qdisc del dev {} root; tc qdisc del dev {} ingress ".format(ifname, ifname)
def build_bandwidth_cmd(self, ifname, change=False): def build_bandwidth_cmd(self, ifname, replace=False):
return "tc qdisc {} dev {} root handle 1:0 tbf rate {}mbit burst 15000 limit {}".format(#; tc qdisc {} dev {} parent 1:0 bfifo limit {}".format( return "tc qdisc {} dev {} root handle 1:0 tbf rate {}mbit burst 15000 limit {}".format(
"change" if change else "add", ifname, self.bandwidth, self.buffer_size())#, "change" if change else "add", ifname, self.buffer_size()) "replace" if replace else "add", ifname, self.bandwidth, self.buffer_size())
def build_changing_bandwidth_cmd(self, ifname): def build_changing_bandwidth_cmd(self, ifname):
return "&& ".join( return "&& ".join(
["sleep {} && ({}) ".format( ["sleep {} && ({}) ".format(
n.delta, self.build_bandwidth_cmd(ifname, change=True)) for n in self.netem_at] n.delta, self.build_bandwidth_cmd(ifname, replace=True)) for n in self.netem_at]
+ ["true &"] + ["true &"]
) )
def build_netem_cmd(self, ifname, cmd, change=False): def build_netem_cmd(self, ifname, cmd, replace=False):
return "tc qdisc {} dev {} root handle 10: netem {} {}".format( return "tc qdisc {} dev {} root handle 10: netem {} {}".format(
"change" if change else "add", ifname, cmd, "delay {}ms limit 50000".format(self.delay) if not change else "") "replace" if replace else "add", ifname, cmd, "delay {}ms limit 50000".format(self.delay) if not replace else "")
def build_changing_netem_cmd(self, ifname): def build_changing_netem_cmd(self, ifname):
return "&& ".join( return "&& ".join(
["sleep {} && {} ".format( ["sleep {} && {} ".format(
n.delta, self.build_netem_cmd(ifname, n.cmd, change=True)) for n in self.netem_at] n.delta, self.build_netem_cmd(ifname, n.cmd, replace=True)) for n in self.netem_at]
+ ["true &"] + ["true &"]
) )