Changeset 884f3f67 for libcfa/src/concurrency/kernel_private.hfa

Timestamp:

Mar 14, 2022, 2:24:51 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

bfb9bf5

Parents:

c42b8a1

Message:

Change how the ready queue is initialized to make it common with I/O

File:

• libcfa/src/concurrency/kernel_private.hfa (modified) (2 diffs)

libcfa/src/concurrency/kernel_private.hfa

@@ -366 +366 @@
 
 //-----------------------------------------------------------------------
+// Decrease the width of the ready queue (number of lanes) by 4
+void ready_queue_close(struct cluster * cltr);
+
+//-----------------------------------------------------------------------
 // Calc moving average based on existing average, before and current time.
 static inline unsigned long long moving_average(unsigned long long currtsc, unsigned long long instsc, unsigned long long old_avg) {
@@ -380 +384 @@
 }
 
-static const unsigned __readyq_shard_factor = 2;
+//-----------------------------------------------------------------------
+// Calc age a timestamp should be before needing help.
+forall(Data_t * | { unsigned long long ts(Data_t & this); })
+static inline unsigned long long calc_cutoff(
+        const unsigned long long ctsc,
+        const processor * proc,
+        size_t count,
+        Data_t * data,
+        __timestamp_t * tscs,
+        const unsigned shard_factor
+) {
+        unsigned start = proc->rdq.id;
+        unsigned long long max = 0;
+        for(i; shard_factor) {
+                unsigned long long ptsc = ts(data[start + i]);
+                if(ptsc != -1ull) {
+                        /* paranoid */ verify( start + i < count );
+                        unsigned long long tsc = moving_average(ctsc, ptsc, tscs[start + i].ma);
+                        if(tsc > max) max = tsc;
+                }
+        }
+        return (max + 2 * max) / 2;
+}
+
+static struct {
+        const unsigned readyq;
+} __shard_factor = { 2 };
 
 // Local Variables: //