source: src/libcfa/concurrency/invoke.h @ 025278e

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

Changed comments to be above fields, to help source control diff readability

  • Property mode set to 100644
File size: 5.4 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// invoke.h --
8//
9// Author           : Thierry Delisle
10// Created On       : Tue Jan 17 12:27:26 2016
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Fri Jul 21 22:28:56 2017
13// Update Count     : 1
14//
15
16#include <stdbool.h>
17#include <stdint.h>
18
19#ifdef __CFORALL__
20extern "C" {
21#endif
22
23#if ! defined(__CFA_INVOKE_PRIVATE__)
24#ifndef _INVOKE_H_
25#define _INVOKE_H_
26
27        #define unlikely(x)    __builtin_expect(!!(x), 0)
28        #define thread_local _Thread_local
29
30        typedef void (*fptr_t)();
31
32        struct spinlock {
33                volatile int lock;
34                #ifdef __CFA_DEBUG__
35                        const char * prev_name;
36                        void* prev_thrd;
37                #endif
38        };
39
40        struct __thread_queue_t {
41                struct thread_desc * head;
42                struct thread_desc ** tail;
43        };
44
45        struct __condition_stack_t {
46                struct __condition_criterion_t * top;
47        };
48
49        #ifdef __CFORALL__
50        extern "Cforall" {
51                void ?{}( struct __thread_queue_t & );
52                void append( struct __thread_queue_t &, struct thread_desc * );
53                struct thread_desc * pop_head( struct __thread_queue_t & );
54                struct thread_desc * remove( struct __thread_queue_t &, struct thread_desc ** );
55
56                void ?{}( struct __condition_stack_t & );
57                void push( struct __condition_stack_t &, struct __condition_criterion_t * );
58                struct __condition_criterion_t * pop( struct __condition_stack_t & );
59
60                void  ?{}(spinlock & this);
61                void ^?{}(spinlock & this);
62        }
63        #endif
64
65        struct coStack_t {
66                // size of stack
67                unsigned int size;
68
69                // pointer to stack
70                void *storage;
71
72                // stack grows towards stack limit
73                void *limit;
74
75                // base of stack
76                void *base;
77
78                // address of cfa_context_t
79                void *context;
80
81                // address of top of storage
82                void *top;
83
84                // whether or not the user allocated the stack
85                bool userStack;
86
87        };
88
89        enum coroutine_state { Halted, Start, Inactive, Active, Primed };
90
91        struct coroutine_desc {
92                // stack information of the coroutine
93                struct coStack_t stack;
94
95                // textual name for coroutine/task, initialized by uC++ generated code
96                const char *name;
97
98                // copy of global UNIX variable errno
99                int errno_;
100
101                // current execution status for coroutine
102                enum coroutine_state state;
103
104                // first coroutine to resume this one
105                struct coroutine_desc * starter;
106
107                // last coroutine to resume this one
108                struct coroutine_desc * last;
109        };
110
111        struct __waitfor_mask_t {
112                // the index of the accepted function, -1 if none
113                short * accepted;
114
115                // list of acceptable functions, null if any
116                struct __acceptable_t * clauses;
117
118                // number of acceptable functions
119                short size;
120        };
121
122        struct monitor_desc {
123                // spinlock to protect internal data
124                struct spinlock lock;
125
126                // current owner of the monitor
127                struct thread_desc * owner;
128
129                // queue of threads that are blocked waiting for the monitor
130                struct __thread_queue_t entry_queue;
131
132                // stack of conditions to run next once we exit the monitor
133                struct __condition_stack_t signal_stack;
134
135                // monitor routines can be called recursively, we need to keep track of that
136                unsigned int recursion;
137
138                // mask used to know if some thread is waiting for something while holding the monitor
139                struct __waitfor_mask_t mask;
140
141                // node used to signal the dtor in a waitfor dtor
142                struct __condition_node_t * dtor_node;
143        };
144
145        struct __monitor_group_t {
146                // currently held monitors
147                struct monitor_desc ** list;
148
149                // number of currently held monitors
150                short                  size;
151
152                // last function that acquired monitors
153                fptr_t                 func;
154        };
155
156        struct thread_desc {
157                // Core threading fields
158                // coroutine body used to store context
159                struct coroutine_desc  self_cor;
160
161                // monitor body used for mutual exclusion
162                struct monitor_desc    self_mon;
163
164                // pointer to monitor with sufficient lifetime for current monitors
165                struct monitor_desc *  self_mon_p;
166
167                // monitors currently held by this thread
168                struct __monitor_group_t monitors;
169
170
171                // Link lists fields
172                // instrusive link field for threads
173                struct thread_desc * next;
174     };
175
176     #ifdef __CFORALL__
177     extern "Cforall" {
178                static inline monitor_desc * ?[?]( const __monitor_group_t & this, ptrdiff_t index ) {
179                        return this.list[index];
180                }
181
182                static inline bool ?==?( const __monitor_group_t & lhs, const __monitor_group_t & rhs ) {
183                        if( (lhs.list != 0) != (rhs.list != 0) ) return false;
184                        if( lhs.size != rhs.size ) return false;
185                        if( lhs.func != rhs.func ) return false;
186
187                        // Check that all the monitors match
188                        for( int i = 0; i < lhs.size; i++ ) {
189                                // If not a match, check next function
190                                if( lhs[i] != rhs[i] ) return false;
191                        }
192
193                        return true;
194                }
195        }
196        #endif
197
198#endif //_INVOKE_H_
199#else //! defined(__CFA_INVOKE_PRIVATE__)
200#ifndef _INVOKE_PRIVATE_H_
201#define _INVOKE_PRIVATE_H_
202
203        struct machine_context_t {
204                void *SP;
205                void *FP;
206                void *PC;
207        };
208
209        // assembler routines that performs the context switch
210        extern void CtxInvokeStub( void );
211        void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
212
213        #if   defined( __x86_64__ )
214        #define CtxGet( ctx ) __asm__ ( \
215                        "movq %%rsp,%0\n"   \
216                        "movq %%rbp,%1\n"   \
217                : "=rm" (ctx.SP), "=rm" (ctx.FP) )
218        #elif defined( __i386__ )
219        #define CtxGet( ctx ) __asm__ ( \
220                        "movl %%esp,%0\n"   \
221                        "movl %%ebp,%1\n"   \
222                : "=rm" (ctx.SP), "=rm" (ctx.FP) )
223        #endif
224
225#endif //_INVOKE_PRIVATE_H_
226#endif //! defined(__CFA_INVOKE_PRIVATE__)
227#ifdef __CFORALL__
228}
229#endif
230
231// Local Variables: //
232// mode: c //
233// tab-width: 4 //
234// End: //
Note: See TracBrowser for help on using the repository browser.