Changeset 8f49a54 for src/libcfa/concurrency/kernel.c

Timestamp:

Jan 19, 2017, 3:42:29 PM (8 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

dcb42b8

Parents:

4a3386b4

Message:

Clean-up thread, kernel and examples

File:

• src/libcfa/concurrency/kernel.c (modified) (5 diffs)

src/libcfa/concurrency/kernel.c

@@ -119 +119 @@
         // context switch to specified coroutine
         // Which is now the current_coroutine
-        LIB_DEBUG_PRINTF("Kernel : switching to ctx %p (from %p, current %p)\n", thrd_ctx, proc_ctx, current_coroutine);
+        // LIB_DEBUG_PRINTF("Kernel : switching to ctx %p (from %p, current %p)\n", thrd_ctx, proc_ctx, current_coroutine);
         current_coroutine = thrd_ctx;
         CtxSwitch( proc_ctx->stack.context, thrd_ctx->stack.context );
         current_coroutine = proc_ctx;
-        LIB_DEBUG_PRINTF("Kernel : returned from ctx %p (to %p, current %p)\n", thrd_ctx, proc_ctx, current_coroutine);
+        // LIB_DEBUG_PRINTF("Kernel : returned from ctx %p (to %p, current %p)\n", thrd_ctx, proc_ctx, current_coroutine);
 
         // when CtxSwitch returns we are back in the processor coroutine
@@ -136 +136 @@
 
 void scheduler_add( thread_h * thrd ) {
-        LIB_DEBUG_PRINTF("Kernel : scheduling %p on core %p (%d spots)\n", thrd, systemProcessor, systemProcessor->thread_count);
         for(int i = 0; i < systemProcessor->thread_count; i++) {
                 if(systemProcessor->threads[i] == NULL) {
@@ -143 +142 @@
                 }
         }
-        assert(false);
+        assertf(false, "Scheduler full");
 }
 
 void scheduler_remove( thread_h * thrd ) {
-        LIB_DEBUG_PRINTF("Kernel : unscheduling %p from core %p\n", thrd, systemProcessor);
         for(int i = 0; i < systemProcessor->thread_count; i++) {
                 if(systemProcessor->threads[i] == thrd) {
                         systemProcessor->threads[i] = NULL;
-                        break;
-                }
-        }
-        for(int i = 0; i < systemProcessor->thread_count; i++) {
-                if(systemProcessor->threads[i] != NULL) {
                         return;
                 }
         }
-        LIB_DEBUG_PRINTF("Kernel : terminating core %p\n", systemProcessor);    
-        systemProcessor->terminated = true;
+        assertf(false, "Trying to unschedule unkown thread");
 }
 
@@ -229 +221 @@
 
         mainThread_info_t ctx;
-        LIB_DEBUG_PRINTF("Kernel :    base : %p\n", ctx.base );
-        LIB_DEBUG_PRINTF("Kernel :     top : %p\n", ctx.top );
-        LIB_DEBUG_PRINTF("Kernel :   limit : %p\n", ctx.limit );
-        LIB_DEBUG_PRINTF("Kernel :    size : %x\n", ctx.size );
-        LIB_DEBUG_PRINTF("Kernel : storage : %p\n", ctx.storage );
-        LIB_DEBUG_PRINTF("Kernel : context : %p\n", ctx.context );
+        // LIB_DEBUG_PRINTF("Kernel :    base : %p\n", ctx.base );
+        // LIB_DEBUG_PRINTF("Kernel :     top : %p\n", ctx.top );
+        // LIB_DEBUG_PRINTF("Kernel :   limit : %p\n", ctx.limit );
+        // LIB_DEBUG_PRINTF("Kernel :    size : %x\n", ctx.size );
+        // LIB_DEBUG_PRINTF("Kernel : storage : %p\n", ctx.storage );
+        // LIB_DEBUG_PRINTF("Kernel : context : %p\n", ctx.context );
 
         // Start by initializing the main thread
@@ -265 +257 @@
         scheduler_remove(mainThread);
 
-        LIB_DEBUG_PRINTF("Suspending main\n");
+        LIB_DEBUG_PRINTF("Kernel : Terminating system processor\n");            
+        systemProcessor->terminated = true;
+
         suspend();
 
-        LIB_DEBUG_PRINTF("Kernel : Control return to initial process thread\n");
+        LIB_DEBUG_PRINTF("Kernel : Control returned to initial process thread\n");
 
         ^(systemProcessor->ctx){};