Changeset a33f0a6 in mainline for kernel/generic/src/proc/thread.c

Timestamp:

2011-08-03T17:34:57Z (13 years ago)

Author:

Oleg Romanenko <romanenko.oleg@…>

Branches:

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

Children:

1940326

Parents:

52a79081 (diff), 3fab770 (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 from mainline

File:

• kernel/generic/src/proc/thread.c (modified) (13 diffs)

kernel/generic/src/proc/thread.c

@@ -55 +55 @@
 #include <time/clock.h>
 #include <time/timeout.h>
+#include <time/delay.h>
 #include <config.h>
 #include <arch/interrupt.h>
@@ -67 +68 @@
 #include <syscall/copy.h>
 #include <errno.h>
-
-
-#ifndef LOADED_PROG_STACK_PAGES_NO
-#define LOADED_PROG_STACK_PAGES_NO 1
-#endif
-
 
 /** Thread states */
@@ -265 +260 @@
          */
         
-        list_append(&thread->rq_link, &cpu->rq[i].rq_head);
+        list_append(&thread->rq_link, &cpu->rq[i].rq);
         cpu->rq[i].n++;
         irq_spinlock_unlock(&(cpu->rq[i].lock), true);
@@ -300 +295 @@
         
         /* Not needed, but good for debugging */
-        memsetb(thread->kstack, THREAD_STACK_SIZE * 1 << STACK_FRAMES, 0);
+        memsetb(thread->kstack, STACK_SIZE, 0);
         
         irq_spinlock_lock(&tidlock, true);
@@ -308 +303 @@
         context_save(&thread->saved_context);
         context_set(&thread->saved_context, FADDR(cushion),
-            (uintptr_t) thread->kstack, THREAD_STACK_SIZE);
+            (uintptr_t) thread->kstack, STACK_SIZE);
         
         the_initialize((the_t *) thread->kstack);
@@ -327 +322 @@
         thread->cpu = NULL;
         thread->flags = flags;
+        thread->nomigrate = 0;
         thread->state = Entering;
         
@@ -427 +423 @@
                 atomic_inc(&task->lifecount);
         
-        list_append(&thread->th_link, &task->th_head);
+        list_append(&thread->th_link, &task->threads);
         
         irq_spinlock_pass(&task->lock, &threads_lock);
@@ -489 +485 @@
 }
 
+/** Prevent the current thread from being migrated to another processor. */
+void thread_migration_disable(void)
+{
+        ASSERT(THREAD);
+
+        THREAD->nomigrate++;
+}
+
+/** Allow the current thread to be migrated to another processor. */
+void thread_migration_enable(void)
+{
+        ASSERT(THREAD);
+        ASSERT(THREAD->nomigrate > 0);
+
+        THREAD->nomigrate--;
+}
+
 /** Thread sleep
  *
@@ -605 +618 @@
                 printf("%-8" PRIu64 " %-14s %10p %-8s %10p %-5" PRIu32 "\n",
                     thread->tid, name, thread, thread_states[thread->state],
-                    thread->task, thread->task->context);
+                    thread->task, thread->task->container);
 #endif
         
@@ -617 +630 @@
                 printf("%-8" PRIu64 " %-14s %18p %-8s %18p %-5" PRIu32 "\n",
                     thread->tid, name, thread, thread_states[thread->state],
-                    thread->task, thread->task->context);
+                    thread->task, thread->task->container);
 #endif
         
@@ -658 +671 @@
         else
                 printf("[id    ] [name        ] [address ] [state ] [task    ]"
-                    " [ctx]\n");
+                    " [ctn]\n");
 #endif
         
@@ -667 +680 @@
         } else
                 printf("[id    ] [name        ] [address         ] [state ]"
-                    " [task            ] [ctx]\n");
+                    " [task            ] [ctn]\n");
 #endif
         
@@ -918 +931 @@
 }
 
+sysarg_t sys_thread_udelay(uint32_t usec)
+{
+        delay(usec);
+        return 0;
+}
+
 /** @}
  */