devela::_dep::nc

Function sendto

pub unsafe fn sendto(
    sockfd: i32,
    buf: &[u8],
    flags: i32,
    dest_addr: Option<*const sockaddr_t>,
    addrlen: u32,
) -> Result<isize, i32> 
Available on crate feature dep_nc only.
Expand description

Send a message on a socket.

§Examples

use std::thread;

const READ_SIDE: usize = 0;
const WRITE_SIDE: usize = 1;

fn main() {
    let mut fds = [-1_i32; 2];

    let ret = unsafe { nc::socketpair(nc::AF_UNIX, nc::SOCK_STREAM, 0, &mut fds) };
    assert!(ret.is_ok());
    println!("socket pairs: {}, {}", fds[0], fds[1]);

    // Start worker thread
    thread::spawn(move || {
        println!("worker thread started");
        let msg = "Hello, Rust";
        println!("[worker] Will send msg: {msg}");
        let ret = unsafe { nc::sendto(fds[WRITE_SIDE], msg.as_bytes(), 0, None, 0) };
        assert!(ret.is_ok());
        assert_eq!(ret, Ok(msg.len() as nc::ssize_t));
    });

    let mut buf = [0_u8; 1024];
    let ret = unsafe { nc::recvfrom(fds[READ_SIDE], &mut buf, 0, None, None) };
    assert!(ret.is_ok());
    let nread = ret.unwrap();
    let msg = std::str::from_utf8(&buf[..nread as usize]).unwrap();
    println!("[main] recv msg: {msg}");

    unsafe {
        let _ = nc::close(fds[0]);
        let _ = nc::close(fds[1]);
    }
}