formatter

Author: erthalion

src/lib.rs

@@ -1,14 +1,13 @@
+use core_affinity::CoreId;
 use serde::Deserialize;
 use std::fmt::Display;
-use core_affinity::CoreId;
 
 pub mod worker;
 
 /// Main workload configuration, contains general bits for all types of
 /// workloads plus workload specific data.
 #[derive(Debug, Copy, Clone, Deserialize)]
 pub struct WorkloadConfig {
-
     /// An amount of time for workload payload to run before restarting.
     pub restart_interval: u64,
 
@@ -21,18 +20,15 @@ pub struct WorkloadConfig {
 #[derive(Debug, Copy, Clone, Deserialize)]
 #[serde(rename_all = "lowercase", tag = "type")]
 pub enum Workload {
-
     /// How to listen on ports.
     Endpoints {
-
         /// Governing the number of ports open.
         #[serde(flatten)]
         distribution: Distribution,
     },
 
     /// How to spawn processes.
     Processes {
-
         /// How often a new process will be spawn.
         arrival_rate: f64,
 
@@ -45,7 +41,6 @@ pub enum Workload {
 
     /// How to invoke syscalls
     Syscalls {
-
         /// How often to invoke a syscall.
         arrival_rate: f64,
     },
@@ -55,7 +50,6 @@ pub enum Workload {
 #[derive(Debug, Copy, Clone, Deserialize)]
 #[serde(tag = "distribution")]
 pub enum Distribution {
-
     /// Few processes are opening large number of ports, the rest are only few.
     #[serde(alias = "zipf")]
     Zipfian { n_ports: u64, exponent: f64 },

src/worker/endpoints.rs

@@ -3,7 +3,7 @@ use std::{fmt::Display, net::TcpListener, thread, time};
 use core_affinity::CoreId;
 use log::info;
 
-use crate::{WorkloadConfig, BaseConfig, Worker, WorkerError};
+use crate::{BaseConfig, Worker, WorkerError, WorkloadConfig};
 
 struct EndpointWorkload {
     restart_interval: u64,

src/worker/mod.rs

@@ -2,7 +2,7 @@ use core_affinity::CoreId;
 use rand::{thread_rng, Rng};
 use rand_distr::{Uniform, Zipf};
 
-use crate::{Distribution, Workload, WorkloadConfig, Worker};
+use crate::{Distribution, Worker, Workload, WorkloadConfig};
 
 use self::{endpoints::EndpointWorker, processes::ProcessesWorker, syscalls::SyscallsWorker};
 

src/worker/processes.rs

@@ -7,7 +7,7 @@ use nix::{sys::wait::waitpid, unistd::Pid};
 use rand::{distributions::Alphanumeric, thread_rng, Rng};
 use rand_distr::Exp;
 
-use crate::{Workload, WorkloadConfig, BaseConfig, Worker, WorkerError};
+use crate::{BaseConfig, Worker, WorkerError, Workload, WorkloadConfig};
 
 #[derive(Debug, Clone, Copy)]
 pub struct ProcessesWorker {

src/worker/syscalls.rs

@@ -6,7 +6,7 @@ use rand::{thread_rng, Rng};
 use rand_distr::Exp;
 use syscalls::{syscall, Sysno};
 
-use crate::{Workload, WorkloadConfig, BaseConfig, Worker, WorkerError};
+use crate::{BaseConfig, Worker, WorkerError, Workload, WorkloadConfig};
 
 #[derive(Debug, Copy, Clone)]
 pub struct SyscallsWorker {