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

File:

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

libcfa/src/concurrency/io.cfa

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