Changes in libcfa/src/concurrency/iofwd.hfa [40a606d2:ff1240f]

File:

• libcfa/src/concurrency/iofwd.hfa (modified) (5 diffs)

libcfa/src/concurrency/iofwd.hfa

@@ -19 +19 @@
 extern "C" {
         #include <asm/types.h>
-        #include <sys/stat.h> // needed for mode_t
         #if CFA_HAVE_LINUX_IO_URING_H
                 #include <linux/io_uring.h>
@@ -25 +24 @@
 }
 #include "bits/defs.hfa"
-#include "kernel/fwd.hfa"
 #include "time.hfa"
 
@@ -49 +47 @@
 
 struct cluster;
+struct io_future_t;
 struct $io_context;
 
@@ -58 +57 @@
 
 struct io_uring_sqe;
-
-//-----------------------------------------------------------------------
-// IO user data
-struct io_future_t {
-        future_t self;
-        __s32 result;
-};
-
-static inline {
-        thread$ * fulfil( io_future_t & this, __s32 result, bool do_unpark = true ) {
-                this.result = result;
-                return fulfil(this.self, do_unpark);
-        }
-
-        // Wait for the future to be fulfilled
-        bool wait     ( io_future_t & this ) { return wait     (this.self); }
-        void reset    ( io_future_t & this ) { return reset    (this.self); }
-        bool available( io_future_t & this ) { return available(this.self); }
-}
 
 //----------
@@ -153 +133 @@
 // Check if a function is blocks a only the user thread
 bool has_user_level_blocking( fptr_t func );
-
-#if CFA_HAVE_LINUX_IO_URING_H
-        static inline void zero_sqe(struct io_uring_sqe * sqe) {
-                sqe->flags = 0;
-                sqe->ioprio = 0;
-                sqe->fd = 0;
-                sqe->off = 0;
-                sqe->addr = 0;
-                sqe->len = 0;
-                sqe->fsync_flags = 0;
-                sqe->__pad2[0] = 0;
-                sqe->__pad2[1] = 0;
-                sqe->__pad2[2] = 0;
-                sqe->fd = 0;
-                sqe->off = 0;
-                sqe->addr = 0;
-                sqe->len = 0;
-        }
-#endif