Changes in libcfa/src/concurrency/kernel.cfa [1c40091:27f5f71]

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -10 +10 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Thu Nov 21 16:46:59 2019
-// Update Count     : 27
+// Last Modified On : Fri Nov 29 17:59:16 2019
+// Update Count     : 35
 //
 
@@ -26 +26 @@
 #include <signal.h>
 #include <unistd.h>
+#include <limits.h>                                                                             // PTHREAD_STACK_MIN
 }
 
@@ -133 +134 @@
         NULL,
         NULL,
-        { 1, false, false }
+        { NULL, 1, false, false },
+        6u //this should be seeded better but due to a bug calling rdtsc doesn't work
 };
 
@@ -232 +234 @@
 
         pthread_join( kernel_thread, NULL );
+        free( this.stack );
 }
 
@@ -260 +263 @@
 //Main of the processor contexts
 void main(processorCtx_t & runner) {
+        // Because of a bug, we couldn't initialized the seed on construction
+        // Do it here
+        kernelTLS.rand_seed ^= rdtscl();
+
         processor * this = runner.proc;
         verify(this);
@@ -440 +447 @@
         __cfaabi_dbg_print_safe("Kernel : Starting core %p\n", this);
 
-        pthread_create( &this->kernel_thread, NULL, CtxInvokeProcessor, (void*)this );
+        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 );
+
+        this->stack = malloc( stacksize );
+        ret = pthread_attr_setstack( &attr, this->stack, stacksize ); 
+        if ( ret ) {
+                abort( "%s : internal error, pthread_attr_setstack failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
+        } // if
+
+        ret = pthread_create( &this->kernel_thread, &attr, CtxInvokeProcessor, (void *)this );
+        if ( ret ) {
+                abort( "%s : internal error, pthread_create failed, error(%d) %s.", __PRETTY_FUNCTION__, ret, strerror( ret ) );
+        } // if
+//      pthread_create( &this->kernel_thread, NULL, CtxInvokeProcessor, (void*)this );
 
         __cfaabi_dbg_print_safe("Kernel : core %p started\n", this);