Changeset 4e74466

Timestamp:

May 5, 2020, 12:12:47 PM (5 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

71c8b7e

Parents:

b6f2b213

Message:

Fast poller thread now polls a few times before baton-passing to the slow thread.
Currently doing 5 tries, the number is arbitrary and requires more work.

File:

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

libcfa/src/concurrency/io.cfa

@@ -522 +522 @@
                 __cfadbg_print_safe(io_core, "Kernel I/O : Fast poller for ring %p ready\n", &this.ring);
 
+                int reset = 0;
+
                 // Then loop until we need to start
                 while(!__atomic_load_n(&this.ring->done, __ATOMIC_SEQ_CST)) {
@@ -527 +529 @@
                         this.waiting = false;
                         int count = __drain_io( *this.ring, 0p, 0, false );
+                        reset += count > 0 ? 1 : 0;
 
                         // Update statistics
@@ -535 +538 @@
 
                         this.waiting = true;
-                        if(0 > count) {
+                        if(reset < 5) {
                                 // If we got something, just yield and check again
                                 yield();
@@ -544 +547 @@
                                 post( this.ring->poller.sem );
                                 park( __cfaabi_dbg_ctx );
+                                reset = 0;
                         }
                 }