Changes in libcfa/src/concurrency/invoke.h [ae7be7a:d72c074]

File:

• libcfa/src/concurrency/invoke.h (modified) (9 diffs)

libcfa/src/concurrency/invoke.h

@@ -48 +48 @@
                 extern __attribute__((aligned(128))) thread_local struct KernelThreadData {
                         struct $thread    * volatile this_thread;
-                        struct processor      * volatile this_processor;
+                        struct processor  * volatile this_processor;
+                        struct __stats_t  * volatile this_stats;
 
                         struct {
@@ -56 +57 @@
                         } preemption_state;
 
-                        uint32_t rand_seed;
+                        __uint128_t rand_seed;
                 } kernelTLS __attribute__ ((tls_model ( "initial-exec" )));
         }
@@ -92 +93 @@
         };
 
-        enum coroutine_state { Halted, Start, Primed, Blocked, Ready, Active, Rerun };
+        enum __Coroutine_State { Halted, Start, Primed, Blocked, Ready, Active };
         enum __Preemption_Reason { __NO_PREEMPTION, __ALARM_PREEMPTION, __POLL_PREEMPTION, __MANUAL_PREEMPTION };
 
@@ -106 +107 @@
 
                 // current execution status for coroutine
-                enum coroutine_state state;
+                enum __Coroutine_State state;
 
                 // first coroutine to resume this one
@@ -161 +162 @@
         };
 
+        // Link lists fields
+        // instrusive link field for threads
+        struct __thread_desc_link {
+                struct $thread * next;
+                struct $thread * prev;
+                volatile unsigned long long ts;
+                int preferred;
+        };
+
         struct $thread {
                 // Core threading fields
@@ -167 +177 @@
 
                 // current execution status for coroutine
-                volatile int state;
-                enum __Preemption_Reason preempted;
+                volatile int ticket;
+                enum __Coroutine_State state:8;
+                enum __Preemption_Reason preempted:8;
 
                 //SKULLDUGGERY errno is not save in the thread data structure because returnToKernel appears to be the only function to require saving and restoring it
+
+                // pointer to the cluster on which the thread is running
+                struct cluster * curr_cluster;
+
+                // Link lists fields
+                // instrusive link field for threads
+                struct __thread_desc_link link;
 
                 // coroutine body used to store context
@@ -184 +202 @@
                 struct $monitor *  self_mon_p;
 
-                // pointer to the cluster on which the thread is running
-                struct cluster * curr_cluster;
-
                 // monitors currently held by this thread
                 struct __monitor_group_t monitors;
-
-                // Link lists fields
-                // instrusive link field for threads
-                struct $thread * next;
 
                 struct {
@@ -202 +213 @@
                         // previous function to park/unpark the thread
                         const char * park_caller;
-                        enum coroutine_state park_result;
+                        int park_result;
+                        enum __Coroutine_State park_state;
                         bool park_stale;
                         const char * unpark_caller;
-                        enum coroutine_state unpark_result;
+                        int unpark_result;
+                        enum __Coroutine_State unpark_state;
                         bool unpark_stale;
                 #endif
@@ -218 +231 @@
         #ifdef __cforall
         extern "Cforall" {
+
                 static inline $thread *& get_next( $thread & this ) __attribute__((const)) {
-                        return this.next;
+                        return this.link.next;
                 }