win_uds 0.2.2

Windows Unix Domain Socket
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

use std::io::Read;
use std::io::Write;
use win_uds::net::*;
#[test]
fn echo() {
    let tmp = std::env::temp_dir();
    let sock_path = tmp.join("test-uds-echo.sock");
    let _ = std::fs::remove_file(&sock_path);
    let listener = UnixListener::bind(&sock_path).unwrap();
    let srv = std::thread::spawn(move || {
        let (mut stream, _addr) = listener.accept().expect("accept failed");
        let mut buf = [0u8; 128];
        let n = match stream.read(&mut buf) {
            Ok(n) => n,
            Err(e) => panic!("read error: {}", e),
        };
        stream.write_all(&buf[..n]).expect("write_all failed");
    });

    let sock_path_clone = sock_path.clone();

    let cli = std::thread::spawn(move || {
        let mut stream = UnixStream::connect(&sock_path).unwrap();
        let req = b"Hello, world!";
        stream.write_all(req).unwrap();
        let mut resp = vec![0; req.len()];
        stream.read_exact(&mut resp).unwrap();
        assert_eq!(req, &resp[..]);
    });
    cli.join().unwrap();
    srv.join().unwrap();
    let _ = std::fs::remove_file(&sock_path_clone);
}
#[test]
fn too_long_path() {
    let tmp = std::env::temp_dir();
    let path = tmp.join("o".repeat(256));
    let _ = std::fs::remove_file(&path);
    assert!(UnixListener::bind(&path).is_err());
}
#[test]
fn zero_path() {
    let tmp = std::env::temp_dir();
    let path = tmp.join("oo\0oo");
    let _ = std::fs::remove_file(&path);
    assert!(UnixListener::bind(&path).is_err());
}