Changes in libcfa/src/concurrency/coroutine.hfa [4269d1b:3318dff]

File:

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

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 );
 }