Changes in src/libcfa/concurrency/kernel.c [ea8b2f7:85b1deb]

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 );
 }