Changeset 28372f7

Timestamp:

Oct 28, 2022, 2:57:20 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master

Children:

2856982c

Parents:

22a0e87

Message:

Changed to park/unpark permit/ticketing to make sure no one unparks a dead thread

Location:

libcfa/src/concurrency

Files:

• kernel.cfa (modified) (1 diff)
• kernel/private.hfa (modified) (1 diff)

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
 
 //-----------------------------------------------------------------------------