Compare commits
No commits in common. "master" and "v0.2.3" have entirely different histories.
@ -23,8 +23,8 @@ pipeline:
|
|||||||
base_url: https://git.metaunix.net
|
base_url: https://git.metaunix.net
|
||||||
files:
|
files:
|
||||||
- "target/release/*${CI_COMMIT_TAG}-linux-x86_64"
|
- "target/release/*${CI_COMMIT_TAG}-linux-x86_64"
|
||||||
- "target/debian/hardware-tests*.deb"
|
- "target/debian/hardware-tests_${CI_COMMIT_TAG}*.deb"
|
||||||
- "target/generate-rpm/hardware-tests*.rpm"
|
- "target/generate-rpm/hardware-tests-${CI_COMMIT_TAG}*.rpm"
|
||||||
title: "${CI_COMMIT_TAG}"
|
title: "${CI_COMMIT_TAG}"
|
||||||
when:
|
when:
|
||||||
event: tag
|
event: tag
|
||||||
|
@ -1,10 +1,11 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "hardware-tests"
|
name = "hardware-tests"
|
||||||
description = "Bit Goblin PC hardware test suite."
|
description = "Bit Goblin PC hardware test suite."
|
||||||
version = "0.4.0"
|
version = "0.2.3"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
license = "BSD 2-Clause"
|
license = "BSD 2-Clause"
|
||||||
|
license-file = "LICENSE"
|
||||||
authors = ["Gregory Ballantine <gballantine@bitgoblin.tech>"]
|
authors = ["Gregory Ballantine <gballantine@bitgoblin.tech>"]
|
||||||
|
|
||||||
[[bin]]
|
[[bin]]
|
||||||
@ -12,9 +13,8 @@ name = "bgbench"
|
|||||||
path = "src/main.rs"
|
path = "src/main.rs"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
chrono = "0.4"
|
chrono = "0.4.20"
|
||||||
clap = { version = "3.2", features = ["derive"] }
|
clap = { version = "3.2.16", features = ["derive"] }
|
||||||
sysinfo = "0.25"
|
|
||||||
|
|
||||||
[package.metadata.deb]
|
[package.metadata.deb]
|
||||||
depends = "fio"
|
depends = "fio"
|
||||||
|
@ -13,8 +13,7 @@ Currently there is no installation method other than downloading the provided re
|
|||||||
Simply run the tool with `./bgbench` and you'll be presented with the available subcommands.
|
Simply run the tool with `./bgbench` and you'll be presented with the available subcommands.
|
||||||
|
|
||||||
### Runtime requirements:
|
### Runtime requirements:
|
||||||
* `disk` - requires `fio`.
|
* disk - requires `fio`.
|
||||||
* `network bandwidth` - requires `iperf3`
|
|
||||||
|
|
||||||
## Building
|
## Building
|
||||||
|
|
||||||
|
@ -1,36 +0,0 @@
|
|||||||
use std::process::Command;
|
|
||||||
|
|
||||||
pub fn run_civ6_ai_benchmark() {
|
|
||||||
// make sure CS:GO is installed via Steam
|
|
||||||
download_game_steam(289070);
|
|
||||||
}
|
|
||||||
|
|
||||||
// run the CS:GO benchmark (using benchmark file from PTS)
|
|
||||||
pub fn run_csgo_benchmark() {
|
|
||||||
// make sure CS:GO is installed via Steam
|
|
||||||
download_game_steam(730);
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn run_demd_benchmark() {
|
|
||||||
// make sure CS:GO is installed via Steam
|
|
||||||
download_game_steam(337000);
|
|
||||||
}
|
|
||||||
|
|
||||||
fn download_game_steam(game_id: u32) {
|
|
||||||
let mut steam_path = "steam";
|
|
||||||
if cfg!(windows) {
|
|
||||||
steam_path = "C:\\Program Files (x86)\\Steam\\steam.exe";
|
|
||||||
}
|
|
||||||
|
|
||||||
// first we need to make sure CS:GO is installed via Steam
|
|
||||||
let install_output = Command::new(steam_path)
|
|
||||||
.arg(format!("steam://install/{}", game_id))
|
|
||||||
.output()
|
|
||||||
.expect("Failed to execute command");
|
|
||||||
|
|
||||||
// check that the command succeeded
|
|
||||||
assert!(install_output.status.success());
|
|
||||||
|
|
||||||
// print the test's output
|
|
||||||
println!("{}", String::from_utf8_lossy(&install_output.stdout));
|
|
||||||
}
|
|
@ -1,90 +0,0 @@
|
|||||||
use std::process;
|
|
||||||
|
|
||||||
use crate::text;
|
|
||||||
|
|
||||||
// ping a host
|
|
||||||
pub fn latency_test(address: &str, count: &u16, interval: &u16) {
|
|
||||||
println!("Pinging host {}, {} times.", address, count);
|
|
||||||
|
|
||||||
// if we're on Windows we need to use the -n flag for ping counts
|
|
||||||
let mut count_arg = "-c";
|
|
||||||
if cfg!(windows) {
|
|
||||||
count_arg = "-n";
|
|
||||||
}
|
|
||||||
|
|
||||||
// convert the ping interval to seconds
|
|
||||||
let interval_secs = *interval as f64 / 1000 as f64;
|
|
||||||
|
|
||||||
// run the ping command
|
|
||||||
let output = process::Command::new("ping")
|
|
||||||
.arg(address)
|
|
||||||
.arg(count_arg)
|
|
||||||
.arg(format!("{}", count))
|
|
||||||
.arg("-i")
|
|
||||||
.arg(format!("{}", interval_secs))
|
|
||||||
.output()
|
|
||||||
.expect("Failed to execute command");
|
|
||||||
|
|
||||||
// check that the command succeeded
|
|
||||||
assert!(output.status.success());
|
|
||||||
|
|
||||||
// grab the ping results from stdout
|
|
||||||
let results_raw = &String::from_utf8_lossy(&output.stdout);
|
|
||||||
let results = text::format::trim_output(results_raw, 4);
|
|
||||||
for line in results {
|
|
||||||
println!("{}", line);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// network jitter test
|
|
||||||
pub fn jitter_test(address: &str, count: &u16, interval: &u16) {
|
|
||||||
println!("Pinging host {}, {} times to determine network jitter.", address, count);
|
|
||||||
|
|
||||||
// if we're on Windows we need to use the -n flag for ping counts
|
|
||||||
let mut count_arg = "-c";
|
|
||||||
if cfg!(windows) {
|
|
||||||
count_arg = "-n";
|
|
||||||
}
|
|
||||||
|
|
||||||
// convert the ping interval to seconds
|
|
||||||
let interval_secs = *interval as f64 / 1000 as f64;
|
|
||||||
|
|
||||||
// run the ping command
|
|
||||||
let output = process::Command::new("ping")
|
|
||||||
.arg(address)
|
|
||||||
.arg(count_arg)
|
|
||||||
.arg(format!("{}", count))
|
|
||||||
.arg("-i")
|
|
||||||
.arg(format!("{}", interval_secs))
|
|
||||||
.output()
|
|
||||||
.expect("Failed to execute command");
|
|
||||||
|
|
||||||
// check that the command succeeded
|
|
||||||
assert!(output.status.success());
|
|
||||||
|
|
||||||
// grab the ping results from stdout
|
|
||||||
let results_raw = &String::from_utf8_lossy(&output.stdout);
|
|
||||||
let results = text::format::trim_output(results_raw, 4);
|
|
||||||
for line in results {
|
|
||||||
println!("{}", line);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// timed file copy test to guage bandwidth speeds
|
|
||||||
pub fn bandwidth_test(host: &str) {
|
|
||||||
println!("Testing network bandwidth using iperf; connecting to {}.", host);
|
|
||||||
println!("{}", host);
|
|
||||||
|
|
||||||
let output = process::Command::new("iperf3")
|
|
||||||
.arg("-c")
|
|
||||||
.arg(host)
|
|
||||||
.output()
|
|
||||||
.expect("Failed to execute command");
|
|
||||||
|
|
||||||
// check that the command succeeded
|
|
||||||
assert!(output.status.success());
|
|
||||||
|
|
||||||
// grab and print the command's results
|
|
||||||
let results_raw = &String::from_utf8_lossy(&output.stdout);
|
|
||||||
println!("{}", results_raw);
|
|
||||||
}
|
|
175
src/main.rs
175
src/main.rs
@ -1,8 +1,6 @@
|
|||||||
mod benchmarks;
|
mod tests;
|
||||||
mod stress;
|
|
||||||
mod text;
|
|
||||||
|
|
||||||
use clap::{Args, Parser, Subcommand};
|
use clap::{Parser, Subcommand};
|
||||||
|
|
||||||
#[derive(Parser)]
|
#[derive(Parser)]
|
||||||
#[clap(name = "Bit Goblin Benchmark", author, version, about = "Bit Goblin's hardware benchmarking tool.", long_about = None)]
|
#[clap(name = "Bit Goblin Benchmark", author, version, about = "Bit Goblin's hardware benchmarking tool.", long_about = None)]
|
||||||
@ -10,48 +8,21 @@ use clap::{Args, Parser, Subcommand};
|
|||||||
struct Cli {
|
struct Cli {
|
||||||
#[clap(subcommand)]
|
#[clap(subcommand)]
|
||||||
command: Commands,
|
command: Commands,
|
||||||
|
|
||||||
#[clap(short = 'l', long, default_value_t = 1, help = "Number of times to run test. Default = 1", global = true)]
|
|
||||||
loopcount: u8,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Subcommand)]
|
#[derive(Subcommand)]
|
||||||
enum Commands {
|
enum Commands {
|
||||||
// CPU benchmarks subcommand
|
// disk tests subcommand
|
||||||
#[clap(name = "cpu", about = "CPU benchmarks and stress tests.")]
|
|
||||||
Cpu(Cpu),
|
|
||||||
// disk benchmarks subcommand
|
|
||||||
#[clap(name = "disk", about = "Hard drive and SSD benchmarks.")]
|
#[clap(name = "disk", about = "Hard drive and SSD benchmarks.")]
|
||||||
Disk(Disk),
|
Disk(Disk),
|
||||||
// games benchmarks subcommand
|
// network tests subcommand
|
||||||
#[clap(name = "games", about = "Benchmark your system with games.")]
|
|
||||||
Games(Games),
|
|
||||||
// network benchmarks subcommand
|
|
||||||
#[clap(name = "network", about = "Test various aspects of your network.")]
|
#[clap(name = "network", about = "Test various aspects of your network.")]
|
||||||
Net(Net),
|
Net(Net),
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Args)]
|
#[derive(Parser)]
|
||||||
struct Cpu {
|
|
||||||
#[clap(subcommand)]
|
|
||||||
cpu_commands: CpuCommands,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Subcommand)]
|
|
||||||
enum CpuCommands {
|
|
||||||
// CPU stress test subcommand
|
|
||||||
#[clap(name = "stress", about = "Stress test the CPU with math!")]
|
|
||||||
StressTest {
|
|
||||||
#[clap(short = 'r', long, default_value_t = 5, help = "Length of time (in minutes) to run the stress test. Defaults to 5")]
|
|
||||||
runtime: u16,
|
|
||||||
#[clap(short = 't', long, default_value_t = 0, help = "Number of threads to use; defaults to CPU's max thread count. Defaults to 0 (automatic)")]
|
|
||||||
threads: usize,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Args)]
|
|
||||||
struct Disk {
|
struct Disk {
|
||||||
#[clap(subcommand)]
|
#[structopt(subcommand)]
|
||||||
disk_commands: DiskCommands,
|
disk_commands: DiskCommands,
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -60,61 +31,40 @@ enum DiskCommands {
|
|||||||
// sequential disk read subcommand
|
// sequential disk read subcommand
|
||||||
#[clap(name = "read_seq", about = "Sequential disk read speed test.")]
|
#[clap(name = "read_seq", about = "Sequential disk read speed test.")]
|
||||||
ReadSeqTest {
|
ReadSeqTest {
|
||||||
#[clap(short = 't', long, default_value_t = String::from("/tmp/disk-test.tmp"))]
|
#[clap(short = 'f', default_value_t = String::from("/tmp/disk-test.tmp"))]
|
||||||
tempfile: String,
|
tempfile: String,
|
||||||
#[clap(short = 's', long, default_value_t = 15)]
|
#[clap(short = 's', default_value_t = 15)]
|
||||||
size: u8,
|
size: u8,
|
||||||
},
|
},
|
||||||
|
|
||||||
// random disk read subcommand
|
// random disk read subcommand
|
||||||
#[clap(name = "read_rand", about = "Random 4K disk read speed test.")]
|
#[clap(name = "read_rand", about = "Random 4K disk read speed test.")]
|
||||||
ReadRandTest {
|
ReadRandTest {
|
||||||
#[clap(short = 't', long, default_value_t = String::from("/tmp/disk-test.tmp"))]
|
#[clap(short = 'f', default_value_t = String::from("/tmp/disk-test.tmp"))]
|
||||||
tempfile: String,
|
tempfile: String,
|
||||||
#[clap(short = 's', long, default_value_t = 15)]
|
#[clap(short = 's', default_value_t = 15)]
|
||||||
size: u8,
|
size: u8,
|
||||||
},
|
},
|
||||||
|
|
||||||
// sequential disk write subcommand
|
// sequential disk write subcommand
|
||||||
#[clap(name = "write_seq", about = "Write a large file to determine sequential disk write speeds.")]
|
#[clap(name = "write_seq", about = "Write a large file to determine sequential disk write speeds.")]
|
||||||
WriteSeqTest {
|
WriteSeqTest {
|
||||||
#[clap(short = 't', long, default_value_t = String::from("/tmp/disk-test.tmp"))]
|
#[clap(short = 't', default_value_t = String::from("/tmp/disk-test.tmp"))]
|
||||||
tempfile: String,
|
tempfile: String,
|
||||||
#[clap(short = 's', long, default_value_t = 15)]
|
#[clap(short = 's', default_value_t = 15)]
|
||||||
size: u8,
|
size: u8,
|
||||||
},
|
},
|
||||||
|
|
||||||
// random 4K disk write subcommand
|
// random 4K disk write subcommand
|
||||||
#[clap(name = "write_rand", about = "Write a bunch of smallfiles to determine random disk write speeds.")]
|
#[clap(name = "write_rand", about = "Write a bunch of smallfiles to determine random disk write speeds.")]
|
||||||
WriteRandTest {
|
WriteRandTest {
|
||||||
#[clap(short = 't', long, default_value_t = String::from("/tmp/disk-test.tmp"))]
|
#[clap(short = 't', default_value_t = String::from("/tmp/disk-test.tmp"))]
|
||||||
tempfile: String,
|
tempfile: String,
|
||||||
#[clap(short = 's', long, default_value_t = 15)]
|
#[clap(short = 's', default_value_t = 15)]
|
||||||
size: u8,
|
size: u8,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Parser)]
|
|
||||||
struct Games {
|
|
||||||
#[structopt(subcommand)]
|
|
||||||
games_commands: GamesCommands,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Subcommand)]
|
|
||||||
enum GamesCommands {
|
|
||||||
// Civilization 6 AI benchmark subcommand
|
|
||||||
#[clap(name = "civ6_ai", about = "Run the Civilization 6 AI benchmark via Steam.")]
|
|
||||||
Civ6AI {},
|
|
||||||
|
|
||||||
// CS:GO benchmark subcommand
|
|
||||||
#[clap(name = "csgo", about = "Run the CS:GO game benchmark via Steam.")]
|
|
||||||
CSGO {},
|
|
||||||
|
|
||||||
// Deus Ex: Mankind Divided benchmark subcommand
|
|
||||||
#[clap(name = "demd", about = "Run the Deus Ex: Mankind Divided game benchmark via Steam.")]
|
|
||||||
DEMD {},
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Parser)]
|
#[derive(Parser)]
|
||||||
struct Net {
|
struct Net {
|
||||||
#[structopt(subcommand)]
|
#[structopt(subcommand)]
|
||||||
@ -123,33 +73,22 @@ struct Net {
|
|||||||
|
|
||||||
#[derive(Subcommand)]
|
#[derive(Subcommand)]
|
||||||
enum NetCommands {
|
enum NetCommands {
|
||||||
// bandwidth test subcommand
|
// ping subcommand
|
||||||
#[clap(name = "bandwidth", about = "Uses iperf to test network bandwidth.")]
|
#[clap(name = "ping", about = "Ping a host to determine network latency.")]
|
||||||
Bandwidth {
|
Ping {
|
||||||
#[clap(short = 'a', long, required = true)]
|
#[clap(short = 't', default_value_t = String::from("8.8.8.8"))]
|
||||||
host: String,
|
host: String,
|
||||||
|
#[clap(short = 'c', default_value_t = 30)]
|
||||||
|
count: u16,
|
||||||
},
|
},
|
||||||
|
|
||||||
// jitter subcommand
|
// bandwidth test subcommand
|
||||||
#[clap(name = "jitter", about = "Ping a host to determine network jitter.")]
|
#[clap(name = "bandwidth", about = "Downloads a remote file to determine network bandwidth.")]
|
||||||
Jitter {
|
Bandwidth {
|
||||||
#[clap(short = 'a', long, default_value_t = String::from("8.8.8.8"))]
|
#[clap(short = 'd', default_value_t = String::from("https://www.bitgoblin.tech/hardware-tests/export-01.mp4"))]
|
||||||
address: String,
|
download: String,
|
||||||
#[clap(short = 'c', long, default_value_t = 100)]
|
#[clap(short = 'o', default_value_t = String::from("./tempfile"))]
|
||||||
count: u16,
|
output: String,
|
||||||
#[clap(short = 'i', long, default_value_t = 1000)]
|
|
||||||
interval: u16,
|
|
||||||
},
|
|
||||||
|
|
||||||
// latency subcommand
|
|
||||||
#[clap(name = "latency", about = "Ping a host to determine network latency.")]
|
|
||||||
Latency {
|
|
||||||
#[clap(short = 'a', long, default_value_t = String::from("8.8.8.8"))]
|
|
||||||
address: String,
|
|
||||||
#[clap(short = 'c', long, default_value_t = 100)]
|
|
||||||
count: u16,
|
|
||||||
#[clap(short = 'i', long, default_value_t = 1000)]
|
|
||||||
interval: u16,
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -158,62 +97,16 @@ fn main() {
|
|||||||
|
|
||||||
// map subcommands back to the main command
|
// map subcommands back to the main command
|
||||||
match &cli.command {
|
match &cli.command {
|
||||||
Commands::Cpu(args) => match &args.cpu_commands {
|
|
||||||
CpuCommands::StressTest { runtime, threads } => stress::cpu::cpu_stress_math(*runtime, *threads),
|
|
||||||
},
|
|
||||||
|
|
||||||
Commands::Disk(args) => match &args.disk_commands {
|
Commands::Disk(args) => match &args.disk_commands {
|
||||||
DiskCommands::ReadSeqTest { tempfile, size } => {
|
DiskCommands::ReadSeqTest { tempfile, size } => tests::disk::disk_read_seq_test(tempfile, size),
|
||||||
for i in 0..cli.loopcount {
|
DiskCommands::ReadRandTest { tempfile, size } => tests::disk::disk_read_rand_test(tempfile, size),
|
||||||
println!("Test run number {}.", i + 1);
|
DiskCommands::WriteSeqTest { tempfile, size } => tests::disk::disk_write_seq_test(tempfile, size),
|
||||||
benchmarks::disk::disk_read_seq_test(tempfile, size);
|
DiskCommands::WriteRandTest { tempfile, size } => tests::disk::disk_write_rand_test(tempfile, size),
|
||||||
}
|
}
|
||||||
},
|
|
||||||
DiskCommands::ReadRandTest { tempfile, size } => {
|
|
||||||
for i in 0..cli.loopcount {
|
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::disk::disk_read_rand_test(tempfile, size);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
DiskCommands::WriteSeqTest { tempfile, size } => {
|
|
||||||
for i in 0..cli.loopcount {
|
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::disk::disk_write_seq_test(tempfile, size);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
DiskCommands::WriteRandTest { tempfile, size } => {
|
|
||||||
for i in 0..cli.loopcount {
|
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::disk::disk_write_rand_test(tempfile, size);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
},
|
|
||||||
|
|
||||||
Commands::Games(args) => match &args.games_commands {
|
|
||||||
GamesCommands::Civ6AI {} => benchmarks::games::run_civ6_ai_benchmark(),
|
|
||||||
GamesCommands::CSGO {} => benchmarks::games::run_csgo_benchmark(),
|
|
||||||
GamesCommands::DEMD {} => benchmarks::games::run_demd_benchmark(),
|
|
||||||
},
|
|
||||||
|
|
||||||
Commands::Net(args) => match &args.net_commands {
|
Commands::Net(args) => match &args.net_commands {
|
||||||
NetCommands::Bandwidth { host } => {
|
NetCommands::Ping { host, count } => tests::network::ping_host(host, count),
|
||||||
for i in 0..cli.loopcount {
|
NetCommands::Bandwidth { download, output } => tests::network::bandwidth_test(download, output),
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::network::bandwidth_test(host);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
NetCommands::Jitter { address, count, interval } => {
|
|
||||||
for i in 0..cli.loopcount {
|
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::network::jitter_test(address, count, interval);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
NetCommands::Latency { address, count, interval } => {
|
|
||||||
for i in 0..cli.loopcount {
|
|
||||||
println!("Test run number {}.", i + 1);
|
|
||||||
benchmarks::network::latency_test(address, count, interval);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,38 +0,0 @@
|
|||||||
use std::{thread, time};
|
|
||||||
use std::process::exit;
|
|
||||||
use sysinfo::{System,SystemExt};
|
|
||||||
|
|
||||||
pub fn cpu_stress_math(runtime: u16, threads: usize) {
|
|
||||||
// fetch system information
|
|
||||||
let mut sys = System::new_all();
|
|
||||||
sys.refresh_all();
|
|
||||||
let num_cpus = sys.cpus().len();
|
|
||||||
|
|
||||||
let mut num_threads = threads;
|
|
||||||
if num_threads == 0 {
|
|
||||||
println!("Number of threads not specified, defaulting to CPU's thread count of {}.", num_cpus);
|
|
||||||
num_threads = num_cpus;
|
|
||||||
} else {
|
|
||||||
println!("Using specified thread count of {}", num_threads);
|
|
||||||
}
|
|
||||||
|
|
||||||
for i in 0..num_threads {
|
|
||||||
println!("Spawning thread number {}", i + 1);
|
|
||||||
thread::spawn (|| {
|
|
||||||
worker();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
println!("Sleeping main thread for the allotted runtime of {} minute(s).", runtime);
|
|
||||||
let duration = time::Duration::from_secs((runtime * 60).into());
|
|
||||||
thread::sleep(duration);
|
|
||||||
exit(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
fn worker() {
|
|
||||||
let mut _x = 0;
|
|
||||||
loop {
|
|
||||||
_x += 1;
|
|
||||||
_x -= 1;
|
|
||||||
}
|
|
||||||
}
|
|
@ -1 +0,0 @@
|
|||||||
pub mod cpu;
|
|
@ -1,3 +1,2 @@
|
|||||||
pub mod disk;
|
pub mod disk;
|
||||||
pub mod games;
|
|
||||||
pub mod network;
|
pub mod network;
|
42
src/tests/network.rs
Normal file
42
src/tests/network.rs
Normal file
@ -0,0 +1,42 @@
|
|||||||
|
use chrono::prelude::*;
|
||||||
|
use std::{fs,process};
|
||||||
|
|
||||||
|
// ping a host
|
||||||
|
pub fn ping_host(host: &str, count: &u16) {
|
||||||
|
println!("Pinging host {}, {} times.", host, count);
|
||||||
|
|
||||||
|
// run the ping command
|
||||||
|
let output = process::Command::new("ping")
|
||||||
|
.arg(host)
|
||||||
|
.arg(format!("-c {}", count))
|
||||||
|
.output()
|
||||||
|
.expect("Failed to execute command");
|
||||||
|
|
||||||
|
// check that the command succeeded
|
||||||
|
assert!(output.status.success());
|
||||||
|
|
||||||
|
// print out the ping results from stdout
|
||||||
|
println!("{}", String::from_utf8_lossy(&output.stdout));
|
||||||
|
}
|
||||||
|
|
||||||
|
// timed file copy test to guage bandwidth speeds
|
||||||
|
pub fn bandwidth_test(download: &str, output: &str) {
|
||||||
|
println!("Testing network bandwidth by downloading {}.", download);
|
||||||
|
|
||||||
|
// get start time so we can track how long it takes to complete
|
||||||
|
let start_time = Utc::now();
|
||||||
|
|
||||||
|
// do the download
|
||||||
|
|
||||||
|
// get finish time
|
||||||
|
let finish_time = Utc::now();
|
||||||
|
// compute time to complete
|
||||||
|
let comp_time = finish_time - start_time;
|
||||||
|
println!("{}", comp_time.num_milliseconds());
|
||||||
|
|
||||||
|
// clean up the test file
|
||||||
|
match fs::remove_file(output) {
|
||||||
|
Ok(()) => println!("Cleaning up..."),
|
||||||
|
Err(e) => println!("There was a problem during cleanup - {}", e),
|
||||||
|
}
|
||||||
|
}
|
@ -1,8 +0,0 @@
|
|||||||
use std::vec::Vec;
|
|
||||||
|
|
||||||
pub fn trim_output(text: &str, linecount: u16) -> Vec<&str> {
|
|
||||||
let text_vec: Vec<&str> = text.split("\n").collect();
|
|
||||||
let text_start = text_vec.len() - (linecount as usize);
|
|
||||||
let text_trim = text_vec.as_slice()[text_start..].to_vec();
|
|
||||||
return text_trim;
|
|
||||||
}
|
|
@ -1 +0,0 @@
|
|||||||
pub mod format;
|
|
Loading…
Reference in New Issue
Block a user