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

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;
@@ -314 +316 @@
                 ctx->proc->io.dirty   = true;
                 if(sq.to_submit > 30 || !lazy) {
-                        ready_schedule_lock();
                         __cfa_io_flush( ctx->proc );
-                        ready_schedule_unlock();
                 }
         }