Changeset 4479890 for libcfa/src/concurrency/kernel.cfa

Timestamp:

Mar 22, 2022, 4:59:53 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, enum, master, pthread-emulation, qualifiedEnum

Children:

1a567d0

Parents:

0521a1a

Message:

Implemented helping for io drain based on timestamps.

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -136 +136 @@
 static void mark_awake(__cluster_proc_list & idles, processor & proc);
 
-extern bool __cfa_io_drain( $io_context *, cluster * cltr );
+extern bool __cfa_io_drain( processor * proc ) __attribute__((nonnull (1)));
 extern bool __cfa_io_flush( processor *, int min_comp );
 static inline bool __maybe_io_drain( processor * );
@@ -829 +829 @@
 
 static inline bool __maybe_io_drain( processor * proc ) {
+        /* paranoid */ verify( proc );
         bool ret = false;
         #if defined(CFA_HAVE_LINUX_IO_URING_H)
@@ -839 +840 @@
                 if(head == tail) return false;
                 ready_schedule_lock();
-                ret = __cfa_io_drain( ctx, proc->cltr );
+                ret = __cfa_io_drain( proc );
                 ready_schedule_unlock();
         #endif