Changes in libcfa/src/concurrency/preemption.cfa [27f5f71:2026bb6]

File:

• libcfa/src/concurrency/preemption.cfa (modified) (13 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 : Sat Nov 30 08:02:56 2019
-// Update Count     : 39
+// Last Modified On : Tue Jun  5 17:35:49 2018
+// Update Count     : 37
 //
 
@@ -24 +24 @@
 #include <string.h>
 #include <unistd.h>
-#include <limits.h>                                                                             // PTHREAD_STACK_MIN
 }
 
@@ -82 +81 @@
 // Get next expired node
 static inline alarm_node_t * get_expired( alarm_list_t * alarms, Time currtime ) {
-        if( !alarms->head ) return 0p;                                          // If no alarms return null
-        if( alarms->head->alarm >= currtime ) return 0p;        // If alarms head not expired return null
-        return pop(alarms);                                                                     // Otherwise just pop head
+        if( !alarms->head ) return NULL;                          // If no alarms return null
+        if( alarms->head->alarm >= currtime ) return NULL;        // If alarms head not expired return null
+        return pop(alarms);                                       // Otherwise just pop head
 }
 
 // Tick one frame of the Discrete Event Simulation for alarms
 static void tick_preemption() {
-        alarm_node_t * node = 0p;                                                       // Used in the while loop but cannot be declared in the while condition
-        alarm_list_t * alarms = &event_kernel->alarms;          // Local copy for ease of reading
-        Time currtime = __kernel_get_time();                            // Check current time once so everything "happens at once"
+        alarm_node_t * node = NULL;                     // Used in the while loop but cannot be declared in the while condition
+        alarm_list_t * alarms = &event_kernel->alarms;  // Local copy for ease of reading
+        Time currtime = __kernel_get_time();                    // Check current time once so we everything "happens at once"
 
         //Loop throught every thing expired
@@ -244 +243 @@
         sigaddset( &mask, sig );
 
-        if ( pthread_sigmask( SIG_UNBLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_UNBLOCK, &mask, NULL ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -255 +254 @@
         sigaddset( &mask, sig );
 
-        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, NULL ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -302 +301 @@
 
         // Setup proper signal handlers
-        __cfaabi_sigaction( SIGUSR1, sigHandler_ctxSwitch, SA_SIGINFO | SA_RESTART ); // CtxSwitch handler
+        __cfaabi_sigaction( SIGUSR1, sigHandler_ctxSwitch, SA_SIGINFO | SA_RESTART );         // CtxSwitch handler
 
         signal_block( SIGALRM );
 
-        pthread_attr_t attr;
-        int ret;
-        ret = pthread_attr_init( &attr );                                       // initialize attribute
-        if ( ret ) {
-                abort( "%s : internal error, pthread_attr_init failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
-        } // if
-
-        size_t stacksize;
-        ret = pthread_attr_getstacksize( &attr, &stacksize ); // default stack size, normally defined by shell limit
-        if ( ret ) {
-                abort( "%s : internal error, pthread_attr_getstacksize failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
-        } // if
-        assert( stacksize >= PTHREAD_STACK_MIN );
-
-        kernelTLS.preemption_state.stack = malloc( stacksize );
-        ret = pthread_attr_setstack( &attr, kernelTLS.preemption_state.stack, stacksize ); 
-        if ( ret ) {
-                abort( "%s : internal error, pthread_attr_setstack failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
-        } // if
-
-        ret = pthread_create( &alarm_thread, &attr, alarm_loop, 0p );
-        if ( ret ) {
-                abort( "%s : internal error, pthread_create failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
-        } // if
+        pthread_create( &alarm_thread, NULL, alarm_loop, NULL );
 }
 
@@ -340 +316 @@
         sigset_t mask;
         sigfillset( &mask );
-        sigprocmask( SIG_BLOCK, &mask, 0p );
+        sigprocmask( SIG_BLOCK, &mask, NULL );
 
         // Notify the alarm thread of the shutdown
@@ -347 +323 @@
 
         // Wait for the preemption thread to finish
-
-        pthread_join( alarm_thread, 0p );
-        free( kernelTLS.preemption_state.stack );
+        pthread_join( alarm_thread, NULL );
 
         // Preemption is now fully stopped
@@ -406 +380 @@
         static_assert( sizeof( sigset_t ) == sizeof( cxt->uc_sigmask ), "Expected cxt->uc_sigmask to be of sigset_t" );
         #endif
-        if ( pthread_sigmask( SIG_SETMASK, (sigset_t *)&(cxt->uc_sigmask), 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_SETMASK, (sigset_t *)&(cxt->uc_sigmask), NULL ) == -1 ) {
                 abort( "internal error, sigprocmask" );
         }
@@ -425 +399 @@
         sigset_t mask;
         sigfillset(&mask);
-        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, NULL ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -446 +420 @@
                                         {__cfaabi_dbg_print_buffer_decl( " KERNEL: Spurious wakeup %d.\n", err );}
                                         continue;
-                                case EINVAL :
+                        case EINVAL :
                                         abort( "Timeout was invalid." );
                                 default:
@@ -479 +453 @@
 EXIT:
         __cfaabi_dbg_print_safe( "Kernel : Preemption thread stopping\n" );
-        return 0p;
+        return NULL;
 }
 
@@ -492 +466 @@
         sigset_t oldset;
         int ret;
-        ret = pthread_sigmask(0, 0p, &oldset);
+        ret = pthread_sigmask(0, NULL, &oldset);
         if(ret != 0) { abort("ERROR sigprocmask returned %d", ret); }