netsim 0.3.0

Run tests in network-isolated threads. Intercept and meddle with their packets.
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
56
57
58

pub(crate) use {
    std::{
        cmp, fmt, io, mem, panic, ptr, slice, task, thread, str,
        collections::{VecDeque, hash_map, HashMap, BTreeMap, HashSet},
        ffi::{CStr, CString},
        future::{Future, IntoFuture},
        fs::File,
        io::Write,
        mem::MaybeUninit,
        net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddrV4},
        os::fd::{OwnedFd, FromRawFd, AsRawFd},
        pin::Pin,
        sync::Arc,
        task::Poll,
        time::{Duration, Instant},
    },
    bytes::BytesMut,
    libc::{c_int, c_long, c_void, pid_t},
    tokio::io::unix::AsyncFd,
    futures::{
        ready, FutureExt, Sink, Stream, StreamExt,
        stream::FusedStream,
        channel::mpsc,
    },
    ioctl_sys::ioctl,
    pin_project::pin_project,
    rand::Rng,
    log::{log_enabled, debug, Level},
    netsim_macros::{ipv4_network, ipv6_network},
    crate::{
        namespace, ioctl, iface, adapter, sys,
        device::IpChannel,
        machine::Machine,
        iface::{
            create::IpIfaceBuilder,
            stream::{IpIface, IpSinkStream},
        },
        network::{Ipv4Network, Ipv6Network},
        packet::{
            IpPacket, IpPacketVersion, Ipv4PacketProtocol, Tcpv4Packet, TcpPacketFlags,
        },
    },
};

#[cfg(test)]
pub(crate) use {
    net_literals::{ipv4, addrv4},
    tokio::{
        io::{AsyncReadExt, AsyncWriteExt},
        net::{TcpStream, TcpListener},
    },
    futures::{join, SinkExt},
    crate::{
        device::{BiChannel, IpHub, NatBuilder},
        SinkStreamExt,
    },
};