Changes in libcfa/src/concurrency/kernel.cfa [69914cbc:57f70ab]

File:

• libcfa/src/concurrency/kernel.cfa (modified) (10 diffs)

libcfa/src/concurrency/kernel.cfa

@@ -182 +182 @@
                 MAIN_LOOP:
                 for() {
-                        #if 1
+                        #define OLD_MAIN 1
+                        #if OLD_MAIN
                         // Check if there is pending io
                         __maybe_io_drain( this );
@@ -262 +263 @@
 
                         #else
-
+                                #warning new kernel loop
                         SEARCH: {
                                 /* paranoid */ verify( ! __preemption_enabled() );
-                                /* paranoid */ verify( kernelTLS().this_proc_id );
 
                                 // First, lock the scheduler since we are searching for a thread
@@ -278 +278 @@
 
                                 // Spin a little on I/O, just in case
-                                for(25) {
+                                        for(5) {
                                         __maybe_io_drain( this );
                                         readyThread = pop_fast( this->cltr );
@@ -285 +285 @@
 
                                 // no luck, try stealing a few times
-                                for(25) {
+                                        for(5) {
                                         if( __maybe_io_drain( this ) ) {
                                                 readyThread = pop_fast( this->cltr );
@@ -323 +323 @@
                                 }
 
-                                __STATS( if(this->print_halts) __cfaabi_bits_print_safe( STDOUT_FILENO, "PH:%d - %lld 0\n", this->id, rdtscl()); )
+                                        __STATS( if(this->print_halts) __cfaabi_bits_print_safe( STDOUT_FILENO, "PH:%d - %lld 0\n", this->unique_id, rdtscl()); )
                                 __cfadbg_print_safe(runtime_core, "Kernel : core %p waiting on eventfd %d\n", this, this->idle);
 
@@ -331 +331 @@
                                 // __enable_interrupts_hard();
 
-                                __STATS( if(this->print_halts) __cfaabi_bits_print_safe( STDOUT_FILENO, "PH:%d - %lld 1\n", this->id, rdtscl()); )
+                                        __STATS( if(this->print_halts) __cfaabi_bits_print_safe( STDOUT_FILENO, "PH:%d - %lld 1\n", this->unique_id, rdtscl()); )
 
                                 // We were woken up, remove self from idle
@@ -341 +341 @@
 
                 RUN_THREAD:
-                        /* paranoid */ verify( kernelTLS().this_proc_id );
                         /* paranoid */ verify( ! __preemption_enabled() );
                         /* paranoid */ verify( readyThread );
@@ -353 +352 @@
                         // Are we done?
                         if( __atomic_load_n(&this->do_terminate, __ATOMIC_SEQ_CST) ) break MAIN_LOOP;
-
-                        #if !defined(__CFA_NO_STATISTICS__)
-                                unsigned long long curr = rdtscl();
-                                if(curr > (last_tally + 500000000)) {
-                                        __tally_stats(this->cltr->stats, __cfaabi_tls.this_stats);
-                                        last_tally = curr;
-                                }
-                        #endif
 
                         if(this->io.pending && !this->io.dirty) {
@@ -877 +868 @@
                 unsigned tail = *ctx->cq.tail;
                 if(head == tail) return false;
+                #if OLD_MAIN
                 ready_schedule_lock();
                 ret = __cfa_io_drain( proc );
                 ready_schedule_unlock();
+                #else
+                        ret = __cfa_io_drain( proc );
+        #endif
         #endif
         return ret;
@@ -908 +903 @@
         }
 
-        static void crawl_list( cluster * cltr, dlist(processor) & list, unsigned count ) {
+        static void crawl_list( cluster * cltr, dlist(processor, processor) & list, unsigned count ) {
                 /* paranoid */ verify( cltr->stats );