source: libcfa/src/concurrency/invoke.h@ f1cb193

stuck-waitfor-destruct
Last change on this file since f1cb193 was a30fceb, checked in by Matthew Au-Yeung <mw2auyeu@…>, 3 days ago

Add a generated hash to fix stuck waitfor comparing static inline mutex destructors
  • Property mode set to 100644
File size: 10.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 Oct 31 08:46:59 2025
13// Update Count : 67
14//
15
16// No not use #pragma once was this file is included twice in some places. It has its own guard system.
17
18#include "bits/collections.hfa"
19#include "bits/defs.hfa"
20#include "bits/locks.hfa"
21#include "bits/random.hfa"
22#include "kernel/fwd.hfa"
23
24#ifdef __cforall
25#include "collections/list.hfa"
26extern "C" {
27#endif
28
29#if ! defined(__CFA_INVOKE_PRIVATE__)
30#ifndef _INVOKE_H_
31#define _INVOKE_H_
32
33 enum { DEFAULT_STACK_SIZE = 65000 };
34
35 struct __cfaehm_try_resume_node;
36 struct __cfaehm_base_exception_t;
37 struct exception_context_t {
38 struct __cfaehm_try_resume_node * top_resume;
39 struct __cfaehm_base_exception_t * current_exception;
40 };
41
42 struct __stack_context_t {
43 void * SP;
44 void * FP;
45 };
46
47 // low adresses : +----------------------+ <- start of allocation
48 // | optional guard page |
49 // +----------------------+ <- __stack_t.limit
50 // | |
51 // | /\ /\ /\ |
52 // | || || || |
53 // | |
54 // | program stack |
55 // | |
56 // __stack_info_t.storage -> +----------------------+ <- __stack_t.base
57 // | __stack_t |
58 // high adresses : +----------------------+ <- end of allocation
59
60 struct __stack_t {
61 // stack grows towards stack limit
62 void * limit;
63
64 // base of stack
65 void * base;
66
67 // Information for exception handling.
68 struct exception_context_t exception_context;
69 };
70
71 struct __stack_info_t {
72 // pointer to stack
73 struct __stack_t * storage;
74 };
75
76 struct nonlocal_ehm {
77 // list of pending nonlocal exceptions
78 __queue_t(struct nonlocal_exception) ehm_buffer;
79
80 // lock to protect the buffer
81 struct __spinlock_t buffer_lock;
82
83 // enable/disabled flag
84 bool ehm_enabled;
85 };
86
87 enum __Coroutine_State { Halted, Start, Primed, Blocked, Ready, Active, Cancelled, Halting };
88
89 struct coroutine$ {
90 // context that is switch during a __cfactx_switch
91 struct __stack_context_t context;
92
93 // stack information of the coroutine
94 struct __stack_info_t stack;
95
96 // textual name for coroutine/task
97 const char * name;
98
99 // current execution status for coroutine
100 enum __Coroutine_State state;
101
102 // first coroutine to resume this one
103 struct coroutine$ * starter;
104
105 // last coroutine to resume this one
106 struct coroutine$ * last;
107
108 // If non-null stack must be unwound with this exception
109 struct _Unwind_Exception * cancellation;
110
111 // Non-local exception handling information
112 struct nonlocal_ehm ehm_state;
113 };
114 // Wrapper for gdb
115 struct cfathread_coroutine_t { struct coroutine$ debug; };
116
117 static inline struct __stack_t * __get_stack( struct coroutine$ * cor ) {
118 return (struct __stack_t*)(((uintptr_t)cor->stack.storage) & ((uintptr_t)-2));
119 }
120
121 // struct which calls the monitor is accepting
122 struct __waitfor_mask_t {
123 // the index of the accepted function, -1 if none
124 short * accepted;
125
126 // list of acceptable functions, null if any
127 __cfa_anonymous_object( __small_array_t(struct __acceptable_t) );
128 };
129
130 struct monitor$ {
131 // spinlock to protect internal data
132 struct __spinlock_t lock;
133
134 // current owner of the monitor
135 struct thread$ * owner;
136
137 // queue of threads that are blocked waiting for the monitor
138 __queue_t(struct thread$) entry_queue;
139
140 // stack of conditions to run next once we exit the monitor
141 __stack_t(struct __condition_criterion_t) signal_stack;
142
143 // monitor routines can be called recursively, we need to keep track of that
144 unsigned int recursion;
145
146 // mask used to know if some thread is waiting for something while holding the monitor
147 struct __waitfor_mask_t mask;
148
149 // node used to signal the dtor in a waitfor dtor
150 struct __condition_node_t * dtor_node;
151 };
152 // Wrapper for gdb
153 struct cfathread_monitor_t { struct monitor$ debug; };
154
155 struct __monitor_group_t {
156 // currently held monitors
157 __cfa_anonymous_object( __small_array_t(monitor$*) );
158
159 // last function that acquired monitors
160 fptr_t func;
161
162 // hash-based function identity for cross-TU matching
163 func_id_t func_id;
164 };
165
166 // Link lists fields
167 // instrusive link field for threads in the ready-queue
168 struct __thread_desc_link {
169 struct thread$ * next;
170 volatile unsigned long long ts;
171 };
172
173 // Link lists fields
174 // instrusive link field for threads in the user_link/cltr_link
175 struct __thread_user_link {
176 #ifdef __cforall
177 inline dlink(thread$);
178 #else
179 struct thread$ * next; struct thread$ * back;
180 #endif
181 };
182 _Static_assert(sizeof(struct __thread_user_link) == 2 * sizeof(struct thread$ *), "__thread_user_link should be consistent in C and Cforall");
183
184 struct thread$ {
185 // Core threading fields
186 // context that is switch during a __cfactx_switch
187 struct __stack_context_t context;
188
189 // Link lists fields
190 // instrusive link field for threads
191 struct __thread_desc_link rdy_link;
192
193 // current execution status for coroutine
194 // Possible values are:
195 // - TICKET_BLOCKED (-1) thread is blocked
196 // - TICKET_RUNNING ( 0) thread is running
197 // - TICKET_UNBLOCK ( 1) thread should ignore next block
198 volatile int ticket;
199 enum __Coroutine_State state:8;
200 enum __Preemption_Reason preempted:8;
201
202 bool corctx_flag;
203
204 //SKULLDUGGERY errno is not save in the thread data structure because returnToKernel appears to be the only function to require saving and restoring it
205
206 // pointer to the cluster on which the thread is running
207 struct cluster * curr_cluster;
208
209 // preferred ready-queue or CPU
210 unsigned preferred;
211
212 // coroutine body used to store context
213 struct coroutine$ self_cor;
214
215 // current active context
216 struct coroutine$ * curr_cor;
217
218 // monitor body used for mutual exclusion
219 struct monitor$ self_mon;
220
221 // pointer to monitor with sufficient lifetime for current monitors
222 struct monitor$ * self_mon_p;
223
224 // monitors currently held by this thread
225 struct __monitor_group_t monitors;
226
227 // intrusive link fields, used for locks, monitors and any user defined data structure
228 // default link fields for dlist
229 struct __thread_user_link user_link;
230
231 // secondary intrusive link fields, used for global cluster list
232 // default link fields for dlist
233 struct __thread_user_link cltr_link;
234
235 struct processor * last_proc;
236
237 // ptr used during handover between blocking lists to allow for stack allocation of intrusive nodes
238 // main use case is wait-morphing to allow a different node to be used to block on condvar vs lock
239 void * link_node;
240
241 // extra fields supporting task related features
242 uintptr_t shadow$; // user information for shadow queue
243 PRNG_STATE_T random_state; // fast random numbers
244
245 #if defined( __CFA_WITH_VERIFY__ )
246 struct processor * volatile executing;
247 void * canary;
248 #endif
249 };
250
251 // Wrapper for gdb
252 struct cfathread_thread_t { struct thread$ debug; };
253
254 #ifdef __CFA_DEBUG__
255 void __cfaabi_dbg_record_thrd(thread$ & this, bool park, const char prev_name[]);
256 #else
257 #define __cfaabi_dbg_record_thrd(x, y, z)
258 #endif
259
260 #ifdef __cforall
261 extern "Cforall" {
262 static inline bool exception_in_flight() {
263 return __get_stack( &active_thread()->self_cor )->exception_context.current_exception != 0p;
264 }
265
266 static inline thread$ * volatile & next( thread$ * this ) {
267 return this->user_link.next;
268 }
269
270 static inline thread$ *& get_next( thread$ & this ) __attribute__((const)) {
271 return this.user_link.next;
272 }
273
274 static inline tytagref( dlink(thread$), dlink(thread$) ) ?`inner( thread$ & this ) {
275 dlink(thread$) & b = this.user_link;
276 tytagref( dlink(thread$), dlink(thread$) ) result = { b };
277 return result;
278 }
279
280 static inline tytagref(struct __thread_user_link, dlink(thread$)) ?`inner( struct thread$ & this ) {
281 struct __thread_user_link & ib = this.cltr_link;
282 dlink(thread$) & b = ib`inner;
283 tytagref(struct __thread_user_link, dlink(thread$)) result = { b };
284 return result;
285 }
286
287 P9_EMBEDDED(struct __thread_user_link, dlink(thread$))
288
289 static inline void ?{}(__monitor_group_t & this) {
290 (this.data){0p};
291 (this.size){0};
292 (this.func){NULL};
293 (this.func_id){0};
294 }
295
296 static inline void ?{}(__monitor_group_t & this, struct monitor$ ** data, __lock_size_t size, fptr_t func, func_id_t func_id) {
297 (this.data){data};
298 (this.size){size};
299 (this.func){func};
300 (this.func_id){func_id};
301 }
302
303 static inline bool ?==?( const __monitor_group_t & lhs, const __monitor_group_t & rhs ) __attribute__((const)) {
304 if( (lhs.data != 0) != (rhs.data != 0) ) return false;
305 if( lhs.size != rhs.size ) return false;
306 // Use hash-based comparison when both sides have a valid func_id,
307 // otherwise fall back to function pointer comparison (for library code
308 // like join() that cannot compute the hash at compile time).
309 if( lhs.func_id != 0 && rhs.func_id != 0 ) {
310 if( lhs.func_id != rhs.func_id ) return false;
311 } else {
312 if( lhs.func != rhs.func ) return false;
313 }
314
315 // Check that all the monitors match
316 for( int i = 0; i < lhs.size; i++ ) {
317 // If not a match, check next function
318 if( lhs[i] != rhs[i] ) return false;
319 }
320
321 return true;
322 }
323
324 static inline void ?=?(__monitor_group_t & lhs, const __monitor_group_t & rhs) {
325 lhs.data = rhs.data;
326 lhs.size = rhs.size;
327 lhs.func = rhs.func;
328 lhs.func_id = rhs.func_id;
329 }
330 }
331 #endif
332
333#endif //_INVOKE_H_
334#else //! defined(__CFA_INVOKE_PRIVATE__)
335#ifndef _INVOKE_PRIVATE_H_
336#define _INVOKE_PRIVATE_H_
337
338 struct machine_context_t {
339 void *SP;
340 void *FP;
341 void *PC;
342 };
343
344 // assembler routines that performs the context switch
345 extern void __cfactx_invoke_stub( void );
346 extern void __cfactx_switch( struct __stack_context_t * from, struct __stack_context_t * to ) asm ("__cfactx_switch");
347 // void CtxStore ( void * this ) asm ("CtxStore");
348 // void CtxRet ( void * dst ) asm ("CtxRet");
349
350#endif //_INVOKE_PRIVATE_H_
351#endif //! defined(__CFA_INVOKE_PRIVATE__)
352#ifdef __cforall
353}
354#endif
355
356// Local Variables: //
357// mode: c //
358// tab-width: 4 //
359// End: //
Note: See TracBrowser for help on using the repository browser.