aqt_sim 0.1.0

Adverserial Queueing Theory (AQT) simulator
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use aqt_sim::protocol::oed::OEDWithSwap;
use aqt_sim::simulation::Simulation;
use aqt_sim::network::presets;
use aqt_sim::protocol::Protocol;
use aqt_sim::adversary::Adversary;
use aqt_sim::simulation::threshold::TimedThreshold;
use aqt_sim::simulation::recorder::{ Recorder, DebugPrintRecorder, BufferLoadRecorder };
use aqt_sim::adversary::path_random::SDPathRandomAdversary;

const NUM_BUFFERS: usize = 10;
const NUM_RDS: usize = 10;

fn main() {
    let network = presets::construct_path(NUM_BUFFERS);
    let protocol = OEDWithSwap::new(1);
    let adversary = SDPathRandomAdversary::new();
    let threshold = TimedThreshold::new(NUM_RDS);
    let recorders: Vec<Box<dyn Recorder>> = vec![
        Box::new(DebugPrintRecorder::new()),
        Box::new(BufferLoadRecorder::new("/home/cammatsui/Dev/aqt_sim/test.csv".to_string())),
    ];
    let mut simulation = Simulation::new(network, protocol, adversary, threshold, recorders);
    simulation.run();
}