Changeset 635 for trunk/kernel/kern/scheduler.c

Timestamp:

Jun 26, 2019, 11:42:37 AM (5 years ago)

Author:

alain

Message:

This version is a major evolution: The physical memory allocators,
defined in the kmem.c, ppm.c, and kcm.c files have been modified
to support remote accesses. The RPCs that were previously user
to allocate physical memory in a remote cluster have been removed.
This has been done to cure a dead-lock in case of concurrent page-faults.

This version 2.2 has been tested on a (4 clusters / 2 cores per cluster)
TSAR architecture, for both the "sort" and the "fft" applications.

File:

• trunk/kernel/kern/scheduler.c (modified) (6 diffs)

trunk/kernel/kern/scheduler.c

@@ -180 +180 @@
     sched = &core->scheduler;
 
-    ////////////////// scan user threads to handle both ACK and DELETE requests
+    ////////////////// scan user threads to handle ACK and DELETE requests
     root = &sched->u_root;
     iter = root->next;
@@ -195 +195 @@
         {
 
-// check thread blocked
+// check target thread blocked
 assert( (thread->blocked & THREAD_BLOCKED_GLOBAL) , "thread not blocked" );
  
@@ -206 +206 @@
 
         // handle REQ_DELETE only if target thread != calling thread
-        if( (thread->flags & THREAD_FLAG_REQ_DELETE) && (thread != CURRENT_THREAD) )
-        {
+        if( thread->flags & THREAD_FLAG_REQ_DELETE )
+        {
+
+// check calling thread != target thread
+assert( (thread != CURRENT_THREAD) , "calling thread cannot delete itself" );
+ 
             // get thread process descriptor
             process = thread->process;
@@ -497 +501 @@
     remote_fifo_t * fifo    = &LOCAL_CLUSTER->rpc_fifo[lid]; 
  
+#if DEBUG_SCHED_YIELD
+uint32_t cycle = (uint32_t)hal_get_cycles();
+#endif
+
 #if (DEBUG_SCHED_YIELD & 0x1)
-if( sched->trace )
+if( sched->trace || (cycle > DEBUG_SCHED_YIELD) )
 sched_display( lid );
 #endif
@@ -551 +559 @@
 
 #if DEBUG_SCHED_YIELD
-if( sched->trace )
+if( sched->trace || (cycle > DEBUG_SCHED_YIELD) )
 printk("\n[%s] core[%x,%d] / cause = %s\n"
 "      thread %x (%s) (%x,%x) => thread %x (%s) (%x,%x) / cycle %d\n",
 __FUNCTION__, local_cxy, lid, cause, 
 current, thread_type_str(current->type), current->process->pid, current->trdid,next ,
-thread_type_str(next->type) , next->process->pid , next->trdid , (uint32_t)hal_get_cycles() );
+thread_type_str(next->type) , next->process->pid , next->trdid , cycle );
 #endif
 
@@ -567 +575 @@
         busylock_release( &sched->lock );
 
-#if (DEBUG_SCHED_YIELD & 1)
-if( sched->trace )
+#if DEBUG_SCHED_YIELD 
+if( sched->trace || (cycle > DEBUG_SCHED_YIELD) )
 printk("\n[%s] core[%x,%d] / cause = %s\n"
 "      thread %x (%s) (%x,%x) continue / cycle %d\n",