Changeset 92976d9 for libcfa/src/concurrency/kernel.hfa

Timestamp:

Apr 10, 2020, 11:20:31 AM (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:

7df014f

Parents:

72828a8

Message:

Implemented basic io_uring setup and poller

File:

• libcfa/src/concurrency/kernel.hfa (modified) (3 diffs)

libcfa/src/concurrency/kernel.hfa

@@ -17 +17 @@
 
 #include <stdbool.h>
+#include <stdint.h>
 
 #include "invoke.h"
@@ -111 +112 @@
 
 //-----------------------------------------------------------------------------
+// I/O
+#if defined(HAVE_LINUX_IO_URING_H)
+struct io_uring_sq {
+        uint32_t * head;
+        uint32_t * tail;
+        uint32_t * mask;
+        uint32_t * entries;
+        uint32_t * flags;
+        uint32_t * dropped;
+        uint32_t * array;
+        struct io_uring_sqe * sqes;
+
+        uint32_t sqe_head;
+        uint32_t sqe_tail;
+
+        size_t ring_sz;
+        void * ring_ptr;
+};
+
+struct io_uring_cq {
+        volatile uint32_t * head;
+        volatile uint32_t * tail;
+        uint32_t * mask;
+        struct io_uring_cqe * entries;
+        uint32_t * overflow;
+        struct io_uring_cqe * cqes;
+
+        size_t ring_sz;
+        void * ring_ptr;
+};
+
+struct io_ring {
+        struct io_uring_sq submit_q;
+        struct io_uring_cq completion_q;
+        uint32_t flags;
+        int fd;
+        pthread_t poller;
+        void * stack;
+        volatile bool done;
+};
+#endif
+
+//-----------------------------------------------------------------------------
 // Cluster
 struct cluster {
@@ -141 +185 @@
                 cluster * prev;
         } node;
+
+        #if defined(HAVE_LINUX_IO_URING_H)
+                struct io_ring io;
+        #endif
 };
 extern Duration default_preemption();