Add umask

src/context/context.rs

@@ -109,6 +109,8 @@ pub struct Context {
     pub egid: u32,
     /// The effective namespace id
     pub ens: SchemeNamespace,
+    /// Process umask
+    pub umask: usize,
     /// Status of context
     pub status: Status,
     /// Context running or not
@@ -169,6 +171,7 @@ impl Context {
             euid: 0,
             egid: 0,
             ens: SchemeNamespace::from(0),
+            umask: 0o022,
             status: Status::Blocked,
             running: false,
             cpu_id: None,

src/syscall/fs.rs

@@ -85,13 +85,15 @@ pub fn getcwd(buf: &mut [u8]) -> Result<usize> {
 
 /// Open syscall
 pub fn open(path: &[u8], flags: usize) -> Result<FileHandle> {
-    let (path_canon, uid, gid, scheme_ns) = {
+    let (path_canon, uid, gid, scheme_ns, umask) = {
         let contexts = context::contexts();
         let context_lock = contexts.current().ok_or(Error::new(ESRCH))?;
         let context = context_lock.read();
-        (context.canonicalize(path), context.euid, context.egid, context.ens)
+        (context.canonicalize(path), context.euid, context.egid, context.ens, context.umask)
     };
 
+    let flags = (flags & (!0o777)) | (flags & 0o777) & (!(umask & 0o777));
+
     //println!("open {}", unsafe { ::core::str::from_utf8_unchecked(&path_canon) });
 
     let mut parts = path_canon.splitn(2, |&b| b == b':');

src/syscall/mod.rs

@@ -131,6 +131,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
                 SYS_PHYSFREE => physfree(b, c),
                 SYS_PHYSMAP => physmap(b, c, d),
                 SYS_PHYSUNMAP => physunmap(b),
+                SYS_UMASK => umask(b),
                 SYS_VIRTTOPHYS => virttophys(b),
                 _ => Err(Error::new(ENOSYS))
             }

src/syscall/process.rs

@@ -73,6 +73,7 @@ pub fn clone(flags: usize, stack_base: usize) -> Result<ContextId> {
         let euid;
         let egid;
         let ens;
+        let umask;
         let mut cpu_id = None;
         let arch;
         let vfork;
@@ -104,6 +105,7 @@ pub fn clone(flags: usize, stack_base: usize) -> Result<ContextId> {
             euid = context.euid;
             egid = context.egid;
             ens = context.ens;
+            umask = context.umask;
 
             if flags & CLONE_VM == CLONE_VM {
                 cpu_id = context.cpu_id;
@@ -323,6 +325,7 @@ pub fn clone(flags: usize, stack_base: usize) -> Result<ContextId> {
             context.euid = euid;
             context.egid = egid;
             context.ens = ens;
+            context.umask = umask;
 
             context.cpu_id = cpu_id;
 
@@ -1187,6 +1190,19 @@ pub fn sigreturn() -> Result<usize> {
     unreachable!();
 }
 
+pub fn umask(mask: usize) -> Result<usize> {
+    let previous;
+    {
+        let contexts = context::contexts();
+        let context_lock = contexts.current().ok_or(Error::new(ESRCH))?;
+        let mut context = context_lock.write();
+        previous = context.umask;
+        context.umask = mask;
+    }
+
+    Ok(previous)
+}
+
 fn reap(pid: ContextId) -> Result<ContextId> {
     // Spin until not running
     let mut running = true;