librqbit-dualstack-sockets 0.6.7

utilities for creating dual-stack TCP and UDP tokio sockets
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
55

#[derive(thiserror::Error, Debug)]
pub enum Error {
    #[error("error creating socket: {0}")]
    SocketNew(std::io::Error),
    #[error("error binding: {0}")]
    Bind(std::io::Error),
    #[error("error setting only_v6={value}: {source}")]
    OnlyV6 { value: bool, source: std::io::Error },
    #[error("error setting SO_REUSEADDR: {0}")]
    ReuseAddress(std::io::Error),
    #[error("error getting local_addr(): {0}")]
    LocalAddr(std::io::Error),
    #[error("as_socket() returned None")]
    AsSocket,
    #[error("error setting nonblocking=true: {0}")]
    SetNonblocking(std::io::Error),
    #[error("mismatch between local_addr and requested bind_addr")]
    LocalBindAddrMismatch,
    #[error("error listening")]
    Listen(std::io::Error),
    #[error("error calling tokio from_std")]
    TokioFromStd(std::io::Error),
    #[error("did not join any multicast groups")]
    MulticastJoinFail,
    #[error("provided link-local address is not link-local")]
    ProvidedLinkLocalAddrIsntLinkLocal,
    #[error("no network interfaces found")]
    NoNics,
    #[error("provided site-local address is not site-local")]
    ProvidedSiteLocalAddrIsNotSiteLocal,
    #[error("error setting SO_REUSEPORT")]
    ReusePort(std::io::Error),
    #[error("error waiting for socket to become writeable")]
    Writeable(std::io::Error),
    #[error("error calling set_multicast_if_v6")]
    SetMulticastIpv6(std::io::Error),
    #[error("error calling set_multicast_if_v4")]
    SetMulticastIpv4(std::io::Error),
    #[error("send_multicast_msg called with conflicting parameters")]
    SendMulticastMsgProtocolMismatch,
    #[error("error sending: {0:#}")]
    Send(std::io::Error),
    #[error("binding to device is not supported on your OS")]
    BindDeviceNotSupported,
    #[error("invalid bind device")]
    BindDeviceInvalid,
    #[error("invalid bind device: {0:#}")]
    BindDeviceInvalidError(std::io::Error),
    #[error("error setting bind device: {0:#}")]
    BindDeviceSetDeviceError(std::io::Error),
    #[error("error connecting: {0:#}")]
    Connect(std::io::Error),
}

pub type Result<T> = core::result::Result<T, Error>;