mactime2 3.2.0

Replacement for `mactime`
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

use libmactime2::*;
use std::sync::mpsc::{self, Sender, Receiver};
use std::cell::RefCell;

#[macro_use]
extern crate more_asserts;

#[test]
fn test_sorted() {
    let (tx, rx): (Sender<String>, Receiver<String>) = mpsc::channel();

    let options = RunOptions {
        strict_mode: false,
        src_zone: chrono_tz::Tz::UTC
    };

    let mut decoder = BodyfileDecoder::with_receiver(rx, options);
    let mut sorter = BodyfileSorter::default()
        .with_receiver(decoder.get_receiver(), options)
        .with_output(Box::new(EventCatcher::new()));

    sorter.run();
    for day in 0..364 {
        for hour in 0..23 {
            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 1))
                .with_atime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 2))
                .with_mtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 3))
                .with_ctime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 4))
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 5))
                .with_atime(random_ts())
                .with_mtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 6))
                .with_atime(random_ts())
                .with_ctime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 7))
                .with_atime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 8))
                .with_mtime(random_ts())
                .with_ctime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 9))
                .with_mtime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 10))
                .with_ctime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 11))
                .with_atime(random_ts())
                .with_mtime(random_ts())
                .with_ctime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 12))
                .with_atime(random_ts())
                .with_mtime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 13))
                .with_atime(random_ts())
                .with_ctime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 14))
                .with_mtime(random_ts())
                .with_ctime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();

            let bf = ::bodyfile::Bodyfile3Line::new()
                .with_name(&format!("sample_{}_{}_{}", day, hour, 15))
                .with_atime(random_ts())
                .with_mtime(random_ts())
                .with_ctime(random_ts())
                .with_crtime(random_ts());
            tx.send(bf.to_string()).unwrap();
        }
    }
    drop(tx);

    decoder.join().unwrap();
    let _ = sorter.join().unwrap();
}

fn random_ts() -> i64 {
    rand::random::<u32>() as i64
}

struct EventCatcher {
    last_timestamp: RefCell<i64>,
}

impl EventCatcher {
    pub fn new () -> Self {
        Self {
            last_timestamp: RefCell::new(-1)
        }
    }
}

impl Mactime2Writer for EventCatcher {
    fn fmt(&self, timestamp: &i64, _entry: &ListEntry) -> String {
        assert_le!(*self.last_timestamp.borrow(), *timestamp);

        *self.last_timestamp.borrow_mut() = *timestamp;
        "".to_owned()
    }
}