use crate::{header::errno::EOPNOTSUPP, io::Write}; use core::{arch::asm, ptr}; use super::{types::*, Pal, ERRNO}; use crate::{ c_str::CStr, header::{ dirent::dirent, errno::EINVAL, signal::SIGCHLD, sys_resource::{rlimit, rusage}, sys_stat::{stat, S_IFIFO}, sys_statvfs::statvfs, sys_time::{timeval, timezone}, unistd::SEEK_SET, }, }; // use header::sys_times::tms; use crate::{ error::{Errno, Result}, header::{sys_utsname::utsname, time::timespec}, }; mod epoll; mod ptrace; mod signal; mod socket; const AT_FDCWD: c_int = -100; const AT_EMPTY_PATH: c_int = 0x1000; const AT_REMOVEDIR: c_int = 0x200; const SYS_CLONE: usize = 56; const CLONE_VM: usize = 0x0100; const CLONE_FS: usize = 0x0200; const CLONE_FILES: usize = 0x0400; const CLONE_SIGHAND: usize = 0x0800; const CLONE_THREAD: usize = 0x00010000; #[repr(C)] #[derive(Default)] struct linux_statfs { f_type: c_long, /* type of file system (see below) */ f_bsize: c_long, /* optimal transfer block size */ f_blocks: fsblkcnt_t, /* total data blocks in file system */ f_bfree: fsblkcnt_t, /* free blocks in fs */ f_bavail: fsblkcnt_t, /* free blocks available to unprivileged user */ f_files: fsfilcnt_t, /* total file nodes in file system */ f_ffree: fsfilcnt_t, /* free file nodes in fs */ f_fsid: c_long, /* file system id */ f_namelen: c_long, /* maximum length of filenames */ f_frsize: c_long, /* fragment size (since Linux 2.6) */ f_flags: c_long, f_spare: [c_long; 4], } // TODO const ERRNO_MAX: usize = 4095; pub fn e_raw(sys: usize) -> Result { if sys > ERRNO_MAX.wrapping_neg() { Err(Errno(sys.wrapping_neg() as _)) } else { Ok(sys) } } /// Linux syscall implementation of the platform abstraction layer. pub struct Sys; impl Sys { pub unsafe fn ioctl(fd: c_int, request: c_ulong, out: *mut c_void) -> Result { // TODO: Somehow support varargs to syscall?? Ok(e_raw(syscall!(IOCTL, fd, request, out))? as c_int) } // fn times(out: *mut tms) -> clock_t { // unsafe { syscall!(TIMES, out) as clock_t } // } } impl Pal for Sys { fn access(path: CStr, mode: c_int) -> Result<()> { e_raw(unsafe { syscall!(ACCESS, path.as_ptr(), mode) }).map(|_| ()) } unsafe fn brk(addr: *mut c_void) -> Result<*mut c_void> { Ok(e_raw(unsafe { syscall!(BRK, addr) })? as *mut c_void) } fn chdir(path: CStr) -> Result<()> { e_raw(unsafe { syscall!(CHDIR, path.as_ptr()) }).map(|_| ()) } fn set_default_scheme(scheme: CStr) -> Result<()> { Err(Errno(EOPNOTSUPP)) } fn chmod(path: CStr, mode: mode_t) -> Result<()> { e_raw(unsafe { syscall!(FCHMODAT, AT_FDCWD, path.as_ptr(), mode, 0) }).map(|_| ()) } fn chown(path: CStr, owner: uid_t, group: gid_t) -> Result<()> { e_raw(unsafe { syscall!( FCHOWNAT, AT_FDCWD, path.as_ptr(), owner as u32, group as u32 ) }) .map(|_| ()) } unsafe fn clock_getres(clk_id: clockid_t, tp: *mut timespec) -> Result<()> { e_raw(syscall!(CLOCK_GETRES, clk_id, tp)).map(|_| ()) } unsafe fn clock_gettime(clk_id: clockid_t, tp: *mut timespec) -> Result<()> { e_raw(syscall!(CLOCK_GETTIME, clk_id, tp)).map(|_| ()) } unsafe fn clock_settime(clk_id: clockid_t, tp: *const timespec) -> Result<()> { e_raw(syscall!(CLOCK_SETTIME, clk_id, tp)).map(|_| ()) } fn close(fildes: c_int) -> Result<()> { e_raw(unsafe { syscall!(CLOSE, fildes) }).map(|_| ()) } fn dup(fildes: c_int) -> Result { e_raw(unsafe { syscall!(DUP, fildes) }).map(|f| f as c_int) } fn dup2(fildes: c_int, fildes2: c_int) -> Result { e_raw(unsafe { syscall!(DUP3, fildes, fildes2, 0) }).map(|f| f as c_int) } unsafe fn execve(path: CStr, argv: *const *mut c_char, envp: *const *mut c_char) -> Result<()> { e_raw(syscall!(EXECVE, path.as_ptr(), argv, envp))?; unreachable!() } unsafe fn fexecve( fildes: c_int, argv: *const *mut c_char, envp: *const *mut c_char, ) -> Result<()> { todo!("not yet used by relibc") } fn exit(status: c_int) -> ! { unsafe { syscall!(EXIT, status); } loop {} } unsafe fn exit_thread(_stack_base: *mut (), _stack_size: usize) -> ! { // TODO Self::exit(0) } fn fchdir(fildes: c_int) -> Result<()> { e_raw(unsafe { syscall!(FCHDIR, fildes) }).map(|_| ()) } fn fchmod(fildes: c_int, mode: mode_t) -> Result<()> { e_raw(unsafe { syscall!(FCHMOD, fildes, mode) }).map(|_| ()) } fn fchown(fildes: c_int, owner: uid_t, group: gid_t) -> Result<()> { e_raw(unsafe { syscall!(FCHOWN, fildes, owner, group) }).map(|_| ()) } fn fdatasync(fildes: c_int) -> Result<()> { e_raw(unsafe { syscall!(FDATASYNC, fildes) }).map(|_| ()) } fn flock(fd: c_int, operation: c_int) -> Result<()> { e_raw(unsafe { syscall!(FLOCK, fd, operation) }).map(|_| ()) } unsafe fn fstat(fildes: c_int, buf: *mut stat) -> Result<()> { let empty = b"\0"; let empty_ptr = empty.as_ptr() as *const c_char; e_raw(unsafe { syscall!(NEWFSTATAT, fildes, empty_ptr, buf, AT_EMPTY_PATH) }).map(|_| ()) } unsafe fn fstatvfs(fildes: c_int, buf: *mut statvfs) -> Result<()> { let mut kbuf = linux_statfs::default(); let kbuf_ptr = &mut kbuf as *mut linux_statfs; e_raw(syscall!(FSTATFS, fildes, kbuf_ptr))?; if !buf.is_null() { (*buf).f_bsize = kbuf.f_bsize as c_ulong; (*buf).f_frsize = if kbuf.f_frsize != 0 { kbuf.f_frsize } else { kbuf.f_bsize } as c_ulong; (*buf).f_blocks = kbuf.f_blocks; (*buf).f_bfree = kbuf.f_bfree; (*buf).f_bavail = kbuf.f_bavail; (*buf).f_files = kbuf.f_files; (*buf).f_ffree = kbuf.f_ffree; (*buf).f_favail = kbuf.f_ffree; (*buf).f_fsid = kbuf.f_fsid as c_ulong; (*buf).f_flag = kbuf.f_flags as c_ulong; (*buf).f_namemax = kbuf.f_namelen as c_ulong; } Ok(()) } fn fcntl(fildes: c_int, cmd: c_int, arg: c_ulonglong) -> Result { Ok(e_raw(unsafe { syscall!(FCNTL, fildes, cmd, arg) })? as c_int) } unsafe fn fork() -> Result { Ok(e_raw(unsafe { syscall!(CLONE, SIGCHLD, 0, 0, 0, 0) })? as pid_t) } fn fpath(fildes: c_int, out: &mut [u8]) -> Result { let proc_path = format!("/proc/self/fd/{}\0", fildes).into_bytes(); Self::readlink(CStr::from_bytes_with_nul(&proc_path).unwrap(), out) } fn fsync(fildes: c_int) -> Result<()> { e_raw(unsafe { syscall!(FSYNC, fildes) }).map(|_| ()) } fn ftruncate(fildes: c_int, length: off_t) -> Result<()> { e_raw(unsafe { syscall!(FTRUNCATE, fildes, length) }).map(|_| ()) } #[inline] unsafe fn futex_wait(addr: *mut u32, val: u32, deadline: Option<×pec>) -> Result<()> { let deadline = deadline.map_or(0, |d| d as *const _ as usize); e_raw(unsafe { syscall!( FUTEX, addr, // uaddr 9, // futex_op: FUTEX_WAIT_BITSET val, // val deadline, // timeout: deadline 0, // uaddr2/val2: 0/NULL 0xffffffff // val3: FUTEX_BITSET_MATCH_ANY ) }) .map(|_| ()) } #[inline] unsafe fn futex_wake(addr: *mut u32, num: u32) -> Result { e_raw(unsafe { syscall!(FUTEX, addr, 1 /* FUTEX_WAKE */, num) }) .map(|n| n as u32) } unsafe fn futimens(fd: c_int, times: *const timespec) -> Result<()> { e_raw(unsafe { syscall!(UTIMENSAT, fd, ptr::null::(), times, 0) }).map(|_| ()) } unsafe fn utimens(path: CStr, times: *const timespec) -> Result<()> { e_raw(unsafe { syscall!(UTIMENSAT, AT_FDCWD, path.as_ptr(), times, 0) }).map(|_| ()) } unsafe fn getcwd(buf: *mut c_char, size: size_t) -> Result<()> { e_raw(unsafe { syscall!(GETCWD, buf, size) })?; Ok(()) } fn getdents(fd: c_int, buf: &mut [u8], _off: u64) -> Result { e_raw(unsafe { syscall!(GETDENTS64, fd, buf.as_mut_ptr(), buf.len()) }) } fn dir_seek(fd: c_int, off: u64) -> Result<()> { e_raw(unsafe { syscall!(LSEEK, fd, off, SEEK_SET) })?; Ok(()) } unsafe fn dent_reclen_offset(this_dent: &[u8], offset: usize) -> Option<(u16, u64)> { let dent = this_dent.as_ptr().cast::(); Some(((*dent).d_reclen, (*dent).d_off as u64)) } fn getegid() -> gid_t { // Always successful unsafe { syscall!(GETEGID) as gid_t } } fn geteuid() -> uid_t { // Always successful unsafe { syscall!(GETEUID) as uid_t } } fn getgid() -> gid_t { // Always successful unsafe { syscall!(GETGID) as gid_t } } unsafe fn getgroups(size: c_int, list: *mut gid_t) -> Result { Ok(e_raw(unsafe { syscall!(GETGROUPS, size, list) })? as c_int) } fn getpagesize() -> usize { 4096 } fn getpgid(pid: pid_t) -> Result { Ok(e_raw(unsafe { syscall!(GETPGID, pid) })? as pid_t) } fn getpid() -> pid_t { // Always successful unsafe { syscall!(GETPID) as pid_t } } fn getppid() -> pid_t { // Always successful unsafe { syscall!(GETPPID) as pid_t } } fn getpriority(which: c_int, who: id_t) -> Result { Ok(e_raw(unsafe { syscall!(GETPRIORITY, which, who) })? as c_int) } fn getrandom(buf: &mut [u8], flags: c_uint) -> Result { e_raw(unsafe { syscall!(GETRANDOM, buf.as_mut_ptr(), buf.len(), flags) }) } unsafe fn getrlimit(resource: c_int, rlim: *mut rlimit) -> Result<()> { e_raw(syscall!(GETRLIMIT, resource, rlim)).map(|_| ()) } fn getresgid( rgid: Option<&mut gid_t>, egid: Option<&mut gid_t>, sgid: Option<&mut gid_t>, ) -> Result<()> { unsafe { e_raw(syscall!( GETRESGID, rgid.map_or(0, |r| r as *const _ as usize), egid.map_or(0, |r| r as *const _ as usize), sgid.map_or(0, |r| r as *const _ as usize) )) .map(|_| ()) } } fn getresuid( ruid: Option<&mut uid_t>, euid: Option<&mut uid_t>, suid: Option<&mut uid_t>, ) -> Result<()> { unsafe { e_raw(syscall!( GETRESUID, ruid.map_or(0, |r| r as *const _ as usize), euid.map_or(0, |r| r as *const _ as usize), suid.map_or(0, |r| r as *const _ as usize) )) .map(|_| ()) } } unsafe fn setrlimit(resource: c_int, rlimit: *const rlimit) -> Result<()> { e_raw(syscall!(SETRLIMIT, resource, rlimit)).map(|_| ()) } fn getrusage(who: c_int, r_usage: &mut rusage) -> Result<()> { e_raw(unsafe { syscall!(GETRUSAGE, who, r_usage as *mut rusage) })?; Ok(()) } fn getsid(pid: pid_t) -> Result { Ok(e_raw(unsafe { syscall!(GETSID, pid) })? as pid_t) } fn gettid() -> pid_t { // Always successful unsafe { syscall!(GETTID) as pid_t } } unsafe fn gettimeofday(tp: *mut timeval, tzp: *mut timezone) -> Result<()> { e_raw(unsafe { syscall!(GETTIMEOFDAY, tp, tzp) }).map(|_| ()) } fn getuid() -> uid_t { unsafe { syscall!(GETUID) as uid_t } } fn lchown(path: CStr, owner: uid_t, group: gid_t) -> Result<()> { e_raw(unsafe { syscall!(LCHOWN, path.as_ptr(), owner, group) }).map(|_| ()) } fn link(path1: CStr, path2: CStr) -> Result<()> { e_raw(unsafe { syscall!( LINKAT, AT_FDCWD, path1.as_ptr(), AT_FDCWD, path2.as_ptr(), 0 ) }) .map(|_| ()) } fn lseek(fildes: c_int, offset: off_t, whence: c_int) -> Result { e_raw(unsafe { syscall!(LSEEK, fildes, offset, whence) }).map(|o| o as off_t) } fn mkdir(path: CStr, mode: mode_t) -> Result<()> { e_raw(unsafe { syscall!(MKDIRAT, AT_FDCWD, path.as_ptr(), mode) }).map(|_| ()) } fn mknodat(dir_fildes: c_int, path: CStr, mode: mode_t, dev: dev_t) -> Result<()> { // Note: dev_t is c_long (i64) and __kernel_dev_t is u32; So we need to cast it // and check for overflow let k_dev: c_uint = dev as c_uint; if k_dev as dev_t != dev { return Err(Errno(EINVAL)); } e_raw(unsafe { syscall!(MKNODAT, dir_fildes, path.as_ptr(), mode, k_dev) }).map(|_| ()) } fn mknod(path: CStr, mode: mode_t, dev: dev_t) -> Result<()> { Sys::mknodat(AT_FDCWD, path, mode, dev) } fn mkfifo(path: CStr, mode: mode_t) -> Result<()> { Sys::mknod(path, mode | S_IFIFO, 0) } unsafe fn mlock(addr: *const c_void, len: usize) -> Result<()> { e_raw(unsafe { syscall!(MLOCK, addr, len) }).map(|_| ()) } unsafe fn mlockall(flags: c_int) -> Result<()> { e_raw(unsafe { syscall!(MLOCKALL, flags) }).map(|_| ()) } unsafe fn mmap( addr: *mut c_void, len: usize, prot: c_int, flags: c_int, fildes: c_int, off: off_t, ) -> Result<*mut c_void> { Ok(e_raw(syscall!(MMAP, addr, len, prot, flags, fildes, off))? as *mut c_void) } unsafe fn mremap( addr: *mut c_void, len: usize, new_len: usize, flags: c_int, args: *mut c_void, ) -> Result<*mut c_void> { Ok(e_raw(syscall!(MREMAP, addr, len, new_len, flags, args))? as *mut c_void) } unsafe fn mprotect(addr: *mut c_void, len: usize, prot: c_int) -> Result<()> { e_raw(syscall!(MPROTECT, addr, len, prot)).map(|_| ()) } unsafe fn msync(addr: *mut c_void, len: usize, flags: c_int) -> Result<()> { e_raw(syscall!(MSYNC, addr, len, flags)).map(|_| ()) } unsafe fn munlock(addr: *const c_void, len: usize) -> Result<()> { e_raw(syscall!(MUNLOCK, addr, len)).map(|_| ()) } unsafe fn munlockall() -> Result<()> { e_raw(unsafe { syscall!(MUNLOCKALL) }).map(|_| ()) } unsafe fn munmap(addr: *mut c_void, len: usize) -> Result<()> { e_raw(syscall!(MUNMAP, addr, len)).map(|_| ()) } unsafe fn madvise(addr: *mut c_void, len: usize, flags: c_int) -> Result<()> { e_raw(syscall!(MADVISE, addr, len, flags)).map(|_| ()) } unsafe fn nanosleep(rqtp: *const timespec, rmtp: *mut timespec) -> Result<()> { e_raw(unsafe { syscall!(NANOSLEEP, rqtp, rmtp) }).map(|_| ()) } fn open(path: CStr, oflag: c_int, mode: mode_t) -> Result { e_raw(unsafe { syscall!(OPENAT, AT_FDCWD, path.as_ptr(), oflag, mode) }) .map(|fd| fd as c_int) } fn pipe2(fildes: &mut [c_int], flags: c_int) -> Result<()> { e_raw(unsafe { syscall!(PIPE2, fildes.as_mut_ptr(), flags) }).map(|_| ()) } #[cfg(target_arch = "x86_64")] unsafe fn rlct_clone(stack: *mut usize) -> Result { let flags = CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND | CLONE_THREAD; let pid; asm!(" # Call clone syscall syscall # Check if child or parent test rax, rax jnz 2f # Load registers pop rax pop rdi pop rsi pop rdx pop rcx pop r8 pop r9 # Call entry point call rax # Exit mov rax, 60 xor rdi, rdi syscall # Invalid instruction on failure to exit ud2 # Return PID if parent 2: ", inout("rax") SYS_CLONE => pid, inout("rdi") flags => _, inout("rsi") stack => _, inout("rdx") 0 => _, inout("r10") 0 => _, inout("r8") 0 => _, //TODO: out("rbx") _, out("rcx") _, out("r9") _, out("r11") _, out("r12") _, out("r13") _, out("r14") _, out("r15") _, ); let tid = e_raw(pid)?; Ok(crate::pthread::OsTid { thread_id: tid }) } unsafe fn rlct_kill(os_tid: crate::pthread::OsTid, signal: usize) -> Result<()> { let tgid = Self::getpid(); e_raw(unsafe { syscall!(TGKILL, tgid, os_tid.thread_id, signal) }).map(|_| ()) } fn current_os_tid() -> crate::pthread::OsTid { crate::pthread::OsTid { thread_id: unsafe { syscall!(GETTID) }, } } fn read(fildes: c_int, buf: &mut [u8]) -> Result { e_raw(unsafe { syscall!(READ, fildes, buf.as_mut_ptr(), buf.len()) }) } fn pread(fildes: c_int, buf: &mut [u8], off: off_t) -> Result { e_raw(unsafe { syscall!(PREAD64, fildes, buf.as_mut_ptr(), buf.len(), off) }) } fn readlink(pathname: CStr, out: &mut [u8]) -> Result { e_raw(unsafe { syscall!( READLINKAT, AT_FDCWD, pathname.as_ptr(), out.as_mut_ptr(), out.len() ) }) } fn rename(old: CStr, new: CStr) -> Result<()> { e_raw(unsafe { syscall!(RENAMEAT, AT_FDCWD, old.as_ptr(), AT_FDCWD, new.as_ptr()) }) .map(|_| ()) } fn rmdir(path: CStr) -> Result<()> { e_raw(unsafe { syscall!(UNLINKAT, AT_FDCWD, path.as_ptr(), AT_REMOVEDIR) }).map(|_| ()) } fn sched_yield() -> Result<()> { e_raw(unsafe { syscall!(SCHED_YIELD) }).map(|_| ()) } unsafe fn setgroups(size: size_t, list: *const gid_t) -> Result<()> { e_raw(unsafe { syscall!(SETGROUPS, size, list) }).map(|_| ()) } fn setpgid(pid: pid_t, pgid: pid_t) -> Result<()> { e_raw(unsafe { syscall!(SETPGID, pid, pgid) }).map(|_| ()) } fn setpriority(which: c_int, who: id_t, prio: c_int) -> Result<()> { e_raw(unsafe { syscall!(SETPRIORITY, which, who, prio) }).map(|_| ()) } fn setresgid(rgid: gid_t, egid: gid_t, sgid: gid_t) -> Result<()> { e_raw(unsafe { syscall!(SETRESGID, rgid, egid, sgid) }).map(|_| ()) } fn setresuid(ruid: uid_t, euid: uid_t, suid: uid_t) -> Result<()> { e_raw(unsafe { syscall!(SETRESUID, ruid, euid, suid) }).map(|_| ()) } fn setsid() -> Result<()> { e_raw(unsafe { syscall!(SETSID) }).map(|_| ()) } fn symlink(path1: CStr, path2: CStr) -> Result<()> { e_raw(unsafe { syscall!(SYMLINKAT, path1.as_ptr(), AT_FDCWD, path2.as_ptr()) }).map(|_| ()) } fn sync() -> Result<()> { e_raw(unsafe { syscall!(SYNC) }).map(|_| ()) } fn umask(mask: mode_t) -> mode_t { unsafe { syscall!(UMASK, mask) as mode_t } } unsafe fn uname(utsname: *mut utsname) -> Result<()> { e_raw(syscall!(UNAME, utsname, 0)).map(|_| ()) } fn unlink(path: CStr) -> Result<()> { e_raw(unsafe { syscall!(UNLINKAT, AT_FDCWD, path.as_ptr(), 0) }).map(|_| ()) } unsafe fn waitpid(pid: pid_t, stat_loc: *mut c_int, options: c_int) -> Result { e_raw(unsafe { syscall!(WAIT4, pid, stat_loc, options, 0) }).map(|p| p as pid_t) } fn write(fildes: c_int, buf: &[u8]) -> Result { e_raw(unsafe { syscall!(WRITE, fildes, buf.as_ptr(), buf.len()) }) } fn pwrite(fildes: c_int, buf: &[u8], off: off_t) -> Result { e_raw(unsafe { syscall!(PWRITE64, fildes, buf.as_ptr(), buf.len(), off) }) } fn verify() -> bool { // GETPID on Linux is 39, which does not exist on Redox e_raw(unsafe { sc::syscall5(sc::nr::GETPID, !0, !0, !0, !0, !0) }).is_ok() } }