msrt 0.1.5

Portable MSRT protocol implementation.
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

//! Scheduler debug logging.

use super::event::EngineOutput;

pub(super) fn log_event(now_ms: u64, queue: &str, offset: usize, event: &EngineOutput) {
    match event {
        EngineOutput::Write(write) => {
            let packet_type = packet_type(write.as_bytes())
                .map(|packet_type| packet_type.code())
                .unwrap_or_default();
            eprintln!(
                "msrt scheduler event now={} queue={} offset={} kind=write packet_type={} msg={} idx={} attempts={} len={} priority={:?}",
                now_ms,
                queue,
                offset,
                packet_type,
                write.key.message_id.get(),
                write.key.packet_index.get(),
                write.attempts,
                write.len,
                write.priority,
            );
        }
        EngineOutput::SendFailed(failed) => {
            eprintln!(
                "msrt scheduler event now={} queue={} offset={} kind=send_failed packet_type={:?} msg={}",
                now_ms,
                queue,
                offset,
                failed.packet_type,
                failed.message_id.get(),
            );
        }
    }
}

fn packet_type(bytes: &[u8]) -> Option<crate::core::PacketType> {
    crate::core::PacketType::from_code(*bytes.get(crate::wire::WIRE_HEADER_LEN)?)
}