Changes in libcfa/src/concurrency/preemption.cfa [5a05946:926d358]

File:

• libcfa/src/concurrency/preemption.cfa (modified) (11 diffs)

libcfa/src/concurrency/preemption.cfa

@@ -10 +10 @@
 // Created On       : Mon Jun 5 14:20:42 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Mon Jan  9 08:42:59 2023
-// Update Count     : 60
+// Last Modified On : Thu Feb 17 11:18:57 2022
+// Update Count     : 59
 //
 
 #define __cforall_thread__
+#define _GNU_SOURCE
 
 // #define __CFA_DEBUG_PRINT_PREEMPTION__
@@ -117 +118 @@
                 __cfadbg_print_buffer_decl( preemption, " KERNEL: preemption tick %lu\n", currtime.tn);
                 Duration period = node->period;
-                if( period == 0 ) {
+                if( period == 0) {
                         node->set = false;                  // Node is one-shot, just mark it as not pending
                 }
@@ -351 +352 @@
         sigset_t oldset;
         int ret;
-        ret = __cfaabi_pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
+        ret = pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
         if(ret != 0) { abort("ERROR sigprocmask returned %d", ret); }
 
@@ -384 +385 @@
         sigaddset( &mask, sig );
 
-        if ( __cfaabi_pthread_sigmask( SIG_UNBLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_UNBLOCK, &mask, 0p ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -395 +396 @@
         sigaddset( &mask, sig );
 
-        if ( __cfaabi_pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
                 abort( "internal error, pthread_sigmask" );
         }
@@ -403 +404 @@
 static void preempt( processor * this ) {
         sigval_t value = { PREEMPT_NORMAL };
-        __cfaabi_pthread_sigqueue( this->kernel_thread, SIGUSR1, value );
+        pthread_sigqueue( this->kernel_thread, SIGUSR1, value );
 }
 
@@ -414 +415 @@
         sigset_t oldset;
         int ret;
-        ret = __cfaabi_pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
+        ret = pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
         if(ret != 0) { abort("ERROR sigprocmask returned %d", ret); }
 
@@ -433 +434 @@
         sigset_t oldset;
         int ret;
-        ret = __cfaabi_pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
+        ret = pthread_sigmask(0, ( const sigset_t * ) 0p, &oldset);  // workaround trac#208: cast should be unnecessary
         if(ret != 0) { abort("ERROR sigprocmask returned %d", ret); }
 
@@ -504 +505 @@
         sigval val;
         val.sival_int = 0;
-        __cfaabi_pthread_sigqueue( alarm_thread, SIGALRM, val );
+        pthread_sigqueue( alarm_thread, SIGALRM, val );
 
         // Wait for the preemption thread to finish
@@ -578 +579 @@
         static_assert( sizeof( sigset_t ) == sizeof( cxt->uc_sigmask ), "Expected cxt->uc_sigmask to be of sigset_t" );
         #endif
-        if ( __cfaabi_pthread_sigmask( SIG_SETMASK, (sigset_t *)&(cxt->uc_sigmask), 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_SETMASK, (sigset_t *)&(cxt->uc_sigmask), 0p ) == -1 ) {
                 abort( "internal error, sigprocmask" );
         }
@@ -606 +607 @@
         sigset_t mask;
         sigfillset(&mask);
-        if ( __cfaabi_pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }