Changeset fd061ed3 for src/libcfa/concurrency/monitor.c
- Timestamp:
- Feb 28, 2017, 1:49:12 PM (7 years ago)
- 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:
- 14f6bb39
- Parents:
- 31868da (diff), cc7f4b1 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the(diff)
links above to see all the changes relative to each parent. - File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
src/libcfa/concurrency/monitor.c
r31868da rfd061ed3 6 6 // file "LICENCE" distributed with Cforall. 7 7 // 8 // monitor.c --8 // __monitor_t.c -- 9 9 // 10 10 // Author : Thierry Delisle … … 19 19 #include "kernel_private.h" 20 20 21 void enter( monitor* this) {21 void enter(__monitor_t * this) { 22 22 lock( &this->lock ); 23 23 thread * thrd = this_thread(); 24 24 25 if( this->holder ) { 25 if( !this->owner ) { 26 //No one has the monitor, just take it 27 this->owner = thrd; 28 this->recursion = 1; 29 } 30 else if( this->owner == thrd) { 31 //We already have the monitor, just not how many times we took it 32 assert( this->recursion > 0 ); 33 this->recursion += 1; 34 } 35 else { 36 //Some one else has the monitor, wait in line for it 26 37 append( &this->entry_queue, thrd ); 27 38 ScheduleInternal( &this->lock ); 28 return; 29 } 30 else { 31 this->holder = thrd; 39 40 //ScheduleInternal will unlock spinlock, no need to unlock ourselves 41 return; 32 42 } 33 43 … … 35 45 } 36 46 37 void leave( monitor* this) {47 void leave(__monitor_t * this) { 38 48 lock( &this->lock ); 39 49 40 50 thread * thrd = this_thread(); 41 assert( thrd == this-> holder );51 assert( thrd == this->owner ); 42 52 43 this->holder = pop_head( &this->entry_queue ); 53 //Leaving a recursion level, decrement the counter 54 this->recursion -= 1; 55 56 //If we left the last level of recursion it means we are changing who owns the monitor 57 thread * new_owner = 0; 58 if( this->recursion == 0) { 59 //Get the next thread in the list 60 new_owner = this->owner = pop_head( &this->entry_queue ); 61 62 //We are passing the monitor to someone else, which means recursion level is not 0 63 this->recursion = new_owner ? 1 : 0; 64 } 44 65 45 66 unlock( &this->lock ); 46 67 47 if( this->holder ) ScheduleThread( this->holder ); 68 //If we have a new owner, we need to wake-up the thread 69 if( new_owner ) { 70 ScheduleThread( new_owner ); 71 } 48 72 }
Note: See TracChangeset
for help on using the changeset viewer.