Changeset 78a580d for libcfa/src/concurrency/kernel/cluster.hfa

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/kernel/cluster.hfa (modified) (2 diffs)

libcfa/src/concurrency/kernel/cluster.hfa

@@ -16 +16 @@
 #pragma once
 
+#include "device/cpu.hfa"
 #include "kernel/private.hfa"
+
+#include "limits.hfa"
 
 //-----------------------------------------------------------------------
@@ -31 +34 @@
         const unsigned long long ret = ((new_weight * new_val) + (old_weight * old_avg)) / total_weight;
         return ret;
+}
+
+static inline void touch_tsc(__timestamp_t * tscs, size_t idx, unsigned long long ts_prev, unsigned long long ts_next) {
+        if (ts_next == MAX) return;
+        unsigned long long now = rdtscl();
+        unsigned long long pma = __atomic_load_n(&tscs[ idx ].ma, __ATOMIC_RELAXED);
+        __atomic_store_n(&tscs[ idx ].tv, ts_next, __ATOMIC_RELAXED);
+        __atomic_store_n(&tscs[ idx ].ma, moving_average(now, ts_prev, pma), __ATOMIC_RELAXED);
 }