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

Timestamp:

2010-05-21T07:50:04Z (16 years ago)

Author:

Lenka Trochtova <trochtova.lenka@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

d51ee2b

Parents:

cf8cc36 (diff), 15b592b (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

merge mainline changes (rev. 451)

File:

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

kernel/generic/src/proc/scheduler.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2001-2007 Jakub Jermar
+ * Copyright (c) 2010 Jakub Jermar
  * All rights reserved.
  *
@@ -187 +187 @@
 
 loop:
-        interrupts_enable();
         
         if (atomic_get(&CPU->nrdy) == 0) {
@@ -196 +195 @@
                  */
 
-                /*
+                 /* Mark CPU as it was idle this clock tick */
+                 spinlock_lock(&CPU->lock);
+                 CPU->idle = true;
+                 spinlock_unlock(&CPU->lock);
+
+                 interrupts_enable();
+                 /*
                  * An interrupt might occur right now and wake up a thread.
                  * In such case, the CPU will continue to go to sleep
                  * even though there is a runnable thread.
                  */
-
                  cpu_sleep();
+                 interrupts_disable();
                  goto loop;
         }
-
-        interrupts_disable();
         
         for (i = 0; i < RQ_COUNT; i++) {
@@ -313 +316 @@
                 spinlock_lock(&THREAD->lock);
                 
-                /* Update thread accounting */
-                THREAD->cycles += get_cycle() - THREAD->last_cycle;
+                /* Update thread kernel accounting */
+                THREAD->kcycles += get_cycle() - THREAD->last_cycle;
                 
 #ifndef CONFIG_FPU_LAZY
@@ -379 +382 @@
         int priority;
         DEADLOCK_PROBE_INIT(p_joinwq);
+        task_t *old_task = TASK;
+        as_t *old_as = AS;
 
         ASSERT(CPU != NULL);
         
+        /*
+         * Hold the current task and the address space to prevent their
+         * possible destruction should thread_destroy() be called on this or any
+         * other processor while the scheduler is still using them.
+         */
+        if (old_task)
+                task_hold(old_task);
+        if (old_as)
+                as_hold(old_as);
+
         if (THREAD) {
                 /* must be run after the switch to scheduler stack */
@@ -473 +488 @@
          */
         if (TASK != THREAD->task) {
-                as_t *as1 = NULL;
-                as_t *as2;
-
-                if (TASK) {
-                        spinlock_lock(&TASK->lock);
-                        as1 = TASK->as;
-                        spinlock_unlock(&TASK->lock);
-                }
-
-                spinlock_lock(&THREAD->task->lock);
-                as2 = THREAD->task->as;
-                spinlock_unlock(&THREAD->task->lock);
+                as_t *new_as = THREAD->task->as;
                 
                 /*
@@ -490 +494 @@
                  * space.
                  */
-                if (as1 != as2) {
+                if (old_as != new_as) {
                         /*
                          * Both tasks and address spaces are different.
                          * Replace the old one with the new one.
                          */
-                        as_switch(as1, as2);
+                        as_switch(old_as, new_as);
                 }
+
                 TASK = THREAD->task;
                 before_task_runs();
         }
 
+        if (old_task)
+                task_release(old_task);
+        if (old_as)
+                as_release(old_as);
+        
         spinlock_lock(&THREAD->lock);   
         THREAD->state = Running;
@@ -542 +552 @@
 {
         thread_t *t;
-        int count, average, j, k = 0;
+        int count;
+        atomic_count_t average;
         unsigned int i;
+        int j;
+        int k = 0;
         ipl_t ipl;