autocommit 2022-03-11 19:24:53 CET

src/utils/mod.rs

@@ -21,3 +21,4 @@ pub mod tri;
 pub mod vasprintf;
 pub mod vec_ext;
 pub mod vecstorage;
+pub mod nonblock;

src/utils/nonblock.rs

@@ -0,0 +1,8 @@
+use uapi::{c};
+use crate::utils::oserror::OsError;
+
+pub fn set_nonblock(fd: c::c_int) -> Result<(), OsError> {
+    let fl = uapi::fcntl_getfl(fd)?;
+    uapi::fcntl_setfl(fd, fl | c::SOCK_NONBLOCK)?;
+    Ok(())
+}

src/utils/syncqueue.rs

@@ -24,4 +24,8 @@ impl<T> SyncQueue<T> {
     pub fn pop(&self) -> Option<T> {
         unsafe { self.el.get().deref_mut().pop_front() }
     }
+
+    pub fn is_empty(&self) -> bool {
+        unsafe { self.el.get().deref_mut().is_empty() }
+    }
 }