Changeset 40a606d2

Timestamp:

Mar 3, 2022, 2:30:50 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, enum, master, pthread-emulation, qualifiedEnum

Children:

d9d8b9f

Parents:

bf8b77e

Message:

Modified io headers so io/types.hfa can stay private

Location:

libcfa/src/concurrency

Files:

• io/types.hfa (modified) (2 diffs)
• iofwd.hfa (modified) (3 diffs)

libcfa/src/concurrency/io/types.hfa

@@ -23 +23 @@
 #include "bits/locks.hfa"
 #include "bits/queue.hfa"
+#include "iofwd.hfa"
 #include "kernel/fwd.hfa"
 
@@ -170 +171 @@
         // void __ioctx_prepare_block($io_context & ctx);
 #endif
-
-//-----------------------------------------------------------------------
-// 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); }
-}

libcfa/src/concurrency/iofwd.hfa

@@ -25 +25 @@
 }
 #include "bits/defs.hfa"
+#include "kernel/fwd.hfa"
 #include "time.hfa"
 
@@ -48 +49 @@
 
 struct cluster;
-struct io_future_t;
 struct $io_context;
 
@@ -58 +58 @@
 
 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); }
+}
 
 //----------