Changes in libcfa/src/concurrency/kernel.cfa [c33c2af:24e321c]

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -196 +196 @@
 
                         if( !readyThread ) {
-                                ready_schedule_lock();
                                 __cfa_io_flush( this );
-                                ready_schedule_unlock();
-
                                 readyThread = __next_thread_slow( this->cltr );
                         }
@@ -280 +277 @@
 
                         if(this->io.pending && !this->io.dirty) {
-                                ready_schedule_lock();
                                 __cfa_io_flush( this );
-                                ready_schedule_unlock();
                         }
 
@@ -322 +317 @@
 
                                 // Don't block if we are done
-                                if( __atomic_load_n(&this->do_terminate, __ATOMIC_SEQ_CST) ) {
-                                        ready_schedule_unlock();
-                                        break MAIN_LOOP;
-                                }
+                                if( __atomic_load_n(&this->do_terminate, __ATOMIC_SEQ_CST) ) break MAIN_LOOP;
 
                                 __STATS( __tls_stats()->ready.sleep.halts++; )
@@ -947 +939 @@
                         /* paranoid */ verifyf( it, "Unexpected null iterator, at index %u of %u\n", i, count);
                         /* paranoid */ verify( it->local_data->this_stats );
-                        // __print_stats( it->local_data->this_stats, cltr->print_stats, "Processor", it->name, (void*)it );
                         __tally_stats( cltr->stats, it->local_data->this_stats );
                         it = &(*it)`next;
@@ -957 +948 @@
                 // this doesn't solve all problems but does solve many
                 // so it's probably good enough
-                disable_interrupts();
                 uint_fast32_t last_size = ready_mutate_lock();
 
@@ -965 +955 @@
                 // Unlock the RWlock
                 ready_mutate_unlock( last_size );
-                enable_interrupts();
         }