Changes in / [13edbac:fa2e183]

Location:

libcfa/src

Files:

• bits/defs.hfa (modified) (1 diff)
• concurrency/invoke.h (modified) (3 diffs)
• concurrency/kernel.cfa (modified) (1 diff)
• concurrency/kernel/private.hfa (modified) (1 diff)

libcfa/src/bits/defs.hfa

@@ -30 +30 @@
 #ifdef __cforall
 #define __cfa_anonymous_object(x) inline struct x
-#define __cfa_dlink1(x) dlink(x)
+#define __cfa_dlink(x) inline dlink(x)
 #else
 #define __cfa_anonymous_object(x) struct x __cfa_anonymous_object
-#define __cfa_dlink1(x) struct { struct x * next; struct x * back; }
+#define __cfa_dlink(x) struct { struct x * next; struct x * back; } __dlink_substitute
 #endif
 

libcfa/src/concurrency/invoke.h

@@ -196 +196 @@
 
                 // used to put threads on dlist data structure
-                __cfa_dlink1(thread$) user_link;
+                __cfa_dlink(thread$);
 
                 struct {
@@ -218 +218 @@
                 #endif
         };
-
+        #ifdef __cforall
+                P9_EMBEDDED( thread$, dlink(thread$) )
+        #endif
         // Wrapper for gdb
         struct cfathread_thread_t { struct thread$ debug; };
@@ -239 +241 @@
                 }
 
-                static inline tytagref( dlink(thread$), dlink(thread$) ) ?`inner( thread$ & this ) {
-                        dlink(thread$) & b = this.user_link;
-                        tytagref( dlink(thread$), dlink(thread$) ) result = { b };
-                        return result;
-                }
-
                 static inline void ?{}(__monitor_group_t & this) {
                         (this.data){0p};

libcfa/src/concurrency/kernel.cfa

@@ -602 +602 @@
                 /* paranoid */ verifyf( ((uintptr_t)thrd->context.SP) < ((uintptr_t)__get_stack(thrd->curr_cor)->base ), "ERROR : thread$ %p has been corrupted.\n StackPointer too small.\n", thrd );
 
+                thrd->state = Halting;
                 if( TICKET_RUNNING != thrd->ticket ) { abort( "Thread terminated with pending unpark" ); }
                 if( thrd != this->owner ) { abort( "Thread internal monitor has incorrect owner" ); }
                 if( this->recursion != 1) { abort( "Thread internal monitor has unbalanced recursion" ); }
-
-                thrd->state = Halting;
-                thrd->ticket = TICKET_DEAD;
 
                 // Leave the thread

libcfa/src/concurrency/kernel/private.hfa

@@ -166 +166 @@
 #define TICKET_RUNNING ( 0) // thread is running
 #define TICKET_UNBLOCK ( 1) // thread should ignore next block
-#define TICKET_DEAD    (0xDEAD) // thread should never be unparked
 
 //-----------------------------------------------------------------------------