Changes in libcfa/src/concurrency/coroutine.hfa [8a97248:3318dff]

File:

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

libcfa/src/concurrency/coroutine.hfa

@@ -19 +19 @@
 #include "invoke.h"
 #include "../exception.hfa"
+
+//-----------------------------------------------------------------------------
+// Type used to store and queue nonlocal exceptions on coroutines
+struct nonlocal_exception {
+    exception_t * the_exception;
+    nonlocal_exception * next;
+};
+static inline void ?{} ( nonlocal_exception & this, exception_t * ex ) with(this) {
+    the_exception = ex;
+    next = 0p;
+}
+
+static inline nonlocal_exception *& get_next( nonlocal_exception & this ) __attribute__((const)) {
+    return this.next;
+}
 
 //-----------------------------------------------------------------------------
@@ -203 +218 @@
 }
 
+// non local ehm and coroutine utility routines
+bool poll( coroutine$ * cor );
+bool poll();
+coroutine$ * resumer();
+
+forall(T & | is_coroutine(T)) {
+    void enable_ehm( T & cor );
+    void disable_ehm( T & cor );
+    bool poll( T & cor );
+    bool checked_poll( T & cor );
+    coroutine$ * resumer( T & cor );
+}
+
+// trait for exceptions able to be resumed at another coroutine
+forall(exceptT *, T & | is_coroutine(T))
+trait ehm_resume_at { void $throwResume(exceptT &); };
+
+// general resumeAt
+forall(exceptT *, T & | ehm_resume_at( exceptT, T ))
+void resumeAt( T & receiver, exceptT & ex );
+
+// resumeAt for underlying coroutine$ type
+forall(exceptT * | { void $throwResume(exceptT &); })
+void resumeAt( coroutine$ * receiver, exceptT & ex );
+
 // Local Variables: //
 // mode: c //