Changeset c3e510b for libcfa/src/concurrency/coroutine.cfa

Timestamp:

Aug 7, 2023, 12:35:53 PM (14 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

27f2bef

Parents:

ff7f6d07

Message:

added support for resuming at resumer, added test for support and cleaned up uneeded include in pingpong exception test

File:

• libcfa/src/concurrency/coroutine.cfa (modified) (2 diffs)

libcfa/src/concurrency/coroutine.cfa

@@ -325 +325 @@
     // poll iff nonlocal ehm is enabled
     bool checked_poll( T & cor ) libcfa_public { return get_coroutine( cor )->ehm_state.ehm_enabled ? poll( cor ) : false; }
+
+    coroutine$ * resumer( T & cor ) libcfa_public { return get_coroutine( cor )->last; }
 }
 
@@ -338 +340 @@
 }
 
+forall(exceptT & | { void $throwResume(exceptT &); })
+void resumeAt( coroutine$ * receiver, exceptT & ex ) libcfa_public {
+    nonlocal_exception * nl_ex = alloc();
+    (*nl_ex){ (exception_t *)&ex };
+    lock( receiver->ehm_state.buffer_lock __cfaabi_dbg_ctx2 );
+    append( receiver->ehm_state.ehm_buffer, nl_ex ); 
+    unlock( receiver->ehm_state.buffer_lock );
+}
+
 // Local Variables: //
 // mode: c //