Changeset 78a580d for libcfa/src/concurrency/io.cfa

Timestamp:

Mar 22, 2022, 3:28:29 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

ff7b2de

Parents:

8f01ad71

Message:

I/O now updates the timestamps when draining.
Timestamps are not used yet.

File:

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

libcfa/src/concurrency/io.cfa

@@ -42 +42 @@
         #include "kernel/fwd.hfa"
         #include "kernel/private.hfa"
+        #include "kernel/cluster.hfa"
         #include "io/types.hfa"
 
@@ -93 +94 @@
         extern void __kernel_unpark( thread$ * thrd, unpark_hint );
 
-        bool __cfa_io_drain( $io_context * ctx ) {
+        bool __cfa_io_drain( $io_context * ctx, cluster * cltr ) {
                 /* paranoid */ verify( ! __preemption_enabled() );
                 /* paranoid */ verify( ready_schedule_islocked() );
@@ -112 +113 @@
                 }
 
+                unsigned long long ts_prev = ctx->cq.ts;
+
                 for(i; count) {
                         unsigned idx = (head + i) & mask;
@@ -125 +128 @@
 
                 __cfadbg_print_safe(io, "Kernel I/O : %u completed\n", count);
+                unsigned long long ts_next = ctx->cq.ts = rdtscl();
 
                 // Mark to the kernel that the cqe has been seen
@@ -134 +138 @@
 
                 __atomic_unlock(&ctx->cq.lock);
+
+                touch_tsc( cltr->sched.io.tscs, ctx->cq.id, ts_prev, ts_next );
 
                 return true;
@@ -143 +149 @@
                 /* paranoid */ verify( proc->io.ctx );
 
-                __attribute__((unused)) cluster * cltr = proc->cltr;
+                cluster * cltr = proc->cltr;
                 $io_context & ctx = *proc->io.ctx;
 
@@ -183 +189 @@
 
                 ready_schedule_lock();
-                bool ret = __cfa_io_drain( &ctx );
+                bool ret = __cfa_io_drain( &ctx, cltr );
                 ready_schedule_unlock();
                 return ret;