rawsock 0.3.0

Library for receiving and sending raw packets. While most crate wrap just one library, rawsock allows you to use pcap, wpcap, npcap and pf_ring (pfring) using a consistent API for all of them.
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
59
60
61
62
63
64
65

/**
    Static and dispatch in a loop in a worker thread wih break on demand.
*/

extern crate rawsock;
extern crate crossbeam_utils;
use crossbeam_utils::thread;
use rawsock::{pcap, open_best_library};
use rawsock::traits::{Library, StaticInterface, DynamicInterface};
mod commons;
use commons::open_library;
use std::thread::sleep;
use std::time::Duration;

fn main() {
    dynamic_loop();
    static_loop();
}

fn dynamic_loop(){
    let lib = open_best_library().expect("Could not open any library");
    let ifname = lib.all_interfaces()
        .expect("Could not obtain interface list").first()
        .expect("There are no available interfaces").name.clone();
    println!("Library version is {}, opening {} interface", lib.version(), &ifname);
    let interf = lib.open_interface(&ifname).expect("Could not open pcap interface");

    //To compile the code we need a thread scope to guarantee that inter2 will not outlive lib
    thread::scope(|s| {
        s.spawn(|_| {
            interf.loop_infinite_dyn(&  |packet|{
                println!("Received packet: {}", packet);
            }).expect("Error when running receiving loop");
        });
        println!("Waiting 5 seconds");
        sleep(Duration::from_secs(5));
        println!("Breaking the loop");
        interf.break_loop();
        println!("Loop is broken");
    }).unwrap();

}

fn static_loop(){
    let lib = open_library::<pcap::Library>();
    let ifname = lib.all_interfaces()
        .expect("Could not obtain interface list").first()
        .expect("There are no available interfaces").name.clone();
    println!("Library version is {}, opening {} interface", lib.version(), &ifname);
    let interf = lib.open_interface(&ifname).expect("Could not open pcap interface");

    //To compile the code we need a thread scope to guarantee that inter2 will not outlive lib
    thread::scope(|s| {
        s.spawn(|_| {
            interf.loop_infinite(|packet|{
                println!("Received packet: {}", packet);
            }).expect("Error when running receiving loop");
        });
        println!("Waiting 5 seconds");
        sleep(Duration::from_secs(5));
        println!("Breaking the loop");
        interf.break_loop();
        println!("Loop is broken");
    }).unwrap();
}