Changeset eaf269d for libcfa/src/concurrency

Timestamp:

Jan 6, 2022, 10:53:39 PM (2 years ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum

Children:

6fafda8

Parents:

6111f1f

Message:

add enum DEFAULT_STACK_SIZE in invoke.h and replace 65000 with enum, change pthread_create to use DEFAULT_STACK_SIZE

Location:

libcfa/src/concurrency

Files:

• coroutine.hfa (modified) (2 diffs)
• invoke.h (modified) (2 diffs)
• kernel/startup.cfa (modified) (3 diffs)
• thread.hfa (modified) (2 diffs)

libcfa/src/concurrency/coroutine.hfa

@@ -10 +10 @@
 // Created On       : Mon Nov 28 12:27:26 2016
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Tue Feb  4 12:29:26 2020
-// Update Count     : 11
+// Last Modified On : Thu Jan  6 16:33:16 2022
+// Update Count     : 12
 //
 
@@ -155 +155 @@
 
         if( unlikely(dst->context.SP == 0p) ) {
-                __stack_prepare(&dst->stack, 65000);
+                __stack_prepare(&dst->stack, DEFAULT_STACK_SIZE);
                 __cfactx_start(main, dst, cor, __cfactx_invoke_coroutine);
         }

libcfa/src/concurrency/invoke.h

@@ -10 +10 @@
 // Created On       : Tue Jan 17 12:27:26 2016
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Thu Dec  5 16:26:03 2019
-// Update Count     : 44
+// Last Modified On : Thu Jan  6 16:37:40 2022
+// Update Count     : 47
 //
 
@@ -27 +27 @@
 #ifndef _INVOKE_H_
 #define _INVOKE_H_
+
+        enum { DEFAULT_STACK_SIZE = 65000 };
 
         struct __cfaehm_try_resume_node;

libcfa/src/concurrency/kernel/startup.cfa

@@ -403 +403 @@
 
         __cfaabi_tls.this_thread->curr_cor = dst;
-        __stack_prepare( &dst->stack, 65000 );
+        __stack_prepare( &dst->stack, DEFAULT_STACK_SIZE );
         __cfactx_start(main, dst, this->runner, __cfactx_invoke_coroutine);
 
@@ -721 +721 @@
         check( pthread_attr_init( &attr ), "pthread_attr_init" ); // initialize attribute
 
-        size_t stacksize;
-        // default stack size, normally defined by shell limit
-        check( pthread_attr_getstacksize( &attr, &stacksize ), "pthread_attr_getstacksize" );
-        assert( stacksize >= PTHREAD_STACK_MIN );
+        size_t stacksize = DEFAULT_STACK_SIZE;
 
         void * stack;
@@ -749 +746 @@
         #endif
 
-
         check( pthread_attr_setstack( &attr, stack, stacksize ), "pthread_attr_setstack" );
-
         check( pthread_create( pthread, &attr, start, arg ), "pthread_create" );
         return stack;

libcfa/src/concurrency/thread.hfa

@@ -10 +10 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Wed Dec  4 09:18:14 2019
-// Update Count     : 6
+// Last Modified On : Thu Jan  6 16:40:16 2022
+// Update Count     : 7
 //
 
@@ -65 +65 @@
 void ^?{}(thread$ & this);
 
-static inline void ?{}(thread$ & this)                                                                  { this{ "Anonymous Thread", *mainCluster, 0p, 65000 }; }
+static inline void ?{}(thread$ & this)                                                                  { this{ "Anonymous Thread", *mainCluster, 0p, DEFAULT_STACK_SIZE }; }
 static inline void ?{}(thread$ & this, size_t stackSize )                                               { this{ "Anonymous Thread", *mainCluster, 0p, stackSize }; }
 static inline void ?{}(thread$ & this, void * storage, size_t storageSize )                             { this{ "Anonymous Thread", *mainCluster, storage, storageSize }; }
-static inline void ?{}(thread$ & this, struct cluster & cl )                                            { this{ "Anonymous Thread", cl, 0p, 65000 }; }
+static inline void ?{}(thread$ & this, struct cluster & cl )                                            { this{ "Anonymous Thread", cl, 0p, DEFAULT_STACK_SIZE }; }
 static inline void ?{}(thread$ & this, struct cluster & cl, size_t stackSize )                          { this{ "Anonymous Thread", cl, 0p, stackSize }; }
 static inline void ?{}(thread$ & this, struct cluster & cl, void * storage, size_t storageSize )        { this{ "Anonymous Thread", cl, storage, storageSize }; }
-static inline void ?{}(thread$ & this, const char * const name)                                         { this{ name, *mainCluster, 0p, 65000 }; }
-static inline void ?{}(thread$ & this, const char * const name, struct cluster & cl )                   { this{ name, cl, 0p, 65000 }; }
+static inline void ?{}(thread$ & this, const char * const name)                                         { this{ name, *mainCluster, 0p, DEFAULT_STACK_SIZE }; }
+static inline void ?{}(thread$ & this, const char * const name, struct cluster & cl )                   { this{ name, cl, 0p, DEFAULT_STACK_SIZE }; }
 static inline void ?{}(thread$ & this, const char * const name, struct cluster & cl, size_t stackSize ) { this{ name, cl, 0p, stackSize }; }