Changes in src/libcfa/concurrency/coroutine.c [47ecf2b:4aa2fb2]

File:

• src/libcfa/concurrency/coroutine.c (modified) (5 diffs)

src/libcfa/concurrency/coroutine.c

@@ -32 +32 @@
 #include "invoke.h"
 
-extern volatile thread_local processor * this_processor;
+extern thread_local processor * this_processor;
 
 //-----------------------------------------------------------------------------
@@ -44 +44 @@
 // Coroutine ctors and dtors
 void ?{}(coStack_t* this) {
-        this->size              = 65000;        // size of stack
+        this->size              = 10240;        // size of stack
         this->storage   = NULL; // pointer to stack
         this->limit             = NULL; // stack grows towards stack limit
@@ -50 +50 @@
         this->context   = NULL; // address of cfa_context_t
         this->top               = NULL; // address of top of storage
-        this->userStack = false;
+        this->userStack = false;        
 }
 
@@ -106 +106 @@
 
         // set state of current coroutine to inactive
-        src->state = src->state == Halted ? Halted : Inactive;
+        src->state = Inactive;
 
         // set new coroutine that task is executing
-        this_coroutine = dst;
+        this_processor->current_coroutine = dst;
 
         // context switch to specified coroutine
-        assert( src->stack.context );
         CtxSwitch( src->stack.context, dst->stack.context );
-        // when CtxSwitch returns we are back in the src coroutine
+        // when CtxSwitch returns we are back in the src coroutine              
 
         // set state of new coroutine to active
@@ -132 +131 @@
                 this->size = libCeiling( storageSize, 16 );
                 // use malloc/memalign because "new" raises an exception for out-of-memory
-
+                
                 // assume malloc has 8 byte alignment so add 8 to allow rounding up to 16 byte alignment
                 LIB_DEBUG_DO( this->storage = memalign( pageSize, cxtSize + this->size + pageSize ) );