PR for Rawposix(dispatcher.rs, fs_call.rs, misc.rs)

Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "rustposix"
+name = "rawposix"
 version = "0.1.0"
 authors = ["Nicholas Smith Renner <[email protected]>", "Jonathan Eli Singer <[email protected]>", "Tristan J. Brigham <[email protected]>"]
 edition = "2018"

mod.rs

@@ -0,0 +1 @@
+pub mod rawposix;

src/interface/comm.rs

@@ -641,4 +641,4 @@ pub fn kernel_select(
     };
 
     return result;
-}
+}

src/interface/misc.rs

@@ -25,7 +25,7 @@ pub use std::sync::atomic::{
 pub use std::sync::Arc as RustRfc;
 pub use std::thread::spawn as helper_thread;
 
-use libc::{mmap, pthread_exit, pthread_kill, pthread_self, sched_yield};
+use libc::{mmap, pthread_exit, pthread_kill, pthread_self, sched_yield, syscall, SYS_clock_nanosleep, SYS_futex};
 use std::ffi::c_void;
 
 pub use serde::{Deserialize as SerdeDeserialize, Serialize as SerdeSerialize};
@@ -306,6 +306,14 @@ pub fn lind_kill_from_id(cage_id: u64, sig: i32) {
     }
 }
 
+pub fn libc_futex(uaddr: u64, futex_op: u32, val: u32, val2: u32, uaddr2: u32, val3: u32) -> i32 {
+    unsafe { syscall(SYS_futex, uaddr, futex_op, val, val2, uaddr2, val3)  as i32 }
+}
+
+pub fn libc_nanosleep_time64(clockid: u32, flags: i32, req: usize, rem: usize) -> i32 {
+    unsafe { syscall(SYS_clock_nanosleep, clockid, flags, req, rem)  as i32 }
+}
+
 #[derive(Debug)]
 pub struct AdvisoryLock {
     //0 signifies unlocked, -1 signifies locked exclusively, positive number signifies that many shared lock holders

src/interface/types.rs

@@ -76,14 +76,14 @@ pub struct Rlimit {
     pub rlim_max: u64,
 }
 
-#[derive(Eq, PartialEq, Default, Copy, Clone)]
+#[derive(Eq, PartialEq, Default, Copy, Clone, Debug)]
 #[repr(C)]
 pub struct PipeArray {
     pub readfd: i32,
     pub writefd: i32,
 }
 
-#[derive(Eq, PartialEq, Default, Copy, Clone)]
+#[derive(Eq, PartialEq, Default, Copy, Clone, Debug)]
 #[repr(C)]
 pub struct SockPair {
     pub sock1: i32,
@@ -229,6 +229,7 @@ pub union Arg {
     // pub dispatch_structsem: *mut sem_t,
     // pub dispatch_ifaddrs: *mut ifaddrs,
     pub dispatch_constiovecstruct: *const interface::IovecStruct,
+    pub dispatch_cloneargs: *mut interface::CloneArgStruct
 }
 
 use std::mem::size_of;
@@ -241,6 +242,22 @@ pub struct ClippedDirent {
     pub d_reclen: u16,
 }
 
+#[derive(Copy, Clone, Default, Debug)]
+#[repr(C)]
+pub struct CloneArgStruct {
+    pub flags: u64,           // Flags that control the behavior of the child process
+    pub pidfd: u64,           // File descriptor to receive the child's PID
+    pub child_tid: u64,       // Pointer to a memory location where the child TID will be stored
+    pub parent_tid: u64,      // Pointer to a memory location where the parent's TID will be stored
+    pub exit_signal: u64,     // Signal to be sent when the child process exits
+    pub stack: u64,           // Address of the stack for the child process
+    pub stack_size: u64,      // Size of the stack for the child process
+    pub tls: u64,             // Thread-Local Storage (TLS) descriptor for the child thread
+    pub set_tid: u64,         // Pointer to an array of TIDs to be set in the child
+    pub set_tid_size: u64,    // Number of TIDs in the `set_tid` array
+    pub cgroup: u64,          // File descriptor for the cgroup to which the child process should be attached
+}
+
 pub const CLIPPED_DIRENT_SIZE: u32 = size_of::<interface::ClippedDirent>() as u32;
 
 pub fn get_int(union_argument: Arg) -> Result<i32, i32> {
@@ -478,6 +495,17 @@ pub fn get_ioctlptrunion<'a>(union_argument: Arg) -> Result<&'a mut u8, i32> {
     ));
 }
 
+pub fn get_cloneargs<'a>(clone_args: Arg) -> Result<&'a mut CloneArgStruct, i32> {
+    let pointer = unsafe { clone_args.dispatch_cloneargs };
+    if !pointer.is_null() {
+        return Ok(unsafe { &mut *pointer });
+    }
+    return Err(syscall_error(
+        Errno::EFAULT,
+        "dispatcher",
+        "input data not valid",
+    ));
+}
 
 // pub fn get_ioctlptrunion(union_argument: Arg) -> Result<IoctlPtrUnion, i32> {
 //     return Ok(unsafe { union_argument.dispatch_ioctlptrunion });
@@ -631,7 +659,8 @@ pub fn get_sockaddr(union_argument: Arg, addrlen: u32) -> Result<interface::GenS
                 let v6_ptr = pointer as *const interface::SockaddrV6;
                 return Ok(interface::GenSockaddr::V6(unsafe { *v6_ptr }));
             }
-            _ => {
+            val => {
+                println!("val: {}", val);
                 return Err(syscall_error(
                     Errno::EOPNOTSUPP,
                     "dispatcher",