Changes in src/libcfa/concurrency/kernel.c [9d944b2:5ea06d6]

File:

• src/libcfa/concurrency/kernel.c (modified) (7 diffs)

src/libcfa/concurrency/kernel.c

@@ -299 +299 @@
 // Scheduler routines
 void ScheduleThread( thread_desc * thrd ) {
+        if( !thrd ) return;
+
         assertf( thrd->next == NULL, "Expected null got %p", thrd->next );
         
@@ -473 +475 @@
 
 void ?{}( signal_once * this ) {
-        this->condition = false;
+        this->cond = false;
 }
 void ^?{}( signal_once * this ) {
@@ -481 +483 @@
 void wait( signal_once * this ) {
         lock( &this->lock );
-        if( !this->condition ) {
+        if( !this->cond ) {
                 append( &this->blocked, this_thread() );
                 ScheduleInternal( &this->lock );
@@ -492 +494 @@
         lock( &this->lock );
         {
-                this->condition = true;
+                this->cond = true;
 
                 thread_desc * it;
@@ -504 +506 @@
 //-----------------------------------------------------------------------------
 // Queues
-void ?{}( simple_thread_list * this ) {
+void ?{}( __thread_queue_t * this ) {
         this->head = NULL;
         this->tail = &this->head;
 }
 
-void append( simple_thread_list * this, thread_desc * t ) {
+void append( __thread_queue_t * this, thread_desc * t ) {
         assert(this->tail != NULL);
         *this->tail = t;
@@ -515 +517 @@
 }
 
-thread_desc * pop_head( simple_thread_list * this ) {
+thread_desc * pop_head( __thread_queue_t * this ) {
         thread_desc * head = this->head;
         if( head ) {
@@ -526 +528 @@
         return head;
 }
+
+void ?{}( __thread_stack_t * this ) {
+        this->top = NULL;
+}
+
+void push( __thread_stack_t * this, thread_desc * t ) {
+        assert(t->next != NULL);
+        t->next = this->top;
+        this->top = t;
+}
+
+thread_desc * pop( __thread_stack_t * this ) {
+        thread_desc * top = this->top;
+        if( top ) {
+                this->top = top->next;
+                top->next = NULL;
+        }       
+        return top;
+}
 // Local Variables: //
 // mode: c //