Changeset 3e2b9c9 for libcfa/src/concurrency/iocall.cfa

Timestamp:

Aug 3, 2020, 1:59:13 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

95789be

Parents:

e660761

Message:

More restructuring of translation units
Unclear if it improves compilation time.

File:

• libcfa/src/concurrency/iocall.cfa (modified) (3 diffs)

libcfa/src/concurrency/iocall.cfa

@@ -14 +14 @@
 //
 
+#define __cforall_thread__
+
 #include "bits/defs.hfa"
 
@@ -21 +23 @@
 
 #if defined(CFA_HAVE_LINUX_IO_URING_H)
+        #include <assert.h>
         #include <stdint.h>
         #include <errno.h>
         #include <linux/io_uring.h>
 
-        #include "kernel_private.hfa"
+        #include "kernel.hfa"
+        #include "kernel/fwd.hfa"
+        #include "io/types.hfa"
 
         extern [* struct io_uring_sqe, uint32_t] __submit_alloc( struct __io_data & ring, uint64_t data );
@@ -53 +58 @@
         }
 
+        static inline io_context * __get_io_context( void ) {
+                cluster * cltr = active_cluster();
+                /* paranoid */ verifyf( cltr, "No active cluster for io operation\n");
+                assertf( cltr->io.cnt > 0, "Cluster %p has no default io contexts and no context was specified\n", cltr );
+                /* paranoid */ verifyf( cltr->io.ctxs, "default io contexts for cluster %p are missing\n", cltr);
+                return &cltr->io.ctxs[ __tls_rand() % cltr->io.cnt ];
+        }