Changeset 708ae38 for libcfa/src/concurrency/ready_queue.cfa

Timestamp:

Mar 15, 2022, 5:11:50 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

9d8124f

Parents:

a552a8c

Message:

Some more cleanup and grow/shrink now readjusts io timestamps.
(They are still unused).

File:

• libcfa/src/concurrency/ready_queue.cfa (modified) (2 diffs)

libcfa/src/concurrency/ready_queue.cfa

@@ -24 +24 @@
 #include "bits/defs.hfa"
 #include "device/cpu.hfa"
-#include "kernel_private.hfa"
+#include "kernel/cluster.hfa"
+#include "kernel/private.hfa"
 
 #include "limits.hfa"
@@ -122 +123 @@
         __cfadbg_print_safe(ready_queue, "Kernel : pop from %u\n", this);
 
-        // Figure out the current cpu and make sure it is valid
-        const int cpu = __kernel_getcpu();
-        /* paranoid */ verify(cpu >= 0);
-        /* paranoid */ verify(cpu < cpu_info.hthrd_count);
-        unsigned this_cache = cpu_info.llc_map[cpu].cache;
-
-        // Super important: don't write the same value over and over again
-        // We want to maximise our chances that his particular values stays in cache
-        if(caches[this / __shard_factor.readyq].id != this_cache)
-                __atomic_store_n(&caches[this / __shard_factor.readyq].id, this_cache, __ATOMIC_RELAXED);
-
+        // Figure out the current cache is
+        const unsigned this_cache = cache_id(cltr, this / __shard_factor.readyq);
         const unsigned long long ctsc = rdtscl();