Changeset 80d9e49 for src/libcfa/concurrency/threads.c

Timestamp:

Dec 7, 2016, 2:47:53 PM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

550a338

Parents:

a68caae

Message:

Coroutines no longer require virtual pointers or any code beyond the get_coroutine routine

File:

• src/libcfa/concurrency/threads.c (modified) (6 diffs)

src/libcfa/concurrency/threads.c

@@ -34 +34 @@
 static size_t pageSize = 0;                             // architecture pagesize
 
-static coroutine main_coroutine;
+void ?{}(coStack_t* this, size_t size);
+void ?{}(coroutine* this, size_t size);
+
+static coroutine main_coroutine = { 1000 };
 static coroutine* current_coroutine = &main_coroutine;
 
@@ -43 +46 @@
 void ctxSwitchDirect(coroutine* src, coroutine* dst);
 void create_stack( coStack_t* this, unsigned int storageSize ); // used by all constructors
+
+extern "C" {
+      forall(dtype T | is_coroutine(T))
+      void invokeCoroutine(T* this);
+
+      forall(dtype T | is_coroutine(T))
+      void startCoroutine(T* this, void (*invoke)(T*));
+}
 
 void ?{}(coStack_t* this) {
@@ -52 +63 @@
         this->top               = NULL; // address of top of storage
         this->userStack = false;        
+}
+
+void ?{}(coStack_t* this, size_t size) {
+        this{};
+        this->size = size;
 
         create_stack(this, this->size);
@@ -66 +82 @@
 }
 
-void ?{}(coroutine* this, covptr_t* object)
+void ?{}(coroutine* this, size_t size)
 {
         this{};
-
-        startCoroutine(object, invokeCoroutine);
+        (&this->stack){size};
 }
 
@@ -88 +103 @@
 }
 
-forall(dtype T | coroutine_t(T))
+forall(dtype T | is_coroutine(T))
 void resume(T* cor) {
         coroutine* src = this_coroutine();              // optimization
-        coroutine* dst = get_coroutine(vtable(cor));
+        coroutine* dst = get_coroutine(cor);
+
+        if( ((intptr_t)dst->stack.base) == 0 ) {
+                create_stack(&dst->stack, dst->stack.size);
+                startCoroutine(cor, invokeCoroutine);
+        }
 
         if ( src != dst ) {                             // not resuming self ?
@@ -103 +123 @@
 }
 
+forall(dtype T | is_coroutine(T))
+void prime(T* cor) {
+        coroutine* this = get_coroutine(cor);
+        assert(this->state == Start);
+
+        this->state = Primed;
+        resume(cor);
+}
+
 void ctxSwitchDirect(coroutine* src, coroutine* dst) {
         // THREAD_GETMEM( This )->disableInterrupts();