Changes in src/libcfa/concurrency/threads [5c81105:78b3f52]

File:

• src/libcfa/concurrency/threads (modified) (1 diff)

src/libcfa/concurrency/threads

@@ -18 +18 @@
 #define __THREADS_H__
 
-#include "invoke.h"
+#include <stdbool.h>
+
+extern "C" {
+      struct coVtable {
+            void (*main)(void*);
+            struct coroutine* (*this_coroutine)(void*);
+      };
+
+      struct coStack_t {
+            unsigned int size;          // size of stack
+            void *storage;                      // pointer to stack
+            void *limit;                        // stack grows towards stack limit
+            void *base;                         // base of stack
+            void *context;                      // address of cfa_context_t
+            void *top;                          // address of top of storage
+            bool userStack;     
+      };
+
+
+      enum coroutine_state { Start, Inactive, Active, Halt };
+
+      struct coroutine {
+            coStack_t stack;
+            const char *name;                   // textual name for coroutine/task, initialized by uC++ generated code
+            int errno_;                         // copy of global UNIX variable errno
+            coroutine_state state;            // current execution status for coroutine
+            bool notHalted;                     // indicate if execuation state is not halted
+
+            coroutine *starter;         // first coroutine to resume this one
+            coroutine *last;                    // last coroutine to resume this one
+      };
+}
 
 void ?{}(coStack_t* this);
 
 void ?{}(coroutine* this);
-void ?{}(coroutine* this, covptr_t* object);
 
 trait coroutine_t(dtype T) {
+      coroutine* this_coroutine(T* this);
       void co_main(T* this);
-      covptr_t* vtable(T* this);
+      coVtable* vtable(T* this);
 };
+
+forall(dtype T | coroutine_t(T))
+void start(T* cor);
 
 void suspend(void);