- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/kernel/startup.cfa
rcd5b58f r15c93d8 535 535 #endif 536 536 537 node.next = 0p; 538 node.prev = 0p; 537 539 doregister(curr_cluster, this); 538 540 … … 657 659 #endif 658 660 659 threads{ };661 threads{ __get }; 660 662 661 663 io.arbiter = create(); … … 737 739 lock (cltr->thread_list_lock __cfaabi_dbg_ctx2); 738 740 cltr->nthreads += 1; 739 insert_first(cltr->threads, thrd);741 push_front(cltr->threads, thrd); 740 742 unlock (cltr->thread_list_lock); 741 743 } … … 743 745 void unregister( cluster * cltr, thread$ & thrd ) { 744 746 lock (cltr->thread_list_lock __cfaabi_dbg_ctx2); 745 { 746 tytagref( dlink(thread$), dlink(thread$) ) ?`inner( thread$ & this ) = void; 747 with( DLINK_VIA( thread$, thread$.cltr_link ) ) 748 remove( thrd ); 749 cltr->nthreads -= 1; 750 } 747 remove(cltr->threads, thrd ); 748 cltr->nthreads -= 1; 751 749 unlock(cltr->thread_list_lock); 752 750 }
Note:
See TracChangeset
for help on using the changeset viewer.