Changeset 27f5f71 for libcfa/src/concurrency/preemption.cfa

Timestamp:

Nov 30, 2019, 11:08:34 AM (4 years ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

4cae032

Parents:

524627e

Message:

explicitly create stack for pthread thread, change NULL to 0p

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 : Tue Jun  5 17:35:49 2018
-// Update Count     : 37
+// Last Modified On : Sat Nov 30 08:02:56 2019
+// Update Count     : 39
 //
 
@@ -24 +24 @@
 #include <string.h>
 #include <unistd.h>
+#include <limits.h>                                                                             // PTHREAD_STACK_MIN
 }
 
@@ -81 +82 @@
 // Get next expired node
 static inline alarm_node_t * get_expired( alarm_list_t * alarms, Time currtime ) {
-        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
+        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
 }
 
 // Tick one frame of the Discrete Event Simulation for alarms
 static void tick_preemption() {
-        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"
+        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"
 
         //Loop throught every thing expired
@@ -243 +244 @@
         sigaddset( &mask, sig );
 
-        if ( pthread_sigmask( SIG_UNBLOCK, &mask, NULL ) == -1 ) {
+        if ( pthread_sigmask( SIG_UNBLOCK, &mask, 0p ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -254 +255 @@
         sigaddset( &mask, sig );
 
-        if ( pthread_sigmask( SIG_BLOCK, &mask, NULL ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -301 +302 @@
 
         // 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_create( &alarm_thread, NULL, alarm_loop, NULL );
+        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
 }
 
@@ -316 +340 @@
         sigset_t mask;
         sigfillset( &mask );
-        sigprocmask( SIG_BLOCK, &mask, NULL );
+        sigprocmask( SIG_BLOCK, &mask, 0p );
 
         // Notify the alarm thread of the shutdown
@@ -323 +347 @@
 
         // Wait for the preemption thread to finish
-        pthread_join( alarm_thread, NULL );
+
+        pthread_join( alarm_thread, 0p );
+        free( kernelTLS.preemption_state.stack );
 
         // Preemption is now fully stopped
@@ -380 +406 @@
         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), NULL ) == -1 ) {
+        if ( pthread_sigmask( SIG_SETMASK, (sigset_t *)&(cxt->uc_sigmask), 0p ) == -1 ) {
                 abort( "internal error, sigprocmask" );
         }
@@ -399 +425 @@
         sigset_t mask;
         sigfillset(&mask);
-        if ( pthread_sigmask( SIG_BLOCK, &mask, NULL ) == -1 ) {
+        if ( pthread_sigmask( SIG_BLOCK, &mask, 0p ) == -1 ) {
             abort( "internal error, pthread_sigmask" );
         }
@@ -420 +446 @@
                                         {__cfaabi_dbg_print_buffer_decl( " KERNEL: Spurious wakeup %d.\n", err );}
                                         continue;
-                        case EINVAL :
+                                case EINVAL :
                                         abort( "Timeout was invalid." );
                                 default:
@@ -453 +479 @@
 EXIT:
         __cfaabi_dbg_print_safe( "Kernel : Preemption thread stopping\n" );
-        return NULL;
+        return 0p;
 }
 
@@ -466 +492 @@
         sigset_t oldset;
         int ret;
-        ret = pthread_sigmask(0, NULL, &oldset);
+        ret = pthread_sigmask(0, 0p, &oldset);
         if(ret != 0) { abort("ERROR sigprocmask returned %d", ret); }