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

extern crate libc;
use std::io::prelude::*;

fn __mkfifo(name: String) -> String {
    let prefix = "/tmp/palombe/";
    let path = format!("{}{}", prefix, name);
    std::fs::create_dir_all(prefix)
        .expect(&format!("Error: couldn't create the folder {}", prefix));
    let filename = std::ffi::CString::new(path.clone()).unwrap();
    unsafe { libc::mkfifo(filename.as_ptr(), 0o600); }
    return path;
}

#[no_mangle]
pub extern "C" fn send(name: String, value: String) {
    let path = __mkfifo(name);
    std::thread::spawn(move || {
        let mut file = std::fs::OpenOptions::new().write(true).open(path)
            .expect("Error: couldn't open the named pipe");
        file.write_all(value.as_bytes())
            .expect("Error: couldn't write the named pipe");
    });
}

#[no_mangle]
pub extern "C" fn receive(name: String) -> String {
    let path = __mkfifo(name);
    let file = std::fs::File::open(path.clone())
        .expect(&format!("Error: couldn't open: {}", path));
    let mut reader = std::io::BufReader::new(file);
    let mut buffer = String::new();
    loop {
        let len = reader.read_line(&mut buffer)
            .expect("Error: couldn't read the input file");
        if len == 0 {
            std::fs::remove_file(&path)
                .expect(&format!("Error: couldn't remove the file {}", path));
            return buffer;
        }
    }
}