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

use std::ffi::c_void;
use std::mem::MaybeUninit;

use crate::*;
use crate::ffi as ffi;

pub fn send(buf: &[u8], recipient: usize, tag: i32) -> DotsResult<()> {
    unsafe {
        let ret = ffi::dots_msg_send(buf.as_ptr() as *const c_void, buf.len(), recipient, tag);
        if ret != 0 {
            return Err(DotsError::from_ret(ret));
        }
    }

    Ok(())
}

pub fn recv(buf: &mut [u8], recipient: usize, tag: i32) -> DotsResult<usize> {
    unsafe {
        let mut bytes_received: usize = MaybeUninit::uninit().assume_init();
        let ret = ffi::dots_msg_recv(buf.as_ptr() as *mut c_void, buf.len(), recipient, tag, &mut bytes_received);
        if ret != 0 {
            return Err(DotsError::from_ret(ret));
        }

        Ok(bytes_received)
    }
}