Changeset 7b28e4a for src/libcfa/concurrency/kernel.c

Timestamp:

Jun 8, 2018, 1:40:52 PM (7 years ago)

Author:

Peter A. Buhr <pabuhr@…>

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, with_gc

Children:

332d3c2, 9c32e21

Parents:

90cedbdd (diff), beefc34c (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 branch 'master' of plg2:software/cfa/cfa-cc

File:

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

src/libcfa/concurrency/kernel.c

@@ -147 +147 @@
         runner.proc = &this;
 
-        sem_init(&idleLock, 0, 0);
+        idleLock{};
 
         start( &this );
@@ -155 +155 @@
         if( ! __atomic_load_n(&do_terminate, __ATOMIC_ACQUIRE) ) {
                 __cfaabi_dbg_print_safe("Kernel : core %p signaling termination\n", &this);
-                terminate(&this);
-                verify( __atomic_load_n(&do_terminate, __ATOMIC_SEQ_CST) );
-                verify( kernelTLS.this_processor != &this);
+
+                __atomic_store_n(&do_terminate, true, __ATOMIC_RELAXED);
+                wake( &this );
+
                 P( terminated );
                 verify( kernelTLS.this_processor != &this);
-                pthread_join( kernel_thread, NULL );
-        }
-
-        sem_destroy(&idleLock);
+        }
+
+        pthread_join( kernel_thread, NULL );
 }
 
@@ -295 +295 @@
 }
 
-// Handles spinning logic
-// TODO : find some strategy to put cores to sleep after some time
-void spin(processor * this, unsigned int * spin_count) {
-        // (*spin_count)++;
-        halt(this);
-}
-
 // KERNEL_ONLY
 // Context invoker for processors
@@ -408 +401 @@
                 unlock( ready_queue_lock );
 
-                if( was_empty ) {
+                if(was_empty) {
                         lock      (proc_list_lock __cfaabi_dbg_ctx2);
                         if(idles) {
-                                wake(idles.head);
+                                wake_fast(idles.head);
                         }
                         unlock    (proc_list_lock);
                 }
+                else if( struct processor * idle = idles.head ) {
+                        wake_fast(idle);
+                }
+
         }
 
@@ -660 +657 @@
 
 void halt(processor * this) with( *this ) {
-        verify( ! __atomic_load_n(&do_terminate, __ATOMIC_SEQ_CST) );
+        // verify( ! __atomic_load_n(&do_terminate, __ATOMIC_SEQ_CST) );
 
         with( *cltr ) {
@@ -671 +668 @@
         __cfaabi_dbg_print_safe("Kernel : Processor %p ready to sleep\n", this);
 
-        // #ifdef __CFA_WITH_VERIFY__
-        //      int sval = 0;
-        //      sem_getvalue(&this->idleLock, &sval);
-        //      verifyf(sval < 200, "Binary semaphore reached value %d : \n", sval);
-        // #endif
-
-        verify( ! __atomic_load_n(&do_terminate, __ATOMIC_SEQ_CST) );
-        int __attribute__((unused)) ret = sem_wait(&idleLock);
-        // verifyf(ret >= 0 || errno == EINTR, "Sem_wait returned %d (errno %d : %s\n", ret, errno, strerror(errno));
-
-        // wait( idleLock );
+        wait( idleLock );
 
         __cfaabi_dbg_print_safe("Kernel : Processor %p woke up and ready to run\n", this);
@@ -691 +678 @@
                 unlock    (proc_list_lock);
         }
-}
-
-void wake(processor * this) {
-        __cfaabi_dbg_print_safe("Kernel : Waking up processor %p\n", this);
-        int __attribute__((unused)) ret = sem_post(&this->idleLock);
-        // verifyf(ret >= 0 || errno == EINTR, "Sem_post returned %d (errno %d : %s\n", ret, errno, strerror(errno));
-
-        // #ifdef __CFA_WITH_VERIFY__
-        //      int sval = 0;
-        //      sem_getvalue(&this->idleLock, &sval);
-        //      verifyf(sval < 200, "Binary semaphore reached value %d\n", sval);
-        // #endif
-
-        // post( this->idleLock );
 }