open-coroutine-core 0.7.0

The open-coroutine is a simple, efficient and generic coroutine library.
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
68
69

use crate::net::EventLoops;
use crate::syscall::{reset_errno, set_errno};
use libc::timespec;
use std::ffi::c_int;
use std::time::Duration;

trait NanosleepSyscall {
    extern "C" fn nanosleep(
        &self,
        fn_ptr: Option<&extern "C" fn(*const timespec, *mut timespec) -> c_int>,
        rqtp: *const timespec,
        rmtp: *mut timespec,
    ) -> c_int;
}

impl_syscall!(NanosleepSyscallFacade, NioNanosleepSyscall,
    nanosleep(rqtp: *const timespec, rmtp: *mut timespec) -> c_int
);

impl_facade!(NanosleepSyscallFacade, NanosleepSyscall,
    nanosleep(rqtp: *const timespec, rmtp: *mut timespec) -> c_int
);

#[repr(C)]
#[derive(Debug, Copy, Clone, Default)]
struct NioNanosleepSyscall {}

impl NanosleepSyscall for NioNanosleepSyscall {
    extern "C" fn nanosleep(
        &self,
        _: Option<&extern "C" fn(*const timespec, *mut timespec) -> c_int>,
        rqtp: *const timespec,
        rmtp: *mut timespec,
    ) -> c_int {
        let rqtp = unsafe { *rqtp };
        if rqtp.tv_sec < 0 || rqtp.tv_nsec < 0 || rqtp.tv_nsec > 999_999_999 {
            set_errno(libc::EINVAL);
            return -1;
        }
        let time = Duration::new(
            rqtp.tv_sec.try_into().expect("overflow"),
            rqtp.tv_nsec.try_into().expect("overflow")
        );
        if let Some(co) = crate::scheduler::SchedulableCoroutine::current() {
            let syscall = crate::common::constants::SyscallName::nanosleep;
            let new_state = crate::common::constants::SyscallState::Suspend(
                crate::common::get_timeout_time(time),
            );
            if co.syscall((), syscall, new_state).is_err() {
                crate::error!(
                    "{} change to syscall {} {} failed !",
                    co.name(),
                    syscall,
                    new_state
                );
            }
        }
        //等待事件到来
        _ = EventLoops::wait_event(Some(time));
        reset_errno();
        if !rmtp.is_null() {
            unsafe {
                (*rmtp).tv_sec = 0;
                (*rmtp).tv_nsec = 0;
            }
        }
        0
    }
}