Changes in / [dfd3410:8f2f185]

File:

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

libcfa/src/concurrency/io.cfa

@@ -635 +635 @@
 
                         // We can proceed to the fast path
-                        if( !__alloc(ctx, &idx, 1) ) {
-                                /* paranoid */ verify( false ); // for now check if this happens, next time just abort the sleep.
-                                return false;
-                        }
+                        if( !__alloc(ctx, &idx, 1) ) return false;
 
                         // Allocation was successful
@@ -668 +665 @@
 
                         /* paranoid */ verify( sqe->user_data == (uintptr_t)&future );
-                        __submit_only( ctx, &idx, 1 );
+                        __submit( ctx, &idx, 1, true );
 
                         /* paranoid */ verify( proc == __cfaabi_tls.this_processor );
@@ -693 +690 @@
                         }
 
-                        if( !__atomic_load_n( &proc->do_terminate, __ATOMIC_SEQ_CST ) ) {
-                                __ioarbiter_flush( *proc->io.ctx );
-                                ioring_syscsll( *proc->io.ctx, 1, IORING_ENTER_GETEVENTS);
-                        }
+                        __ioarbiter_flush( *proc->io.ctx );
+                        ioring_syscsll( *proc->io.ctx, 1, IORING_ENTER_GETEVENTS);
 
                         ready_schedule_lock();