Changeset 059ad16 for libcfa/src/concurrency/kernel.cfa

Timestamp:

Nov 19, 2021, 3:53:47 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum

Children:

7ef162b2

Parents:

cd4c605

Message:

Flush now supports blocking until at least one I/O op terminates.

File:

• libcfa/src/concurrency/kernel.cfa (modified) (5 diffs)

libcfa/src/concurrency/kernel.cfa

@@ -130 +130 @@
 extern void __cfa_io_start( processor * );
 extern bool __cfa_io_drain( processor * );
-extern void __cfa_io_flush( processor * );
+extern bool __cfa_io_flush( processor *, bool wait );
 extern void __cfa_io_stop ( processor * );
 static inline bool __maybe_io_drain( processor * );
@@ -197 +197 @@
                         if( !readyThread ) {
                                 ready_schedule_lock();
-                                __cfa_io_flush( this );
+                                __cfa_io_flush( this, false );
                                 ready_schedule_unlock();
 
@@ -251 +251 @@
                         if(this->io.pending && !this->io.dirty) {
                                 ready_schedule_lock();
-                                __cfa_io_flush( this );
+                                __cfa_io_flush( this, false );
                                 ready_schedule_unlock();
                         }
@@ -268 +268 @@
 
                                 // If we can't find a thread, might as well flush any outstanding I/O
-                                if(this->io.pending) { __cfa_io_flush( this ); }
+                                if(this->io.pending) { __cfa_io_flush( this, false ); }
 
                                 // Spin a little on I/O, just in case
@@ -363 +363 @@
 
                         if(this->io.pending && !this->io.dirty) {
-                                __cfa_io_flush( this );
+                                __cfa_io_flush( this, false );
                         }