nlink 0.15.1

Async netlink library for Linux network configuration
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

//! Destroy TCP sockets matching a filter.
//!
//! Demonstrates using SOCK_DESTROY to force-close sockets,
//! similar to `ss -K`.
//!
//! Run with: cargo run -p nlink --example sockdiag_kill --features sockdiag
//!
//! Requires root (CAP_NET_ADMIN).
//!
//! Examples:
//!   sudo cargo run -p nlink --example sockdiag_kill --features sockdiag -- 8080

use std::env;

use nlink::netlink::{Connection, SockDiag};

#[tokio::main]
async fn main() -> nlink::netlink::Result<()> {
    let args: Vec<String> = env::args().collect();
    let port: u16 = match args.get(1) {
        Some(p) => p.parse().expect("invalid port number"),
        None => {
            println!("Usage: sockdiag_kill <port>");
            println!("Destroys all TCP sockets with the given remote port.");
            return Ok(());
        }
    };

    let conn = Connection::<SockDiag>::new()?;

    // Find matching sockets
    let sockets = conn.query_tcp().await?;
    let mut destroyed = 0;

    for sock in &sockets {
        if sock.remote.port() == port {
            match conn.destroy_tcp_socket(sock).await {
                Ok(()) => {
                    println!("Destroyed: {} -> {}", sock.local, sock.remote);
                    destroyed += 1;
                }
                Err(e) => eprintln!("Failed to destroy {} -> {}: {}", sock.local, sock.remote, e),
            }
        }
    }

    println!(
        "\nDestroyed {} socket(s) with remote port {}",
        destroyed, port
    );

    Ok(())
}