Changeset 3d84734 in mainline for kernel/generic/src/proc/scheduler.c

Timestamp:

2024-01-20T17:19:52Z (15 months ago)

Author:

Jiří Zárevúcky <zarevucky.jiri@…>

Branches:

master

Children:

41bfc64

Parents:

efed95a3

git-author:

Jiří Zárevúcky <zarevucky.jiri@…> (2024-01-20 17:18:35)

git-committer:

Jiří Zárevúcky <zarevucky.jiri@…> (2024-01-20 17:19:52)

Message:

Make thread→priority weakly atomic to avoid need for locking

File:

• kernel/generic/src/proc/scheduler.c (modified) (5 diffs)

kernel/generic/src/proc/scheduler.c

@@ -314 +314 @@
 
         THREAD->state = Running;
-        THREAD->priority = rq_index;  /* Correct rq index */
+        atomic_set_unordered(&THREAD->priority, rq_index);  /* Correct rq index */
 
         /*
@@ -325 +325 @@
         log(LF_OTHER, LVL_DEBUG,
             "cpu%u: tid %" PRIu64 " (priority=%d, ticks=%" PRIu64
-            ", nrdy=%zu)", CPU->id, THREAD->tid, THREAD->priority,
+            ", nrdy=%zu)", CPU->id, THREAD->tid, rq_index,
             THREAD->ticks, atomic_load(&CPU->nrdy));
 #endif
@@ -389 +389 @@
         assert(atomic_get_unordered(&thread->cpu) == CPU);
 
-        int i = (thread->priority < RQ_COUNT - 1) ?
-            ++thread->priority : thread->priority;
+        int prio = atomic_get_unordered(&thread->priority);
+
+        if (prio < RQ_COUNT - 1) {
+                prio++;
+                atomic_set_unordered(&thread->priority, prio);
+        }
 
         thread->state = Ready;
@@ -396 +400 @@
         irq_spinlock_unlock(&thread->lock, false);
 
-        add_to_rq(thread, CPU, i);
+        add_to_rq(thread, CPU, prio);
 }
 
@@ -407 +411 @@
         assert(thread->state == Sleeping || thread->state == Entering);
 
-        thread->priority = 0;
+        atomic_set_unordered(&thread->priority, 0);
         thread->state = Ready;