read/
read.rs

1use async_std::os::unix::io::AsRawFd;
2use async_std::prelude::*;
3use async_std::task;
4use async_tun::result::Result;
5use async_tun::TunBuilder;
6use std::net::Ipv4Addr;
7
8async fn async_main() -> Result<()> {
9    let tun = TunBuilder::new()
10        .name("")
11        .tap(false)
12        .packet_info(false)
13        .mtu(1350)
14        .up()
15        .address(Ipv4Addr::new(10, 0, 0, 1))
16        .destination(Ipv4Addr::new(10, 1, 0, 1))
17        .broadcast(Ipv4Addr::BROADCAST)
18        .netmask(Ipv4Addr::new(255, 255, 255, 0))
19        .try_build()
20        .await?;
21
22    println!("-----------");
23    println!("tun created");
24    println!("-----------");
25
26    println!(
27        "┌ name: {}\n├ fd: {}\n├ mtu: {}\n├ flags: {}\n├ address: {}\n├ destination: {}\n├ broadcast: {}\n└ netmask: {}",
28        tun.name(),
29        tun.as_raw_fd(),
30        tun.mtu().unwrap(),
31        tun.flags().unwrap(),
32        tun.address().unwrap(),
33        tun.destination().unwrap(),
34        tun.broadcast().unwrap(),
35        tun.netmask().unwrap(),
36    );
37
38    println!("---------------------");
39    println!("ping 10.1.0.2 to test");
40    println!("---------------------");
41
42    let (mut reader, mut _writer) = tun.split();
43
44    let mut buf = [0u8; 1024];
45    loop {
46        let n = reader.read(&mut buf).await?;
47        println!("reading {} bytes: {:?}", n, &buf[..n]);
48    }
49}
50
51fn main() -> Result<()> {
52    task::block_on(async_main())
53}