kevy-sys 1.17.0

Hand-curated OS bindings for kevy — sockets + readiness poller.
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
66
67
68
69

use super::*;
use std::io::{Read, Write};

#[test]
fn listen_accept_roundtrip() {
    let listener = tcp_listen([127, 0, 0, 1], 0, 16).unwrap();
    let port = listener.local_port().unwrap();
    assert_ne!(port, 0);

    let server = std::thread::spawn(move || {
        let conn = listener.accept().unwrap();
        let mut b = [0u8; 1];
        assert_eq!(conn.read(&mut b).unwrap(), 1);
        conn.write_all(&b).unwrap();
    });

    let mut client = std::net::TcpStream::connect(("127.0.0.1", port)).unwrap();
    client.write_all(b"Z").unwrap();
    let mut got = [0u8; 1];
    assert_eq!(client.read(&mut got).unwrap(), 1);
    assert_eq!(&got, b"Z");

    server.join().unwrap();
}

#[test]
fn poller_signals_listener_readable() {
    let listener = tcp_listen([127, 0, 0, 1], 0, 16).unwrap();
    listener.set_nonblocking().unwrap();
    let port = listener.local_port().unwrap();

    let poller = Poller::new().unwrap();
    poller.add(listener.raw(), true, false).unwrap();

    let _client = std::net::TcpStream::connect(("127.0.0.1", port)).unwrap();

    let mut events = Vec::new();
    let n = poller.wait(&mut events, Some(2000)).unwrap();
    assert!(n >= 1, "expected a readiness event");
    assert!(events.iter().any(|e| e.fd == listener.raw() && e.readable));

    // Non-blocking accept should now succeed.
    listener.accept().unwrap();
}

#[test]
fn waker_wakes_poller() {
    let w = std::sync::Arc::new(waker().unwrap());
    let poller = Poller::new().unwrap();
    poller.add(w.read_fd(), true, false).unwrap();

    let w2 = w.clone();
    std::thread::spawn(move || w2.wake().unwrap());

    let mut events = Vec::new();
    let n = poller.wait(&mut events, Some(2000)).unwrap();
    assert!(n >= 1, "waker should have woken the poller");
    assert!(events.iter().any(|e| e.fd == w.read_fd() && e.readable));
    w.drain();
}

#[test]
fn reuseport_allows_shared_port() {
    let l1 = tcp_listen_reuseport([127, 0, 0, 1], 0, 16).unwrap();
    let port = l1.local_port().unwrap();
    // A second listener on the SAME port succeeds only because of SO_REUSEPORT.
    let l2 = tcp_listen_reuseport([127, 0, 0, 1], port, 16).unwrap();
    assert_eq!(l2.local_port().unwrap(), port);
}