Changes in src/libcfa/concurrency/invoke.h [8118303:0157ca7]

File:

• src/libcfa/concurrency/invoke.h (modified) (4 diffs)

src/libcfa/concurrency/invoke.h

@@ +1 @@
+//                              -*- Mode: C -*-
+//
+// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
+//
+// The contents of this file are covered under the licence agreement in the
+// file "LICENCE" distributed with Cforall.
+//
+// invoke.h --
+//
+// Author           : Thierry Delisle
+// Created On       : Tue Jan 17 12:27:26 2016
+// Last Modified By : Thierry Delisle
+// Last Modified On : --
+// Update Count     : 0
+//
+
 #include <stdbool.h>
 #include <stdint.h>
@@ -11 +27 @@
 
       #define unlikely(x)    __builtin_expect(!!(x), 0)
+      #define thread_local _Thread_local
+      #define SCHEDULER_CAPACITY 10
+
+      struct simple_thread_list {
+            struct thread * head;
+            struct thread ** tail;
+      };
+
+      #ifdef __CFORALL__
+      extern "Cforall" {
+            void ?{}( struct simple_thread_list * );
+            void append( struct simple_thread_list *, struct thread * );
+            struct thread * pop_head( struct simple_thread_list * );
+      }
+      #endif
 
       struct coStack_t {
@@ -35 +66 @@
       };
 
-      struct thread_h {
+      struct simple_lock {
+        struct simple_thread_list blocked;
+      };
+
+      struct thread {
             struct coroutine c;
+            struct simple_lock lock;
+            struct thread * next;
       };
 
@@ -52 +89 @@
       // assembler routines that performs the context switch
       extern void CtxInvokeStub( void );
-      void CtxSwitch( void *from, void *to ) asm ("CtxSwitch");
+      void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
+      void CtxGet( void * this ) asm ("CtxGet");
 
 #endif //_INVOKE_PRIVATE_H_