ockam_core/
debugger.rs

1use crate::{Mailbox, RelayMessage};
2
3#[cfg(feature = "debugger")]
4use core::sync::atomic::{AtomicU32, Ordering};
5
6/// Log incoming message flow authorization
7pub fn log_incoming_access_control(_mailbox: &Mailbox, _relay_msg: &RelayMessage) {
8    #[cfg(feature = "debugger")]
9    {
10        static COUNTER: AtomicU32 = AtomicU32::new(0);
11
12        tracing::debug!(
13            "log_incoming_access_control #{:03}: {:?} for {} -> {}",
14            COUNTER.fetch_add(1, Ordering::Relaxed),
15            _mailbox.incoming_access_control(),
16            _relay_msg.source(),
17            _relay_msg.destination()
18        );
19    }
20}
21
22/// Log outgoing message flow authorization
23pub fn log_outgoing_access_control(_mailbox: &Mailbox, _relay_msg: &RelayMessage) {
24    #[cfg(feature = "debugger")]
25    {
26        static COUNTER: AtomicU32 = AtomicU32::new(0);
27
28        tracing::debug!(
29            "log_outgoing_access_control #{:03}: {:?} for {} -> {}",
30            COUNTER.fetch_add(1, Ordering::Relaxed),
31            _mailbox.outgoing_access_control(),
32            _relay_msg.source(),
33            _relay_msg.destination()
34        );
35    }
36}