moto-rt 0.16.0

Motor OS Runtime.
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

use core::sync::atomic::Ordering;

use super::error::ErrorCode;
use crate::Result;
use crate::RtVdsoVtable;
use crate::into_result;

pub type ThreadHandle = u64;

pub fn spawn(
    thread_fn: extern "C" fn(thread_arg: u64),
    stack_size: usize,
    thread_arg: u64,
) -> Result<ThreadHandle> {
    let vdso_spawn: extern "C" fn(extern "C" fn(thread_arg: u64), usize, u64) -> u64 = unsafe {
        core::mem::transmute(
            RtVdsoVtable::get().thread_spawn.load(Ordering::Relaxed) as usize as *const (),
        )
    };

    let res = vdso_spawn(thread_fn, stack_size, thread_arg);
    if res < u16::MAX as u64 {
        Err((res as ErrorCode).into())
    } else {
        Ok(res)
    }
}

pub fn yield_now() {
    let vdso_yield: extern "C" fn() = unsafe {
        core::mem::transmute(
            RtVdsoVtable::get().thread_yield.load(Ordering::Relaxed) as usize as *const (),
        )
    };

    vdso_yield()
}

pub fn sleep_until(deadline: crate::time::Instant) {
    let vdso_sleep: extern "C" fn(u64) = unsafe {
        core::mem::transmute(
            RtVdsoVtable::get().thread_sleep.load(Ordering::Relaxed) as usize as *const (),
        )
    };

    vdso_sleep(deadline.as_u64())
}

pub fn set_name(name: &str) -> Result<()> {
    let vdso_set_name: extern "C" fn(*const u8, usize) -> ErrorCode = unsafe {
        core::mem::transmute(
            RtVdsoVtable::get().thread_set_name.load(Ordering::Relaxed) as usize as *const (),
        )
    };

    into_result(vdso_set_name(name.as_ptr(), name.len()))
}

pub fn join(handle: ThreadHandle) -> Result<()> {
    let vdso_join: extern "C" fn(u64) -> ErrorCode = unsafe {
        core::mem::transmute(
            RtVdsoVtable::get().thread_join.load(Ordering::Relaxed) as usize as *const (),
        )
    };

    into_result(vdso_join(handle))
}