Changes in libcfa/src/concurrency/io.cfa [a3821fa:11054eb]

File:

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

libcfa/src/concurrency/io.cfa

@@ -90 +90 @@
         static inline __u32 __release_sqes( struct $io_context & );
 
-        bool __cfa_io_drain( processor * proc ) {
+        void __cfa_io_drain( processor * proc ) {
                 /* paranoid */ verify( ! __preemption_enabled() );
                 /* paranoid */ verify( proc );
@@ -104 +104 @@
                 __STATS__( false, io.calls.drain++; io.calls.completed += count; )
 
-                if(count == 0) return false;
-
                 for(i; count) {
                         unsigned idx = (head + i) & mask;
@@ -126 +124 @@
                 /* paranoid */ verify( ! __preemption_enabled() );
 
-                return true;
+                return;
         }
 
@@ -244 +242 @@
                         // Allocation was successful
                         __STATS__( true, io.alloc.fast += 1; )
-                        enable_interrupts();
+                        enable_interrupts( __cfaabi_dbg_ctx );
 
                         __cfadbg_print_safe(io, "Kernel I/O : fast allocation successful from ring %d\n", ctx->fd);
@@ -256 +254 @@
                 // Fast path failed, fallback on arbitration
                 __STATS__( true, io.alloc.slow += 1; )
-                enable_interrupts();
+                enable_interrupts( __cfaabi_dbg_ctx );
 
                 $io_arbiter * ioarb = proc->cltr->io.arbiter;
@@ -314 +312 @@
                         // Mark the instance as no longer in-use, re-enable interrupts and return
                         __STATS__( true, io.submit.fast += 1; )
-                        enable_interrupts();
+                        enable_interrupts( __cfaabi_dbg_ctx );
 
                         __cfadbg_print_safe(io, "Kernel I/O : submitted on fast path\n");
@@ -322 +320 @@
                 // Fast path failed, fallback on arbitration
                 __STATS__( true, io.submit.slow += 1; )
-                enable_interrupts();
+                enable_interrupts( __cfaabi_dbg_ctx );
 
                 __cfadbg_print_safe(io, "Kernel I/O : falling back on arbiter for submission\n");