mirror of
https://github.com/LibreQoE/LibreQoS.git
synced 2025-02-25 18:55:32 -06:00
Add a standard format file, and use #[rustfmt::skip] to say 'stop formatting this block'
This commit is contained in:
Herbert Wolverson
parent
9c135e8b4f
commit
c676b8a33f
@ -17,153 +17,135 @@ const IP: &str = "ip";
|
||||
// Using a ASCII64 encoding would help
|
||||
|
||||
fn setup_dummy_interface(interface: &str) -> String {
|
||||
let interface = format!("{}{}{}", "t_", interface, id());
|
||||
if interface.len() > 15 {
|
||||
panic!("Interface Queue Length must be less than 15 characters");
|
||||
}
|
||||
let status = Command::new(SUDO)
|
||||
.args([IP, "link","add","name", interface.as_str(),"type","dummy"])
|
||||
.status().expect("file not found");
|
||||
if !status.success() {
|
||||
panic!("Dummy device is not supported on this OS: {}", status);
|
||||
}
|
||||
return interface;
|
||||
let interface = format!("{}{}{}", "t_", interface, id());
|
||||
if interface.len() > 15 {
|
||||
panic!("Interface Queue Length must be less than 15 characters");
|
||||
}
|
||||
let status = Command::new(SUDO)
|
||||
.args([IP, "link", "add", "name", interface.as_str(), "type", "dummy"])
|
||||
.status()
|
||||
.expect("file not found");
|
||||
if !status.success() {
|
||||
panic!("Dummy device is not supported on this OS: {}", status);
|
||||
}
|
||||
return interface;
|
||||
}
|
||||
|
||||
fn clear_queues(interface: &str) {
|
||||
Command::new(SUDO)
|
||||
.args([TC, "qdisc", "delete", "dev", interface, "root"])
|
||||
.output()
|
||||
.unwrap();
|
||||
Command::new(SUDO)
|
||||
.args([TC, "qdisc", "delete", "dev", interface, "root"])
|
||||
.output()
|
||||
.unwrap();
|
||||
}
|
||||
|
||||
fn setup_mq(interface: &str) {
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "replace", "dev", interface, "root", "handle", "7FFF:", "mq",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "replace", "dev", interface, "root", "handle", "7FFF:",
|
||||
"mq",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
}
|
||||
|
||||
fn setup_parent_htb(interface: &str) {
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "add", "dev", interface, "parent", "7FFF:0x1", "handle", "0x1:", "htb",
|
||||
"default", "2",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "add", "dev", interface, "parent", "7FFF:0x1", "handle",
|
||||
"0x1:", "htb", "default", "2",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC,
|
||||
"class",
|
||||
"add",
|
||||
"dev",
|
||||
interface,
|
||||
"parent",
|
||||
"0x1:",
|
||||
"classid",
|
||||
"0x1:1",
|
||||
"htb",
|
||||
"rate",
|
||||
"10000mbit",
|
||||
"ceil",
|
||||
"10000mbit",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
#[rustfmt::skip]
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "class", "add", "dev", interface, "parent", "0x1:", "classid",
|
||||
"0x1:1", "htb", "rate", "10000mbit", "ceil", "10000mbit",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC,
|
||||
"qdisc",
|
||||
"add",
|
||||
"dev",
|
||||
interface,
|
||||
"parent",
|
||||
"0x1:1",
|
||||
"cake",
|
||||
"diffserv4",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
#[rustfmt::skip]
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "add", "dev", interface, "parent", "0x1:1", "cake",
|
||||
"diffserv4",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
}
|
||||
|
||||
fn add_client_pair(interface: &str, queue_number: u32) {
|
||||
let class_id = format!("0x1:{:x}", queue_number);
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "class", "add", "dev", interface, "parent", "0x1:1", "classid", &class_id, "htb",
|
||||
"rate", "2500mbit", "ceil", "9999mbit", "prio", "5",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
let class_id = format!("0x1:{:x}", queue_number);
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "class", "add", "dev", interface, "parent", "0x1:1", "classid",
|
||||
&class_id, "htb", "rate", "2500mbit", "ceil", "9999mbit", "prio", "5",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC,
|
||||
"qdisc",
|
||||
"add",
|
||||
"dev",
|
||||
interface,
|
||||
"parent",
|
||||
&class_id,
|
||||
"cake",
|
||||
"diffserv4",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
#[rustfmt::skip]
|
||||
Command::new(SUDO)
|
||||
.args([
|
||||
TC, "qdisc", "add", "dev", interface, "parent", &class_id, "cake",
|
||||
"diffserv4",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
}
|
||||
|
||||
pub fn criterion_benchmark(c: &mut Criterion) {
|
||||
c.bench_function("deserialize_cake", |b| {
|
||||
b.iter(|| {
|
||||
deserialize_tc_tree(EXAMPLE_JSON).unwrap();
|
||||
});
|
||||
c.bench_function("deserialize_cake", |b| {
|
||||
b.iter(|| {
|
||||
deserialize_tc_tree(EXAMPLE_JSON).unwrap();
|
||||
});
|
||||
});
|
||||
|
||||
let binding = setup_dummy_interface("qt");
|
||||
let interface = binding.as_str();
|
||||
|
||||
const QUEUE_COUNTS: [u32; 3] = [10, 100, 1000];
|
||||
for queue_count in QUEUE_COUNTS.iter() {
|
||||
let no_stdbuf =
|
||||
format!("NO-STBUF, {queue_count} queues: tc qdisc show -s -j");
|
||||
let stdbuf =
|
||||
format!("STBUF -i1024, {queue_count} queues: tc qdisc show -s -j");
|
||||
|
||||
clear_queues(interface);
|
||||
setup_mq(interface);
|
||||
setup_parent_htb(interface);
|
||||
for i in 0..*queue_count {
|
||||
let queue_handle = (i + 1) * 2;
|
||||
add_client_pair(interface, queue_handle);
|
||||
}
|
||||
|
||||
c.bench_function(&no_stdbuf, |b| {
|
||||
b.iter(|| {
|
||||
let command_output = Command::new("/sbin/tc")
|
||||
.args(["-s", "-j", "qdisc", "show", "dev", "eth1"])
|
||||
.output()
|
||||
.unwrap();
|
||||
let json = String::from_utf8(command_output.stdout).unwrap();
|
||||
black_box(json);
|
||||
});
|
||||
});
|
||||
|
||||
let binding = setup_dummy_interface("qt");
|
||||
let interface = binding.as_str();
|
||||
|
||||
const QUEUE_COUNTS: [u32; 3] = [10, 100, 1000];
|
||||
for queue_count in QUEUE_COUNTS.iter() {
|
||||
let no_stdbuf = format!("NO-STBUF, {queue_count} queues: tc qdisc show -s -j");
|
||||
let stdbuf = format!("STBUF -i1024, {queue_count} queues: tc qdisc show -s -j");
|
||||
|
||||
clear_queues(interface);
|
||||
setup_mq(interface);
|
||||
setup_parent_htb(interface);
|
||||
for i in 0..*queue_count {
|
||||
let queue_handle = (i + 1) * 2;
|
||||
add_client_pair(interface, queue_handle);
|
||||
}
|
||||
|
||||
c.bench_function(&no_stdbuf, |b| {
|
||||
b.iter(|| {
|
||||
let command_output = Command::new("/sbin/tc")
|
||||
.args(["-s", "-j", "qdisc", "show", "dev", "eth1"])
|
||||
.output()
|
||||
.unwrap();
|
||||
let json = String::from_utf8(command_output.stdout).unwrap();
|
||||
black_box(json);
|
||||
});
|
||||
});
|
||||
|
||||
c.bench_function(&stdbuf, |b| {
|
||||
b.iter(|| {
|
||||
let command_output = Command::new("/usr/bin/stdbuf")
|
||||
.args([
|
||||
"-i0", "-o1024M", "-e0", TC, "-s", "-j", "qdisc", "show", "dev", "eth1",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
let json = String::from_utf8(command_output.stdout).unwrap();
|
||||
black_box(json);
|
||||
});
|
||||
});
|
||||
}
|
||||
c.bench_function(&stdbuf, |b| {
|
||||
b.iter(|| {
|
||||
let command_output = Command::new("/usr/bin/stdbuf")
|
||||
.args([
|
||||
"-i0", "-o1024M", "-e0", TC, "-s", "-j", "qdisc", "show", "dev",
|
||||
"eth1",
|
||||
])
|
||||
.output()
|
||||
.unwrap();
|
||||
let json = String::from_utf8(command_output.stdout).unwrap();
|
||||
black_box(json);
|
||||
});
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
criterion_group!(benches, criterion_benchmark);
|
||||
|
||||
5
src/rust/rustfmt.toml
Normal file
5
src/rust/rustfmt.toml
Normal file
@ -0,0 +1,5 @@
|
||||
max_width = 78
|
||||
tab_spaces = 2
|
||||
use_small_heuristics = "Max"
|
||||
array_width = 78
|
||||
|
||||
Loading…
Reference in New Issue
Block a user