Changeset dd4e2d7 for libcfa/src/concurrency/io.cfa

Timestamp:

May 8, 2020, 2:42:15 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

6c12fd2

Parents:

0335620

Message:

Added option to change the length of the array of ready sqe

File:

• libcfa/src/concurrency/io.cfa (modified) (5 diffs)

libcfa/src/concurrency/io.cfa

@@ -20 +20 @@
 
 #if !defined(HAVE_LINUX_IO_URING_H)
-        void __kernel_io_startup( cluster &, int, bool ) {
+        void __kernel_io_startup( cluster &, unsigned, bool ) {
                 // Nothing to do without io_uring
         }
@@ -205 +205 @@
 // I/O Startup / Shutdown logic
 //=============================================================================================
-        void __kernel_io_startup( cluster & this, int io_flags, bool main_cluster ) {
+        void __kernel_io_startup( cluster & this, unsigned io_flags, bool main_cluster ) {
                 this.io = malloc();
 
@@ -280 +280 @@
 
                 if( io_flags & CFA_CLUSTER_IO_POLLER_THREAD_SUBMITS ) {
-                        sq.ready_cnt = 32;
+                        sq.ready_cnt = max(io_flags >> CFA_CLUSTER_IO_BUFFLEN_OFFSET, 8);
                         sq.ready = alloc_align( 64, sq.ready_cnt );
                         for(i; sq.ready_cnt) {
@@ -753 +753 @@
                                 __atomic_fetch_add( &ring.submit_q.stats.look_avg.cnt,   1,     __ATOMIC_RELAXED );
                         #endif
+
+                        __cfadbg_print_safe( io, "Kernel I/O : Added %u to ready for %p\n", idx, active_thread() );
                 }
                 else {
@@ -781 +783 @@
 
                         unlock(ring.submit_q.lock);
-                }
-                // Make sure that idx was submitted
-                // Be careful to not get false positive if we cycled the entire list or that someone else submitted for us
-                __cfadbg_print_safe( io, "Kernel I/O : Performed io_submit for %p, returned %d\n", active_thread(), ret );
+
+                        __cfadbg_print_safe( io, "Kernel I/O : Performed io_submit for %p, returned %d\n", active_thread(), ret );
+                }
         }