uniudp 1.0.0

Unidirectional UDP transport with chunking, redundancy, and Reed-Solomon FEC.
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

use std::net::SocketAddr;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[non_exhaustive]
pub enum SourcePolicy {
    /// Accept the first packet from any source, then pin all follow-up packets
    /// for that message to the same socket address.
    AnyFirstSource,
    /// Require all packets to come from this exact socket address.
    Exact(SocketAddr),
    /// Accept the first packet from any source, then require follow-up packets
    /// to match the first packet's IP address (port may differ).
    SameIp,
}

impl SourcePolicy {
    pub(crate) fn allows_first(self, source: SocketAddr) -> bool {
        match self {
            SourcePolicy::AnyFirstSource | SourcePolicy::SameIp => true,
            SourcePolicy::Exact(expected) => source == expected,
        }
    }

    pub(crate) fn allows_existing(self, first_source: SocketAddr, incoming: SocketAddr) -> bool {
        match self {
            SourcePolicy::AnyFirstSource => incoming == first_source,
            SourcePolicy::Exact(expected) => incoming == expected && incoming == first_source,
            SourcePolicy::SameIp => incoming.ip() == first_source.ip(),
        }
    }

    pub(crate) fn allows_buffered(self, first_source: SocketAddr) -> bool {
        match self {
            SourcePolicy::AnyFirstSource | SourcePolicy::SameIp => true,
            SourcePolicy::Exact(expected) => expected == first_source,
        }
    }
}