Changes in src/libcfa/concurrency/preemption.c [90c4df0:ed235b6]

File:

• src/libcfa/concurrency/preemption.c (modified) (3 diffs)

src/libcfa/concurrency/preemption.c

@@ -71 +71 @@
 static pthread_t alarm_thread;                        // pthread handle to alarm thread
 
-void ?{}(event_kernel_t * this) {
-        (&this->alarms){};
-        (&this->lock){};
+void ?{}(event_kernel_t & this) {
+        (this.alarms){};
+        (this.lock){};
 }
 
@@ -240 +240 @@
         // Initialize the event kernel
         event_kernel = (event_kernel_t *)&storage_event_kernel;
-        event_kernel{};
+        (*event_kernel){};
 
         // Setup proper signal handlers
-        __kernel_sigaction( SIGUSR1, sigHandler_ctxSwitch, SA_SIGINFO );         // CtxSwitch handler
+        __kernel_sigaction( SIGUSR1, sigHandler_ctxSwitch, SA_SIGINFO | SA_RESTART );         // CtxSwitch handler
         // __kernel_sigaction( SIGSEGV, sigHandler_segv     , SA_SIGINFO );      // Failure handler
         // __kernel_sigaction( SIGBUS , sigHandler_segv     , SA_SIGINFO );      // Failure handler
@@ -276 +276 @@
 // Raii ctor/dtor for the preemption_scope
 // Used by thread to control when they want to receive preemption signals
-void ?{}( preemption_scope * this, processor * proc ) {
-        (&this->alarm){ proc, zero_time, zero_time };
-        this->proc = proc;
-        this->proc->preemption_alarm = &this->alarm;
-
-        update_preemption( this->proc, from_us(this->proc->cltr->preemption) );
-}
-
-void ^?{}( preemption_scope * this ) {
+void ?{}( preemption_scope & this, processor * proc ) {
+        (this.alarm){ proc, zero_time, zero_time };
+        this.proc = proc;
+        this.proc->preemption_alarm = &this.alarm;
+
+        update_preemption( this.proc, from_us(this.proc->cltr->preemption) );
+}
+
+void ^?{}( preemption_scope & this ) {
         disable_interrupts();
 
-        update_preemption( this->proc, zero_time );
+        update_preemption( this.proc, zero_time );
 }