rzmq 0.5.25

High performance, CPU and memory efficient, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and TCP Cork acceleration on Linux.
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

pub(crate) mod macros;

#[cfg(feature = "io-uring")]
pub mod uring;

#[cfg(feature = "diagnostics")]
pub(crate) mod active {
  use std::sync::atomic::AtomicU64;

  pub(crate) struct RZmqMetrics {
    pub(crate) global_drained_msgs: AtomicU64,
    pub(crate) global_msgs_pulled: AtomicU64,
    pub(crate) global_bytes_pulled: AtomicU64,
    pub(crate) last_bytes_sent: AtomicU64,
  }

  pub(crate) static METRICS: RZmqMetrics = RZmqMetrics {
    global_drained_msgs: AtomicU64::new(0),
    global_msgs_pulled: AtomicU64::new(0),
    global_bytes_pulled: AtomicU64::new(0),
    last_bytes_sent: AtomicU64::new(0),
  };

  /// RAII guard that prints a cancellation warning if dropped before `complete()` is called.
  ///
  /// Use via the `cancel_guard!` / `cancel_guard_complete!` macros so call sites
  /// compile to nothing in release builds without the `diagnostics` feature.
  pub(crate) struct CancelGuard {
    pub(crate) label: &'static str,
    pub(crate) completed: bool,
  }

  impl CancelGuard {
    pub(crate) fn new(label: &'static str) -> Self {
      Self { label, completed: false }
    }

    pub(crate) fn complete(&mut self) {
      self.completed = true;
    }
  }

  impl Drop for CancelGuard {
    fn drop(&mut self) {
      if !self.completed {
        println!(
          "[CANCEL-DETECTED pid={}] future dropped mid-flight at: {}",
          std::process::id(),
          self.label,
        );
      }
    }
  }
}