Changes in libcfa/src/concurrency/kernel_private.hfa [13fdf86:bfb9bf5]

File:

• libcfa/src/concurrency/kernel_private.hfa (modified) (1 diff)

libcfa/src/concurrency/kernel_private.hfa

@@ -365 +365 @@
 void ready_queue_shrink(struct cluster * cltr);
 
+//-----------------------------------------------------------------------
+// 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) {
+        /* paranoid */ verifyf( currtsc < 45000000000000000, "Suspiciously large current time: %'llu (%llx)\n", currtsc, currtsc );
+        /* paranoid */ verifyf( instsc  < 45000000000000000, "Suspiciously large insert time: %'llu (%llx)\n", instsc, instsc );
+        /* paranoid */ verifyf( old_avg < 15000000000000, "Suspiciously large previous average: %'llu (%llx)\n", old_avg, old_avg );
+
+        const unsigned long long new_val = currtsc > instsc ? currtsc - instsc : 0;
+        const unsigned long long total_weight = 16;
+        const unsigned long long new_weight   = 4;
+        const unsigned long long old_weight = total_weight - new_weight;
+        const unsigned long long ret = ((new_weight * new_val) + (old_weight * old_avg)) / total_weight;
+        return ret;
+}
+
+//-----------------------------------------------------------------------
+// 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 __attribute__((unused)) = { 2 };
 
 // Local Variables: //