Changes in / [8a9a3ab:4c0fa03]

Location:

libcfa/src/concurrency

Files:

• coroutine.cfa (modified) (2 diffs)
• coroutine.hfa (modified) (5 diffs)
• exception.cfa (modified) (1 diff)

libcfa/src/concurrency/coroutine.cfa

@@ -344 +344 @@
 bool poll() libcfa_public { return poll( active_coroutine() ); }
 coroutine$ * resumer() libcfa_public { return active_coroutine()->last; }
-coroutine$ * first_resumer() libcfa_public { return active_coroutine()->starter; }
 
 // user facing ehm operations
@@ -359 +358 @@
 
     coroutine$ * resumer( T & cor ) libcfa_public { return get_coroutine( cor )->last; }
-    coroutine$ * first_resumer( T & cor ) libcfa_public { return get_coroutine( cor )->starter; }
 }
 

libcfa/src/concurrency/coroutine.hfa

@@ -124 +124 @@
         src->state = Active;
 
-        if( unlikely(src->cancellation != 0p && src->cancellation != 1p) ) {
+        if( unlikely(src->cancellation != 0p) ) {
                 __cfactx_coroutine_unwind(src->cancellation, src);
         }
@@ -169 +169 @@
         coroutine$ * dst = get_coroutine(cor);
 
-    // printf("FROM RES src: %p, dest: %p\n", src, dst);
-
         if( unlikely(dst->context.SP == 0p) ) {
                 __stack_prepare(&dst->stack, DEFAULT_STACK_SIZE);
@@ -190 +188 @@
         // always done for performance testing
         $ctx_switch( src, dst );
-
-        if ( unlikely(src->cancellation == 1p) ) {
-        src->cancellation = 0p;
-        // we know dst hasn't been deallocated
+        if ( unlikely(dst->cancellation) ) {
                 __cfaehm_cancelled_coroutine( cor, dst, _default_vtable );
         }
@@ -227 +222 @@
 bool poll();
 coroutine$ * resumer();
-coroutine$ * first_resumer();
 
 forall(T & | is_coroutine(T)) {
@@ -235 +229 @@
     bool checked_poll( T & cor );
     coroutine$ * resumer( T & cor );
-    coroutine$ * first_resumer( T & cor );
 }
 

libcfa/src/concurrency/exception.cfa

@@ -57 +57 @@
         struct coroutine$ * src = (coroutine$ *)stop_param;
         struct coroutine$ * dst = src->last;
-    dst->cancellation = 1p;
+
         $ctx_switch( src, dst );
         abort();