Changeset 54cc2bf for libcfa/src/concurrency/io

Timestamp:

Jan 14, 2021, 7:42:53 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

f756a7f

Parents:

7836dad (diff), 7222630 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

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

libcfa/src/concurrency/io/setup.cfa

@@ -314 +314 @@
         }
 
+        extern void __disable_interrupts_hard();
+        extern void __enable_interrupts_hard();
+
         static void __io_create( __io_data & this, const io_context_params & params_in ) {
                 // Step 1 : call to setup
@@ -429 +432 @@
 
                 // Step 4 : eventfd
-                int efd;
-                for() {
-                        efd = eventfd(0, 0);
-                        if (efd < 0) {
-                                if (errno == EINTR) continue;
-                                abort("KERNEL ERROR: IO_URING EVENTFD - %s\n", strerror(errno));
-                        }
-                        break;
-                }
-
-                int ret;
-                for() {
-                        ret = syscall( __NR_io_uring_register, fd, IORING_REGISTER_EVENTFD, &efd, 1);
-                        if (ret < 0) {
-                                if (errno == EINTR) continue;
-                                abort("KERNEL ERROR: IO_URING EVENTFD REGISTER - %s\n", strerror(errno));
-                        }
-                        break;
-                }
+                // io_uring_register is so f*cking slow on some machine that it
+                // will never succeed if preemption isn't hard blocked
+                __disable_interrupts_hard();
+
+                int efd = eventfd(0, 0);
+                if (efd < 0) {
+                        abort("KERNEL ERROR: IO_URING EVENTFD - %s\n", strerror(errno));
+                }
+
+                int ret = syscall( __NR_io_uring_register, fd, IORING_REGISTER_EVENTFD, &efd, 1);
+                if (ret < 0) {
+                        abort("KERNEL ERROR: IO_URING EVENTFD REGISTER - %s\n", strerror(errno));
+                }
+
+                __enable_interrupts_hard();
 
                 // some paranoid checks