Changeset d36bac7 for libcfa/src/concurrency

Timestamp:

May 19, 2021, 1:26:33 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

9cac0da

Parents:

78ea291

Message:

Drain on I/O
Added (commented) hack to prevent workstealing when pushing.

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();
+                // }
         }