source: src/libcfa/concurrency/invoke.h @ 8def349

aaron-thesisarm-ehcleanup-dtorsdeferred_resndemanglerjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerresolv-newwith_gc
Last change on this file since 8def349 was 8def349, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

cfa now supports processors which represent kernel threads, allowing basic parallelism

  • Property mode set to 100644
File size: 2.8 KB
Line 
1//                              -*- Mode: CFA -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// invoke.h --
9//
10// Author           : Thierry Delisle
11// Created On       : Tue Jan 17 12:27:26 2016
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count     : 0
15//
16
17#include <stdbool.h>
18#include <stdint.h>
19
20#ifdef __CFORALL__
21extern "C" {
22#endif
23
24#if ! defined(__CFA_INVOKE_PRIVATE__)
25#ifndef _INVOKE_H_
26#define _INVOKE_H_
27
28      #define unlikely(x)    __builtin_expect(!!(x), 0)
29      #define thread_local _Thread_local
30      #define SCHEDULER_CAPACITY 10
31
32      struct simple_thread_list {
33            struct thread_h * head;
34            struct thread_h ** tail;
35      };
36
37      #ifdef __CFORALL__
38      extern "Cforall" {
39            void ?{}( struct simple_thread_list * );
40            void append( struct simple_thread_list *, struct thread_h * );
41            struct thread_h * pop_head( struct simple_thread_list * );
42      }
43      #endif
44
45      struct coStack_t {
46            unsigned int size;          // size of stack
47            void *storage;                      // pointer to stack
48            void *limit;                        // stack grows towards stack limit
49            void *base;                         // base of stack
50            void *context;                      // address of cfa_context_t
51            void *top;                          // address of top of storage
52            bool userStack;     
53      };
54
55      enum coroutine_state { Start, Inactive, Active, Halt, Primed };
56
57      struct coroutine {
58            struct coStack_t stack;
59            const char *name;                   // textual name for coroutine/task, initialized by uC++ generated code
60            int errno_;                         // copy of global UNIX variable errno
61            enum coroutine_state state; // current execution status for coroutine
62            bool notHalted;                     // indicate if execuation state is not halted
63
64            struct coroutine *starter;  // first coroutine to resume this one
65            struct coroutine *last;             // last coroutine to resume this one
66      };
67
68      struct simple_lock {
69        struct simple_thread_list blocked;
70      };
71
72      struct thread_h {
73            struct coroutine c;
74            struct simple_lock lock;
75            struct thread_h * next;
76      };
77
78#endif //_INVOKE_H_
79#else //! defined(__CFA_INVOKE_PRIVATE__)
80#ifndef _INVOKE_PRIVATE_H_
81#define _INVOKE_PRIVATE_H_
82     
83      struct machine_context_t {
84            void *SP;
85            void *FP;
86            void *PC;
87      };
88
89      // assembler routines that performs the context switch
90      extern void CtxInvokeStub( void );
91      void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
92      void CtxGet( void * this ) asm ("CtxGet");
93
94#endif //_INVOKE_PRIVATE_H_
95#endif //! defined(__CFA_INVOKE_PRIVATE__)
96#ifdef __CFORALL__
97}
98#endif
Note: See TracBrowser for help on using the repository browser.