Changes in libcfa/src/concurrency/io.cfa [24e321c:45c9441]

File:

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

libcfa/src/concurrency/io.cfa

@@ -183 +183 @@
                 ctx.proc->io.pending = false;
 
-                ready_schedule_lock();
                 __cfa_io_drain( proc );
-                ready_schedule_unlock();
                 // for(i; 2) {
                 //      unsigned idx = proc->rdq.id + i;
@@ -316 +314 @@
                 ctx->proc->io.dirty   = true;
                 if(sq.to_submit > 30 || !lazy) {
+                        ready_schedule_lock();
                         __cfa_io_flush( ctx->proc );
+                        ready_schedule_unlock();
                 }
         }