Changes in libcfa/src/concurrency/io.cfa [e9c0b4c:d36bac7]

File:

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

libcfa/src/concurrency/io.cfa

@@ -138 +138 @@
                 /* paranoid */ verify( proc->io.ctx );
 
+                __attribute__((unused)) cluster * cltr = proc->cltr;
                 $io_context & ctx = *proc->io.ctx;
+
+                // for(i; 2) {
+                //      unsigned idx = proc->rdq.id + i;
+                //      cltr->ready_queue.lanes.tscs[idx].tv = -1ull;
+                // }
 
                 __ioarbiter_flush( ctx );
@@ -151 +157 @@
                                 // Update statistics
                                 __STATS__( false, io.calls.errors.busy ++; )
+                                // for(i; 2) {
+                                //      unsigned idx = proc->rdq.id + i;
+                                //      cltr->ready_queue.lanes.tscs[idx].tv = rdtscl();
+                                // }
                                 return;
                         default:
@@ -172 +182 @@
 
                 ctx.proc->io.pending = false;
+
+                ready_schedule_lock();
+                __cfa_io_drain( proc );
+                ready_schedule_unlock();
+                // for(i; 2) {
+                //      unsigned idx = proc->rdq.id + i;
+                //      cltr->ready_queue.lanes.tscs[idx].tv = rdtscl();
+                // }
         }