Changeset 1c273d0 for src/libcfa/concurrency/monitor.c

Timestamp:

Jun 23, 2017, 10:12:04 AM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

d43cd01

Parents:

aa3d77b

Message:

preemption works for threads

File:

• src/libcfa/concurrency/monitor.c (modified) (13 diffs)

src/libcfa/concurrency/monitor.c

@@ -44 +44 @@
 
 extern "C" {
-        void __enter_monitor_desc(monitor_desc * this) {
-                lock( &this->lock );
-                thread_desc * thrd = this_thread();
-
-                LIB_DEBUG_PRINT_SAFE("%p Entering %p (o: %p, r: %i)\n", thrd, this, this->owner, this->recursion);
+        void __enter_monitor_desc( monitor_desc * this ) {
+                lock( &this->lock, __PRETTY_FUNCTION__ );
+                thread_desc * thrd = this_thread;
+
+                // LIB_DEBUG_PRINT_SAFE("%p Entering %p (o: %p, r: %i)\n", thrd, this, this->owner, this->recursion);
 
                 if( !this->owner ) {
@@ -62 +62 @@
                         //Some one else has the monitor, wait in line for it
                         append( &this->entry_queue, thrd );
-                        LIB_DEBUG_PRINT_SAFE("%p Blocking on entry\n", thrd);
+                        // LIB_DEBUG_PRINT_SAFE("%p Blocking on entry\n", thrd);
                         BlockInternal( &this->lock );
 
@@ -75 +75 @@
         // leave pseudo code :
         //      TODO
-        void __leave_monitor_desc(monitor_desc * this) {
-                lock( &this->lock );
-
-                LIB_DEBUG_PRINT_SAFE("%p Leaving %p (o: %p, r: %i)\n", thrd, this, this->owner, this->recursion);
-                verifyf( this_thread() == this->owner, "Expected owner to be %p, got %p (r: %i)", this_thread(), this->owner, this->recursion );
+        void __leave_monitor_desc( monitor_desc * this ) {
+                lock( &this->lock, __PRETTY_FUNCTION__ );
+
+                // LIB_DEBUG_PRINT_SAFE("%p Leaving %p (o: %p, r: %i). ", this_thread, this, this->owner, this->recursion);
+                verifyf( this_thread == this->owner, "Expected owner to be %p, got %p (r: %i)", this_thread, this->owner, this->recursion );
 
                 //Leaving a recursion level, decrement the counter
@@ -96 +96 @@
                 unlock( &this->lock );
 
-                LIB_DEBUG_PRINT_SAFE("Next owner is %p\n", new_owner);
+                // LIB_DEBUG_PRINT_SAFE("Next owner is %p\n", new_owner);
 
                 //We need to wake-up the thread
-                ScheduleThread( new_owner );
+                WakeThread( new_owner );
+        }
+
+        void __leave_thread_monitor( thread_desc * thrd ) {
+                monitor_desc * this = &thrd->mon;
+                lock( &this->lock, __PRETTY_FUNCTION__ );
+
+                disable_interrupts();
+
+                thrd->cor.state = Halted;
+
+                verifyf( thrd == this->owner, "Expected owner to be %p, got %p (r: %i)", thrd, this->owner, this->recursion );
+
+                //Leaving a recursion level, decrement the counter
+                this->recursion -= 1;
+
+                //If we haven't left the last level of recursion
+                //it means we don't need to do anything
+                if( this->recursion != 0) {
+                        unlock( &this->lock );
+                        return;
+                }
+
+                thread_desc * new_owner = next_thread( this );
+
+                //We can now let other threads in safely
+                unlock( &this->lock );
+
+                //We need to wake-up the thread
+                if( new_owner) ScheduleThread( new_owner );
         }
 }
@@ -121 +150 @@
         enter( this->m, this->count );
 
-        this->prev_mntrs = this_thread()->current_monitors;
-        this->prev_count = this_thread()->current_monitor_count;
-
-        this_thread()->current_monitors      = m;
-        this_thread()->current_monitor_count = count;
+        this->prev_mntrs = this_thread->current_monitors;
+        this->prev_count = this_thread->current_monitor_count;
+
+        this_thread->current_monitors      = m;
+        this_thread->current_monitor_count = count;
 }
 
@@ -131 +160 @@
         leave( this->m, this->count );
 
-        this_thread()->current_monitors      = this->prev_mntrs;
-        this_thread()->current_monitor_count = this->prev_count;
+        this_thread->current_monitors      = this->prev_mntrs;
+        this_thread->current_monitor_count = this->prev_count;
 }
 
@@ -174 +203 @@
         LIB_DEBUG_PRINT_SAFE("count %i\n", count);
 
-        __condition_node_t waiter = { this_thread(), count, user_info };
+        __condition_node_t waiter = { (thread_desc*)this_thread, count, user_info };
 
         __condition_criterion_t criteria[count];
@@ -234 +263 @@
         //Some more checking in debug
         LIB_DEBUG_DO(
-                thread_desc * this_thrd = this_thread();
+                thread_desc * this_thrd = this_thread;
                 if ( this->monitor_count != this_thrd->current_monitor_count ) {
                         abortf( "Signal on condition %p made with different number of monitor(s), expected %i got %i", this, this->monitor_count, this_thrd->current_monitor_count );
@@ -286 +315 @@
 
         //create creteria
-        __condition_node_t waiter = { this_thread(), count, 0 };
+        __condition_node_t waiter = { (thread_desc*)this_thread, count, 0 };
 
         __condition_criterion_t criteria[count];
@@ -335 +364 @@
 // Internal scheduling
 void __accept_internal( unsigned short count, __acceptable_t * acceptables, void (*func)(void) ) {
-        // thread_desc * this = this_thread();
+        // thread_desc * this = this_thread;
 
         // unsigned short count = this->current_monitor_count;
@@ -393 +422 @@
 static inline void lock_all( spinlock ** locks, unsigned short count ) {
         for( int i = 0; i < count; i++ ) {
-                lock( locks[i] );
+                lock( locks[i], __PRETTY_FUNCTION__ );
         }
 }
@@ -400 +429 @@
         for( int i = 0; i < count; i++ ) {
                 spinlock * l = &source[i]->lock;
-                lock( l );
+                lock( l, __PRETTY_FUNCTION__ );
                 if(locks) locks[i] = l;
         }
@@ -457 +486 @@
 
 static inline void brand_condition( condition * this ) {
-        thread_desc * thrd = this_thread();
+        thread_desc * thrd = this_thread;
         if( !this->monitors ) {
                 LIB_DEBUG_PRINT_SAFE("Branding\n");