Changes in libcfa/src/concurrency/io.cfa [21a5bfb7:70b4aeb9]

File:

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

libcfa/src/concurrency/io.cfa

@@ -306 +306 @@
                 ctx->proc->io.pending = true;
                 ctx->proc->io.dirty   = true;
-                if(sq.to_submit > 30 || !lazy) {
+                if(sq.to_submit > 30) {
+                        __tls_stats()->io.flush.full++;
+                        __cfa_io_flush( ctx->proc, 0 );
+                }
+                if(!lazy) {
+                        __tls_stats()->io.flush.eager++;
                         __cfa_io_flush( ctx->proc, 0 );
                 }
@@ -552 +557 @@
                         /* paranoid */ verify( proc == __cfaabi_tls.this_processor );
                         /* paranoid */ verify( ! __preemption_enabled() );
+
+                        return true;
                 }
         #endif