Changeset 9cac0da for libcfa/src

Timestamp:

May 19, 2021, 1:34:11 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

b808625

Parents:

d36bac7

Message:

Small fixes to how timestamp is handled in workstealing queue.

File:

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

libcfa/src/concurrency/ready_queue.cfa

@@ -409 +409 @@
                         unsigned target = proc->rdq.target;
                         proc->rdq.target = -1u;
-                        if(lanes.tscs[target].tv < proc->rdq.cutoff) {
+                        const unsigned long long bias = 0; //2_500_000_000;
+                        const unsigned long long cutoff = proc->rdq.cutoff > bias ? proc->rdq.cutoff - bias : proc->rdq.cutoff;
+                        if(lanes.tscs[target].tv < cutoff && ts(lanes.data[target]) < cutoff) {
                                 $thread * t = try_pop(cltr, target __STATS(, __tls_stats()->ready.pop.help));
                                 if(t) return t;
@@ -571 +573 @@
                 lanes.tscs = alloc(lanes.count, lanes.tscs`realloc);
                 for(i; lanes.count) {
-                        lanes.tscs[i].tv = ts(lanes.data[i]);
+                        unsigned long long tsc = ts(lanes.data[i]);
+                        lanes.tscs[i].tv = tsc != 0 ? tsc : rdtscl();
                 }
         #endif