Struct Peer 

pub struct Peer { /* private fields */ }

One connection, as the voice plane sees it.

Implementations

impl Peer

pub fn new( connection: ConnectionId, session: SessionId, host: IpAddr, crypt: CryptState, queue: Arc<OutboundQueue>, plane: ShardPlane, now: Instant, ) -> Peer

pub fn online_since(&self) -> Instant

When this connection was registered.

pub fn record_report(&self, report: ClientReport)

Store what the client reported about its own side of the link.

pub fn reported(&self) -> ClientReport

pub fn traffic(&self, now: Instant) -> (u32, Duration)

Voice throughput over the last second, in bytes per second, and how long this connection has been idle.

pub fn record_activity(&self, now: Instant)

Note a control message that is not a keepalive.

pub fn connection(&self) -> ConnectionId

pub fn session(&self) -> SessionId

pub fn host(&self) -> IpAddr

pub fn queue(&self) -> Arc<OutboundQueue>

pub fn cursor_cell(&self) -> Arc<AtomicU64>

pub fn cursor(&self) -> u64

pub fn shard(&self) -> ShardId

pub fn routing(&self) -> Arc<AudioRouting>

The routing table of the shard this connection belongs to.

pub fn move_to(&self, plane: ShardPlane)

Point this connection at another shard. Called by a migration, once.

pub fn decrypt(&self, datagram: &[u8]) -> Option<Vec<u8>>

Try to decrypt a datagram in this peer’s OCB2 domain.

A failure is side-effect free - the IV is restored and nothing is written to the replay history - which is what makes the cold path’s “try every candidate” safe.

REF: references/mumble/src/murmur/Server.cpp : Server::run binds an unknown peer to the first checkDecrypt that succeeds.

pub fn encrypt(&self, plaintext: &[u8]) -> Option<Vec<u8>>

pub fn crypt_counters(&self) -> (u32, u32, u32)

The OCB2 counters the TCP Ping reply must report.

pub fn allow_voice(&self, now: Instant, bytes: usize) -> bool

Whether this peer may send one more voice packet right now.

pub fn allow_text(&self, now: Instant) -> bool

Whether this peer may send one more text message right now.

pub fn set_udp_mode(&self, on: bool)

Record that this peer’s audio is arriving over UDP again, or that it has fallen back to the tunnel.

REF: references/mumble/src/murmur/Server.cpp : aiUdpFlag goes to 0 on a UDPTunnel message and back to 1 when a datagram arrives.

pub fn destination(&self) -> Option<SocketAddr>

Where audio for this peer goes: its proven address, or None meaning the TCP tunnel.

Both conditions are required, as in the real server: a proven address and a peer whose own audio last came over UDP. A client whose UDP dies mid-call keeps hearing everyone, through the tunnel.

pub fn proven_address(&self) -> Option<SocketAddr>

The address this peer has proven, whatever transport it last used.

pub fn close(&self)

Mark the connection for teardown by its own task.

Trait Implementations

impl Debug for Peer

Hand-written so key material never reaches a log. Everything printed here is an identifier or a state flag; the OCB2 domain is named, not shown.

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.