Add F_GETFL and F_SETFL for fcntl

services/libs/jinux-std/src/fs/file_handle.rs

@@ -1,7 +1,7 @@
 //! Opend File Handle
 
 use crate::events::Observer;
-use crate::fs::utils::{IoEvents, IoctlCmd, Metadata, Poller, SeekFrom};
+use crate::fs::utils::{AccessMode, IoEvents, IoctlCmd, Metadata, Poller, SeekFrom, StatusFlags};
 use crate::prelude::*;
 use crate::tty::get_n_tty;
 
@@ -40,6 +40,18 @@ pub trait FileLike: Send + Sync + Any {
         panic!("metadata unsupported");
     }
 
+    fn status_flags(&self) -> StatusFlags {
+        StatusFlags::empty()
+    }
+
+    fn set_status_flags(&self, _new_flags: StatusFlags) -> Result<()> {
+        return_errno_with_message!(Errno::EINVAL, "set_status_flags is not supported");
+    }
+
+    fn access_mode(&self) -> AccessMode {
+        AccessMode::O_RDWR
+    }
+
     fn seek(&self, seek_from: SeekFrom) -> Result<usize> {
         return_errno_with_message!(Errno::EINVAL, "seek is not supported");
     }

services/libs/jinux-std/src/fs/inode_handle/dyn_cap.rs

@@ -23,7 +23,7 @@ impl InodeHandle<Rights> {
             dentry,
             offset: Mutex::new(0),
             access_mode,
-            status_flags: Mutex::new(status_flags),
+            status_flags: AtomicU32::new(status_flags.bits()),
         });
         Ok(Self(inner, Rights::from(access_mode)))
     }
@@ -80,6 +80,19 @@ impl FileLike for InodeHandle<Rights> {
         self.dentry().vnode().metadata()
     }
 
+    fn status_flags(&self) -> StatusFlags {
+        self.0.status_flags()
+    }
+
+    fn set_status_flags(&self, new_status_flags: StatusFlags) -> Result<()> {
+        self.0.set_status_flags(new_status_flags);
+        Ok(())
+    }
+
+    fn access_mode(&self) -> AccessMode {
+        self.0.access_mode()
+    }
+
     fn seek(&self, seek_from: SeekFrom) -> Result<usize> {
         self.0.seek(seek_from)
     }

services/libs/jinux-std/src/fs/inode_handle/mod.rs

@@ -3,6 +3,8 @@
 mod dyn_cap;
 mod static_cap;
 
+use core::sync::atomic::{AtomicU32, Ordering};
+
 use crate::fs::file_handle::FileLike;
 use crate::fs::utils::{
     AccessMode, Dentry, DirentVisitor, InodeType, IoEvents, Metadata, Poller, SeekFrom, StatusFlags,
@@ -16,13 +18,13 @@ struct InodeHandle_ {
     dentry: Arc<Dentry>,
     offset: Mutex<usize>,
     access_mode: AccessMode,
-    status_flags: Mutex<StatusFlags>,
+    status_flags: AtomicU32,
 }
 
 impl InodeHandle_ {
     pub fn read(&self, buf: &mut [u8]) -> Result<usize> {
         let mut offset = self.offset.lock();
-        let len = if self.status_flags.lock().contains(StatusFlags::O_DIRECT) {
+        let len = if self.status_flags().contains(StatusFlags::O_DIRECT) {
             self.dentry.vnode().read_direct_at(*offset, buf)?
         } else {
             self.dentry.vnode().read_at(*offset, buf)?
@@ -34,10 +36,10 @@ impl InodeHandle_ {
 
     pub fn write(&self, buf: &[u8]) -> Result<usize> {
         let mut offset = self.offset.lock();
-        if self.status_flags.lock().contains(StatusFlags::O_APPEND) {
+        if self.status_flags().contains(StatusFlags::O_APPEND) {
             *offset = self.dentry.vnode().len();
         }
-        let len = if self.status_flags.lock().contains(StatusFlags::O_DIRECT) {
+        let len = if self.status_flags().contains(StatusFlags::O_DIRECT) {
             self.dentry.vnode().write_direct_at(*offset, buf)?
         } else {
             self.dentry.vnode().write_at(*offset, buf)?
@@ -48,7 +50,7 @@ impl InodeHandle_ {
     }
 
     pub fn read_to_end(&self, buf: &mut Vec<u8>) -> Result<usize> {
-        let len = if self.status_flags.lock().contains(StatusFlags::O_DIRECT) {
+        let len = if self.status_flags().contains(StatusFlags::O_DIRECT) {
             self.dentry.vnode().read_direct_to_end(buf)?
         } else {
             self.dentry.vnode().read_to_end(buf)?
@@ -99,19 +101,13 @@ impl InodeHandle_ {
     }
 
     pub fn status_flags(&self) -> StatusFlags {
-        let status_flags = self.status_flags.lock();
-        *status_flags
+        let bits = self.status_flags.load(Ordering::Relaxed);
+        StatusFlags::from_bits(bits).unwrap()
     }
 
     pub fn set_status_flags(&self, new_status_flags: StatusFlags) {
-        let mut status_flags = self.status_flags.lock();
-        // Can change only the O_APPEND, O_ASYNC, O_NOATIME, and O_NONBLOCK flags
-        let valid_flags_mask = StatusFlags::O_APPEND
-            | StatusFlags::O_ASYNC
-            | StatusFlags::O_NOATIME
-            | StatusFlags::O_NONBLOCK;
-        status_flags.remove(valid_flags_mask);
-        status_flags.insert(new_status_flags & valid_flags_mask);
+        self.status_flags
+            .store(new_status_flags.bits(), Ordering::Relaxed);
     }
 
     pub fn readdir(&self, visitor: &mut dyn DirentVisitor) -> Result<usize> {
@@ -124,30 +120,6 @@ impl InodeHandle_ {
 
 /// Methods for both dyn and static
 impl<R> InodeHandle<R> {
-    pub fn seek(&self, pos: SeekFrom) -> Result<usize> {
-        self.0.seek(pos)
-    }
-
-    pub fn offset(&self) -> usize {
-        self.0.offset()
-    }
-
-    pub fn len(&self) -> usize {
-        self.0.len()
-    }
-
-    pub fn access_mode(&self) -> AccessMode {
-        self.0.access_mode()
-    }
-
-    pub fn status_flags(&self) -> StatusFlags {
-        self.0.status_flags()
-    }
-
-    pub fn set_status_flags(&self, new_status_flags: StatusFlags) {
-        self.0.set_status_flags(new_status_flags)
-    }
-
     pub fn dentry(&self) -> &Arc<Dentry> {
         &self.0.dentry
     }

services/libs/jinux-std/src/fs/pipe.rs

@@ -2,7 +2,7 @@ use crate::events::Observer;
 use crate::prelude::*;
 
 use super::file_handle::FileLike;
-use super::utils::{Consumer, IoEvents, Poller, Producer};
+use super::utils::{AccessMode, Consumer, IoEvents, Poller, Producer, StatusFlags};
 
 pub struct PipeReader {
     consumer: Consumer<u8>,
@@ -43,6 +43,18 @@ impl FileLike for PipeReader {
         self.consumer.poll(mask, poller)
     }
 
+    fn status_flags(&self) -> StatusFlags {
+        self.consumer.status_flags()
+    }
+
+    fn set_status_flags(&self, new_flags: StatusFlags) -> Result<()> {
+        self.consumer.set_status_flags(new_flags)
+    }
+
+    fn access_mode(&self) -> AccessMode {
+        AccessMode::O_RDONLY
+    }
+
     fn register_observer(
         &self,
         observer: Weak<dyn Observer<IoEvents>>,
@@ -98,6 +110,18 @@ impl FileLike for PipeWriter {
         self.producer.poll(mask, poller)
     }
 
+    fn status_flags(&self) -> StatusFlags {
+        self.producer.status_flags()
+    }
+
+    fn set_status_flags(&self, new_flags: StatusFlags) -> Result<()> {
+        self.producer.set_status_flags(new_flags)
+    }
+
+    fn access_mode(&self) -> AccessMode {
+        AccessMode::O_WRONLY
+    }
+
     fn register_observer(
         &self,
         observer: Weak<dyn Observer<IoEvents>>,

services/libs/jinux-std/src/fs/utils/channel.rs

@@ -67,7 +67,7 @@ macro_rules! impl_common_methods_for_channel {
             self.this_end().status_flags()
         }
 
-        pub fn set_status_flags(&self, new_flags: StatusFlags) {
+        pub fn set_status_flags(&self, new_flags: StatusFlags) -> Result<()> {
             self.this_end().set_status_flags(new_flags)
         }
 
@@ -330,8 +330,10 @@ impl<T> EndPointInner<T> {
         StatusFlags::from_bits(bits).unwrap()
     }
 
-    pub fn set_status_flags(&self, new_flags: StatusFlags) {
+    pub fn set_status_flags(&self, new_flags: StatusFlags) -> Result<()> {
+        check_status_flags(new_flags)?;
         self.status_flags.store(new_flags.bits(), Ordering::Relaxed);
+        Ok(())
     }
 }