rustasim 0.0.99

Distributed event-driven simulator with a focus on datacenter networks
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use slog::OwnedKVList;
use slog::Record;

use std::cell::RefCell;
use std::io;
use std::time::Instant;

/// Attempt to write a *very* simple logger
#[derive(Debug)]
pub struct MsgLogger<W: io::Write> {
    io: RefCell<W>,
    pub start: Instant,
}

impl<W> MsgLogger<W>
where
    W: io::Write,
{
    pub fn new(io: W) -> MsgLogger<W> {
        MsgLogger {
            io: RefCell::new(io),
            start: Instant::now(),
        }
    }
}

impl<W> slog::Drain for MsgLogger<W>
where
    W: io::Write,
{
    type Ok = ();
    type Err = io::Error;

    fn log(&self, rinfo: &Record, _logger_values: &OwnedKVList) -> io::Result<()> {
        let mut io = self.io.borrow_mut();
        if rinfo.level() == slog::Level::Trace {
            writeln!(io, "{},{}", self.start.elapsed().as_nanos(), rinfo.msg())?;
        } else {
            writeln!(io, "{}", rinfo.msg())?;
        }

        Ok(())
    }
}

// TODO serializer?