Changes in libcfa/src/concurrency/kernel.cfa [8e16177:c66f6cb]

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -256 +256 @@
 }
 
-void ?{}(cluster & this, const char name[], Duration preemption_rate, int io_flags) with( this ) {
+void ?{}(cluster & this, const char name[], Duration preemption_rate) with( this ) {
         this.name = name;
         this.preemption_rate = preemption_rate;
@@ -270 +270 @@
         threads{ __get };
 
-        __kernel_io_startup( this, io_flags, &this == mainCluster );
+        __kernel_io_startup( this, &this == mainCluster );
 
         doregister(this);
@@ -901 +901 @@
         // Wake them up
         __cfadbg_print_safe(runtime_core, "Kernel : waking Processor %p\n", this->idles.head);
-        /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
         post( this->idles.head->idle );
 
@@ -912 +911 @@
 static bool __wake_proc(processor * this) {
         __cfadbg_print_safe(runtime_core, "Kernel : waking Processor %p\n", this);
-
-        disable_interrupts();
-                /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
-                bool ret = post( this->idle );
-        enable_interrupts( __cfaabi_dbg_ctx );
-
-        return ret;
+        return post( this->idle );
 }
 
@@ -1000 +993 @@
 void ^?{}(semaphore & this) {}
 
-bool P(semaphore & this) with( this ){
+void P(semaphore & this) with( this ){
         lock( lock __cfaabi_dbg_ctx2 );
         count -= 1;
@@ -1010 +1003 @@
                 unlock( lock );
                 park( __cfaabi_dbg_ctx );
-                return true;
         }
         else {
             unlock( lock );
-            return false;
         }
 }