libgomp.h revision 1.1.1.9 1 1.1.1.9 mrg /* Copyright (C) 2005-2019 Free Software Foundation, Inc.
2 1.1 mrg Contributed by Richard Henderson <rth (at) redhat.com>.
3 1.1 mrg
4 1.1.1.3 mrg This file is part of the GNU Offloading and Multi Processing Library
5 1.1.1.3 mrg (libgomp).
6 1.1 mrg
7 1.1 mrg Libgomp is free software; you can redistribute it and/or modify it
8 1.1 mrg under the terms of the GNU General Public License as published by
9 1.1 mrg the Free Software Foundation; either version 3, or (at your option)
10 1.1 mrg any later version.
11 1.1 mrg
12 1.1 mrg Libgomp is distributed in the hope that it will be useful, but WITHOUT ANY
13 1.1 mrg WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
14 1.1 mrg FOR A PARTICULAR PURPOSE. See the GNU General Public License for
15 1.1 mrg more details.
16 1.1 mrg
17 1.1 mrg Under Section 7 of GPL version 3, you are granted additional
18 1.1 mrg permissions described in the GCC Runtime Library Exception, version
19 1.1 mrg 3.1, as published by the Free Software Foundation.
20 1.1 mrg
21 1.1 mrg You should have received a copy of the GNU General Public License and
22 1.1 mrg a copy of the GCC Runtime Library Exception along with this program;
23 1.1 mrg see the files COPYING3 and COPYING.RUNTIME respectively. If not, see
24 1.1 mrg <http://www.gnu.org/licenses/>. */
25 1.1 mrg
26 1.1 mrg /* This file contains data types and function declarations that are not
27 1.1.1.3 mrg part of the official OpenACC or OpenMP user interfaces. There are
28 1.1.1.3 mrg declarations in here that are part of the GNU Offloading and Multi
29 1.1.1.3 mrg Processing ABI, in that the compiler is required to know about them
30 1.1.1.3 mrg and use them.
31 1.1 mrg
32 1.1 mrg The convention is that the all caps prefix "GOMP" is used group items
33 1.1 mrg that are part of the external ABI, and the lower case prefix "gomp"
34 1.1 mrg is used group items that are completely private to the library. */
35 1.1 mrg
36 1.1 mrg #ifndef LIBGOMP_H
37 1.1 mrg #define LIBGOMP_H 1
38 1.1 mrg
39 1.1.1.4 mrg #ifndef _LIBGOMP_CHECKING_
40 1.1.1.4 mrg /* Define to 1 to perform internal sanity checks. */
41 1.1.1.4 mrg #define _LIBGOMP_CHECKING_ 0
42 1.1.1.4 mrg #endif
43 1.1.1.4 mrg
44 1.1 mrg #include "config.h"
45 1.1 mrg #include "gstdint.h"
46 1.1.1.3 mrg #include "libgomp-plugin.h"
47 1.1.1.9 mrg #include "gomp-constants.h"
48 1.1 mrg
49 1.1.1.5 mrg #ifdef HAVE_PTHREAD_H
50 1.1 mrg #include <pthread.h>
51 1.1.1.5 mrg #endif
52 1.1 mrg #include <stdbool.h>
53 1.1.1.3 mrg #include <stdlib.h>
54 1.1.1.3 mrg #include <stdarg.h>
55 1.1 mrg
56 1.1.1.4 mrg /* Needed for memset in priority_queue.c. */
57 1.1.1.4 mrg #if _LIBGOMP_CHECKING_
58 1.1.1.4 mrg # ifdef STRING_WITH_STRINGS
59 1.1.1.4 mrg # include <string.h>
60 1.1.1.4 mrg # include <strings.h>
61 1.1.1.4 mrg # else
62 1.1.1.4 mrg # ifdef HAVE_STRING_H
63 1.1.1.4 mrg # include <string.h>
64 1.1.1.4 mrg # else
65 1.1.1.4 mrg # ifdef HAVE_STRINGS_H
66 1.1.1.4 mrg # include <strings.h>
67 1.1.1.4 mrg # endif
68 1.1.1.4 mrg # endif
69 1.1.1.4 mrg # endif
70 1.1.1.4 mrg #endif
71 1.1.1.4 mrg
72 1.1 mrg #ifdef HAVE_ATTRIBUTE_VISIBILITY
73 1.1 mrg # pragma GCC visibility push(hidden)
74 1.1 mrg #endif
75 1.1 mrg
76 1.1.1.2 mrg /* If we were a C++ library, we'd get this from <std/atomic>. */
77 1.1.1.2 mrg enum memmodel
78 1.1.1.2 mrg {
79 1.1.1.2 mrg MEMMODEL_RELAXED = 0,
80 1.1.1.2 mrg MEMMODEL_CONSUME = 1,
81 1.1.1.2 mrg MEMMODEL_ACQUIRE = 2,
82 1.1.1.2 mrg MEMMODEL_RELEASE = 3,
83 1.1.1.2 mrg MEMMODEL_ACQ_REL = 4,
84 1.1.1.2 mrg MEMMODEL_SEQ_CST = 5
85 1.1.1.2 mrg };
86 1.1.1.2 mrg
87 1.1.1.4 mrg /* alloc.c */
88 1.1.1.4 mrg
89 1.1.1.9 mrg #if defined(HAVE_ALIGNED_ALLOC) \
90 1.1.1.9 mrg || defined(HAVE__ALIGNED_MALLOC) \
91 1.1.1.9 mrg || defined(HAVE_POSIX_MEMALIGN) \
92 1.1.1.9 mrg || defined(HAVE_MEMALIGN)
93 1.1.1.9 mrg /* Defined if gomp_aligned_alloc doesn't use fallback version
94 1.1.1.9 mrg and free can be used instead of gomp_aligned_free. */
95 1.1.1.9 mrg #define GOMP_HAVE_EFFICIENT_ALIGNED_ALLOC 1
96 1.1.1.9 mrg #endif
97 1.1.1.9 mrg
98 1.1.1.4 mrg extern void *gomp_malloc (size_t) __attribute__((malloc));
99 1.1.1.4 mrg extern void *gomp_malloc_cleared (size_t) __attribute__((malloc));
100 1.1.1.4 mrg extern void *gomp_realloc (void *, size_t);
101 1.1.1.9 mrg extern void *gomp_aligned_alloc (size_t, size_t)
102 1.1.1.9 mrg __attribute__((malloc, alloc_size (2)));
103 1.1.1.9 mrg extern void gomp_aligned_free (void *);
104 1.1.1.4 mrg
105 1.1.1.4 mrg /* Avoid conflicting prototypes of alloca() in system headers by using
106 1.1.1.4 mrg GCC's builtin alloca(). */
107 1.1.1.4 mrg #define gomp_alloca(x) __builtin_alloca(x)
108 1.1.1.4 mrg
109 1.1.1.4 mrg /* error.c */
110 1.1.1.4 mrg
111 1.1.1.4 mrg extern void gomp_vdebug (int, const char *, va_list);
112 1.1.1.4 mrg extern void gomp_debug (int, const char *, ...)
113 1.1.1.4 mrg __attribute__ ((format (printf, 2, 3)));
114 1.1.1.4 mrg #define gomp_vdebug(KIND, FMT, VALIST) \
115 1.1.1.4 mrg do { \
116 1.1.1.4 mrg if (__builtin_expect (gomp_debug_var, 0)) \
117 1.1.1.4 mrg (gomp_vdebug) ((KIND), (FMT), (VALIST)); \
118 1.1.1.4 mrg } while (0)
119 1.1.1.4 mrg #define gomp_debug(KIND, ...) \
120 1.1.1.4 mrg do { \
121 1.1.1.4 mrg if (__builtin_expect (gomp_debug_var, 0)) \
122 1.1.1.4 mrg (gomp_debug) ((KIND), __VA_ARGS__); \
123 1.1.1.4 mrg } while (0)
124 1.1.1.4 mrg extern void gomp_verror (const char *, va_list);
125 1.1.1.4 mrg extern void gomp_error (const char *, ...)
126 1.1.1.4 mrg __attribute__ ((format (printf, 1, 2)));
127 1.1.1.4 mrg extern void gomp_vfatal (const char *, va_list)
128 1.1.1.4 mrg __attribute__ ((noreturn));
129 1.1.1.4 mrg extern void gomp_fatal (const char *, ...)
130 1.1.1.4 mrg __attribute__ ((noreturn, format (printf, 1, 2)));
131 1.1.1.4 mrg
132 1.1.1.4 mrg struct gomp_task;
133 1.1.1.4 mrg struct gomp_taskgroup;
134 1.1.1.4 mrg struct htab;
135 1.1.1.4 mrg
136 1.1.1.4 mrg #include "priority_queue.h"
137 1.1 mrg #include "sem.h"
138 1.1 mrg #include "mutex.h"
139 1.1 mrg #include "bar.h"
140 1.1.1.5 mrg #include "simple-bar.h"
141 1.1 mrg #include "ptrlock.h"
142 1.1 mrg
143 1.1 mrg
144 1.1 mrg /* This structure contains the data to control one work-sharing construct,
145 1.1 mrg either a LOOP (FOR/DO) or a SECTIONS. */
146 1.1 mrg
147 1.1 mrg enum gomp_schedule_type
148 1.1 mrg {
149 1.1 mrg GFS_RUNTIME,
150 1.1 mrg GFS_STATIC,
151 1.1 mrg GFS_DYNAMIC,
152 1.1 mrg GFS_GUIDED,
153 1.1.1.9 mrg GFS_AUTO,
154 1.1.1.9 mrg GFS_MONOTONIC = 0x80000000U
155 1.1 mrg };
156 1.1 mrg
157 1.1.1.4 mrg struct gomp_doacross_work_share
158 1.1.1.4 mrg {
159 1.1.1.4 mrg union {
160 1.1.1.4 mrg /* chunk_size copy, as ws->chunk_size is multiplied by incr for
161 1.1.1.4 mrg GFS_DYNAMIC. */
162 1.1.1.4 mrg long chunk_size;
163 1.1.1.4 mrg /* Likewise, but for ull implementation. */
164 1.1.1.4 mrg unsigned long long chunk_size_ull;
165 1.1.1.4 mrg /* For schedule(static,0) this is the number
166 1.1.1.4 mrg of iterations assigned to the last thread, i.e. number of
167 1.1.1.4 mrg iterations / number of threads. */
168 1.1.1.4 mrg long q;
169 1.1.1.4 mrg /* Likewise, but for ull implementation. */
170 1.1.1.4 mrg unsigned long long q_ull;
171 1.1.1.4 mrg };
172 1.1.1.4 mrg /* Size of each array entry (padded to cache line size). */
173 1.1.1.4 mrg unsigned long elt_sz;
174 1.1.1.4 mrg /* Number of dimensions in sink vectors. */
175 1.1.1.4 mrg unsigned int ncounts;
176 1.1.1.4 mrg /* True if the iterations can be flattened. */
177 1.1.1.4 mrg bool flattened;
178 1.1.1.4 mrg /* Actual array (of elt_sz sized units), aligned to cache line size.
179 1.1.1.4 mrg This is indexed by team_id for GFS_STATIC and outermost iteration
180 1.1.1.4 mrg / chunk_size for other schedules. */
181 1.1.1.4 mrg unsigned char *array;
182 1.1.1.4 mrg /* These two are only used for schedule(static,0). */
183 1.1.1.4 mrg /* This one is number of iterations % number of threads. */
184 1.1.1.4 mrg long t;
185 1.1.1.4 mrg union {
186 1.1.1.4 mrg /* And this one is cached t * (q + 1). */
187 1.1.1.4 mrg long boundary;
188 1.1.1.4 mrg /* Likewise, but for the ull implementation. */
189 1.1.1.4 mrg unsigned long long boundary_ull;
190 1.1.1.4 mrg };
191 1.1.1.9 mrg /* Pointer to extra memory if needed for lastprivate(conditional). */
192 1.1.1.9 mrg void *extra;
193 1.1.1.4 mrg /* Array of shift counts for each dimension if they can be flattened. */
194 1.1.1.4 mrg unsigned int shift_counts[];
195 1.1.1.4 mrg };
196 1.1.1.4 mrg
197 1.1 mrg struct gomp_work_share
198 1.1 mrg {
199 1.1 mrg /* This member records the SCHEDULE clause to be used for this construct.
200 1.1 mrg The user specification of "runtime" will already have been resolved.
201 1.1 mrg If this is a SECTIONS construct, this value will always be DYNAMIC. */
202 1.1 mrg enum gomp_schedule_type sched;
203 1.1 mrg
204 1.1 mrg int mode;
205 1.1 mrg
206 1.1 mrg union {
207 1.1 mrg struct {
208 1.1 mrg /* This is the chunk_size argument to the SCHEDULE clause. */
209 1.1 mrg long chunk_size;
210 1.1 mrg
211 1.1 mrg /* This is the iteration end point. If this is a SECTIONS construct,
212 1.1 mrg this is the number of contained sections. */
213 1.1 mrg long end;
214 1.1 mrg
215 1.1 mrg /* This is the iteration step. If this is a SECTIONS construct, this
216 1.1 mrg is always 1. */
217 1.1 mrg long incr;
218 1.1 mrg };
219 1.1 mrg
220 1.1 mrg struct {
221 1.1 mrg /* The same as above, but for the unsigned long long loop variants. */
222 1.1 mrg unsigned long long chunk_size_ull;
223 1.1 mrg unsigned long long end_ull;
224 1.1 mrg unsigned long long incr_ull;
225 1.1 mrg };
226 1.1 mrg };
227 1.1 mrg
228 1.1.1.4 mrg union {
229 1.1.1.4 mrg /* This is a circular queue that details which threads will be allowed
230 1.1.1.4 mrg into the ordered region and in which order. When a thread allocates
231 1.1.1.4 mrg iterations on which it is going to work, it also registers itself at
232 1.1.1.4 mrg the end of the array. When a thread reaches the ordered region, it
233 1.1.1.4 mrg checks to see if it is the one at the head of the queue. If not, it
234 1.1.1.4 mrg blocks on its RELEASE semaphore. */
235 1.1.1.4 mrg unsigned *ordered_team_ids;
236 1.1.1.4 mrg
237 1.1.1.4 mrg /* This is a pointer to DOACROSS work share data. */
238 1.1.1.4 mrg struct gomp_doacross_work_share *doacross;
239 1.1.1.4 mrg };
240 1.1 mrg
241 1.1 mrg /* This is the number of threads that have registered themselves in
242 1.1 mrg the circular queue ordered_team_ids. */
243 1.1 mrg unsigned ordered_num_used;
244 1.1 mrg
245 1.1 mrg /* This is the team_id of the currently acknowledged owner of the ordered
246 1.1 mrg section, or -1u if the ordered section has not been acknowledged by
247 1.1 mrg any thread. This is distinguished from the thread that is *allowed*
248 1.1 mrg to take the section next. */
249 1.1 mrg unsigned ordered_owner;
250 1.1 mrg
251 1.1 mrg /* This is the index into the circular queue ordered_team_ids of the
252 1.1 mrg current thread that's allowed into the ordered reason. */
253 1.1 mrg unsigned ordered_cur;
254 1.1 mrg
255 1.1 mrg /* This is a chain of allocated gomp_work_share blocks, valid only
256 1.1 mrg in the first gomp_work_share struct in the block. */
257 1.1 mrg struct gomp_work_share *next_alloc;
258 1.1 mrg
259 1.1 mrg /* The above fields are written once during workshare initialization,
260 1.1 mrg or related to ordered worksharing. Make sure the following fields
261 1.1 mrg are in a different cache line. */
262 1.1 mrg
263 1.1 mrg /* This lock protects the update of the following members. */
264 1.1 mrg gomp_mutex_t lock __attribute__((aligned (64)));
265 1.1 mrg
266 1.1 mrg /* This is the count of the number of threads that have exited the work
267 1.1 mrg share construct. If the construct was marked nowait, they have moved on
268 1.1 mrg to other work; otherwise they're blocked on a barrier. The last member
269 1.1 mrg of the team to exit the work share construct must deallocate it. */
270 1.1 mrg unsigned threads_completed;
271 1.1 mrg
272 1.1 mrg union {
273 1.1 mrg /* This is the next iteration value to be allocated. In the case of
274 1.1 mrg GFS_STATIC loops, this the iteration start point and never changes. */
275 1.1 mrg long next;
276 1.1 mrg
277 1.1 mrg /* The same, but with unsigned long long type. */
278 1.1 mrg unsigned long long next_ull;
279 1.1 mrg
280 1.1 mrg /* This is the returned data structure for SINGLE COPYPRIVATE. */
281 1.1 mrg void *copyprivate;
282 1.1 mrg };
283 1.1 mrg
284 1.1 mrg union {
285 1.1 mrg /* Link to gomp_work_share struct for next work sharing construct
286 1.1 mrg encountered after this one. */
287 1.1 mrg gomp_ptrlock_t next_ws;
288 1.1 mrg
289 1.1 mrg /* gomp_work_share structs are chained in the free work share cache
290 1.1 mrg through this. */
291 1.1 mrg struct gomp_work_share *next_free;
292 1.1 mrg };
293 1.1 mrg
294 1.1.1.9 mrg /* Task reductions for this work-sharing construct. */
295 1.1.1.9 mrg uintptr_t *task_reductions;
296 1.1.1.9 mrg
297 1.1 mrg /* If only few threads are in the team, ordered_team_ids can point
298 1.1 mrg to this array which fills the padding at the end of this struct. */
299 1.1 mrg unsigned inline_ordered_team_ids[0];
300 1.1 mrg };
301 1.1 mrg
302 1.1 mrg /* This structure contains all of the thread-local data associated with
303 1.1 mrg a thread team. This is the data that must be saved when a thread
304 1.1 mrg encounters a nested PARALLEL construct. */
305 1.1 mrg
306 1.1 mrg struct gomp_team_state
307 1.1 mrg {
308 1.1 mrg /* This is the team of which the thread is currently a member. */
309 1.1 mrg struct gomp_team *team;
310 1.1 mrg
311 1.1 mrg /* This is the work share construct which this thread is currently
312 1.1 mrg processing. Recall that with NOWAIT, not all threads may be
313 1.1 mrg processing the same construct. */
314 1.1 mrg struct gomp_work_share *work_share;
315 1.1 mrg
316 1.1 mrg /* This is the previous work share construct or NULL if there wasn't any.
317 1.1 mrg When all threads are done with the current work sharing construct,
318 1.1 mrg the previous one can be freed. The current one can't, as its
319 1.1 mrg next_ws field is used. */
320 1.1 mrg struct gomp_work_share *last_work_share;
321 1.1 mrg
322 1.1 mrg /* This is the ID of this thread within the team. This value is
323 1.1 mrg guaranteed to be between 0 and N-1, where N is the number of
324 1.1 mrg threads in the team. */
325 1.1 mrg unsigned team_id;
326 1.1 mrg
327 1.1 mrg /* Nesting level. */
328 1.1 mrg unsigned level;
329 1.1 mrg
330 1.1 mrg /* Active nesting level. Only active parallel regions are counted. */
331 1.1 mrg unsigned active_level;
332 1.1 mrg
333 1.1.1.3 mrg /* Place-partition-var, offset and length into gomp_places_list array. */
334 1.1.1.3 mrg unsigned place_partition_off;
335 1.1.1.3 mrg unsigned place_partition_len;
336 1.1.1.3 mrg
337 1.1 mrg #ifdef HAVE_SYNC_BUILTINS
338 1.1 mrg /* Number of single stmts encountered. */
339 1.1 mrg unsigned long single_count;
340 1.1 mrg #endif
341 1.1 mrg
342 1.1 mrg /* For GFS_RUNTIME loops that resolved to GFS_STATIC, this is the
343 1.1 mrg trip number through the loop. So first time a particular loop
344 1.1 mrg is encountered this number is 0, the second time through the loop
345 1.1 mrg is 1, etc. This is unused when the compiler knows in advance that
346 1.1 mrg the loop is statically scheduled. */
347 1.1 mrg unsigned long static_trip;
348 1.1 mrg };
349 1.1 mrg
350 1.1.1.3 mrg struct target_mem_desc;
351 1.1.1.3 mrg
352 1.1.1.3 mrg /* These are the OpenMP 4.0 Internal Control Variables described in
353 1.1 mrg section 2.3.1. Those described as having one copy per task are
354 1.1 mrg stored within the structure; those described as having one copy
355 1.1 mrg for the whole program are (naturally) global variables. */
356 1.1.1.3 mrg
357 1.1 mrg struct gomp_task_icv
358 1.1 mrg {
359 1.1 mrg unsigned long nthreads_var;
360 1.1 mrg enum gomp_schedule_type run_sched_var;
361 1.1.1.4 mrg int run_sched_chunk_size;
362 1.1.1.3 mrg int default_device_var;
363 1.1.1.3 mrg unsigned int thread_limit_var;
364 1.1 mrg bool dyn_var;
365 1.1 mrg bool nest_var;
366 1.1.1.3 mrg char bind_var;
367 1.1.1.3 mrg /* Internal ICV. */
368 1.1.1.3 mrg struct target_mem_desc *target_data;
369 1.1 mrg };
370 1.1 mrg
371 1.1 mrg extern struct gomp_task_icv gomp_global_icv;
372 1.1 mrg #ifndef HAVE_SYNC_BUILTINS
373 1.1.1.3 mrg extern gomp_mutex_t gomp_managed_threads_lock;
374 1.1 mrg #endif
375 1.1 mrg extern unsigned long gomp_max_active_levels_var;
376 1.1.1.3 mrg extern bool gomp_cancel_var;
377 1.1.1.4 mrg extern int gomp_max_task_priority_var;
378 1.1 mrg extern unsigned long long gomp_spin_count_var, gomp_throttled_spin_count_var;
379 1.1 mrg extern unsigned long gomp_available_cpus, gomp_managed_threads;
380 1.1.1.2 mrg extern unsigned long *gomp_nthreads_var_list, gomp_nthreads_var_list_len;
381 1.1.1.3 mrg extern char *gomp_bind_var_list;
382 1.1.1.3 mrg extern unsigned long gomp_bind_var_list_len;
383 1.1.1.3 mrg extern void **gomp_places_list;
384 1.1.1.3 mrg extern unsigned long gomp_places_list_len;
385 1.1.1.5 mrg extern unsigned int gomp_num_teams_var;
386 1.1.1.3 mrg extern int gomp_debug_var;
387 1.1.1.9 mrg extern bool gomp_display_affinity_var;
388 1.1.1.9 mrg extern char *gomp_affinity_format_var;
389 1.1.1.9 mrg extern size_t gomp_affinity_format_len;
390 1.1.1.3 mrg extern int goacc_device_num;
391 1.1.1.3 mrg extern char *goacc_device_type;
392 1.1.1.9 mrg extern int goacc_default_dims[GOMP_DIM_MAX];
393 1.1 mrg
394 1.1 mrg enum gomp_task_kind
395 1.1 mrg {
396 1.1.1.4 mrg /* Implicit task. */
397 1.1 mrg GOMP_TASK_IMPLICIT,
398 1.1.1.4 mrg /* Undeferred task. */
399 1.1.1.4 mrg GOMP_TASK_UNDEFERRED,
400 1.1.1.4 mrg /* Task created by GOMP_task and waiting to be run. */
401 1.1 mrg GOMP_TASK_WAITING,
402 1.1.1.4 mrg /* Task currently executing or scheduled and about to execute. */
403 1.1.1.4 mrg GOMP_TASK_TIED,
404 1.1.1.4 mrg /* Used for target tasks that have vars mapped and async run started,
405 1.1.1.4 mrg but not yet completed. Once that completes, they will be readded
406 1.1.1.4 mrg into the queues as GOMP_TASK_WAITING in order to perform the var
407 1.1.1.4 mrg unmapping. */
408 1.1.1.4 mrg GOMP_TASK_ASYNC_RUNNING
409 1.1 mrg };
410 1.1 mrg
411 1.1.1.3 mrg struct gomp_task_depend_entry
412 1.1.1.3 mrg {
413 1.1.1.4 mrg /* Address of dependency. */
414 1.1.1.3 mrg void *addr;
415 1.1.1.3 mrg struct gomp_task_depend_entry *next;
416 1.1.1.3 mrg struct gomp_task_depend_entry *prev;
417 1.1.1.4 mrg /* Task that provides the dependency in ADDR. */
418 1.1.1.3 mrg struct gomp_task *task;
419 1.1.1.4 mrg /* Depend entry is of type "IN". */
420 1.1.1.3 mrg bool is_in;
421 1.1.1.3 mrg bool redundant;
422 1.1.1.3 mrg bool redundant_out;
423 1.1.1.3 mrg };
424 1.1.1.3 mrg
425 1.1.1.3 mrg struct gomp_dependers_vec
426 1.1.1.3 mrg {
427 1.1.1.3 mrg size_t n_elem;
428 1.1.1.3 mrg size_t allocated;
429 1.1.1.3 mrg struct gomp_task *elem[];
430 1.1.1.3 mrg };
431 1.1.1.3 mrg
432 1.1.1.3 mrg /* Used when in GOMP_taskwait or in gomp_task_maybe_wait_for_dependencies. */
433 1.1.1.3 mrg
434 1.1.1.3 mrg struct gomp_taskwait
435 1.1.1.3 mrg {
436 1.1.1.3 mrg bool in_taskwait;
437 1.1.1.3 mrg bool in_depend_wait;
438 1.1.1.4 mrg /* Number of tasks we are waiting for. */
439 1.1.1.3 mrg size_t n_depend;
440 1.1.1.3 mrg gomp_sem_t taskwait_sem;
441 1.1.1.3 mrg };
442 1.1.1.3 mrg
443 1.1 mrg /* This structure describes a "task" to be run by a thread. */
444 1.1 mrg
445 1.1 mrg struct gomp_task
446 1.1 mrg {
447 1.1.1.4 mrg /* Parent of this task. */
448 1.1 mrg struct gomp_task *parent;
449 1.1.1.4 mrg /* Children of this task. */
450 1.1.1.4 mrg struct priority_queue children_queue;
451 1.1.1.4 mrg /* Taskgroup this task belongs in. */
452 1.1.1.3 mrg struct gomp_taskgroup *taskgroup;
453 1.1.1.4 mrg /* Tasks that depend on this task. */
454 1.1.1.3 mrg struct gomp_dependers_vec *dependers;
455 1.1.1.3 mrg struct htab *depend_hash;
456 1.1.1.3 mrg struct gomp_taskwait *taskwait;
457 1.1.1.4 mrg /* Number of items in DEPEND. */
458 1.1.1.3 mrg size_t depend_count;
459 1.1.1.4 mrg /* Number of tasks this task depends on. Once this counter reaches
460 1.1.1.4 mrg 0, we have no unsatisfied dependencies, and this task can be put
461 1.1.1.4 mrg into the various queues to be scheduled. */
462 1.1.1.3 mrg size_t num_dependees;
463 1.1.1.4 mrg
464 1.1.1.4 mrg /* Priority of this task. */
465 1.1.1.4 mrg int priority;
466 1.1.1.4 mrg /* The priority node for this task in each of the different queues.
467 1.1.1.4 mrg We put this here to avoid allocating space for each priority
468 1.1.1.4 mrg node. Then we play offsetof() games to convert between pnode[]
469 1.1.1.4 mrg entries and the gomp_task in which they reside. */
470 1.1.1.4 mrg struct priority_node pnode[3];
471 1.1.1.4 mrg
472 1.1 mrg struct gomp_task_icv icv;
473 1.1 mrg void (*fn) (void *);
474 1.1 mrg void *fn_data;
475 1.1 mrg enum gomp_task_kind kind;
476 1.1 mrg bool in_tied_task;
477 1.1.1.2 mrg bool final_task;
478 1.1.1.3 mrg bool copy_ctors_done;
479 1.1.1.4 mrg /* Set for undeferred tasks with unsatisfied dependencies which
480 1.1.1.4 mrg block further execution of their parent until the dependencies
481 1.1.1.4 mrg are satisfied. */
482 1.1.1.3 mrg bool parent_depends_on;
483 1.1.1.4 mrg /* Dependencies provided and/or needed for this task. DEPEND_COUNT
484 1.1.1.4 mrg is the number of items available. */
485 1.1.1.3 mrg struct gomp_task_depend_entry depend[];
486 1.1.1.3 mrg };
487 1.1.1.3 mrg
488 1.1.1.4 mrg /* This structure describes a single #pragma omp taskgroup. */
489 1.1.1.4 mrg
490 1.1.1.3 mrg struct gomp_taskgroup
491 1.1.1.3 mrg {
492 1.1.1.3 mrg struct gomp_taskgroup *prev;
493 1.1.1.4 mrg /* Queue of tasks that belong in this taskgroup. */
494 1.1.1.4 mrg struct priority_queue taskgroup_queue;
495 1.1.1.9 mrg uintptr_t *reductions;
496 1.1.1.3 mrg bool in_taskgroup_wait;
497 1.1.1.3 mrg bool cancelled;
498 1.1.1.9 mrg bool workshare;
499 1.1.1.3 mrg gomp_sem_t taskgroup_sem;
500 1.1.1.3 mrg size_t num_children;
501 1.1 mrg };
502 1.1 mrg
503 1.1.1.4 mrg /* Various state of OpenMP async offloading tasks. */
504 1.1.1.4 mrg enum gomp_target_task_state
505 1.1.1.4 mrg {
506 1.1.1.4 mrg GOMP_TARGET_TASK_DATA,
507 1.1.1.4 mrg GOMP_TARGET_TASK_BEFORE_MAP,
508 1.1.1.4 mrg GOMP_TARGET_TASK_FALLBACK,
509 1.1.1.4 mrg GOMP_TARGET_TASK_READY_TO_RUN,
510 1.1.1.4 mrg GOMP_TARGET_TASK_RUNNING,
511 1.1.1.4 mrg GOMP_TARGET_TASK_FINISHED
512 1.1.1.4 mrg };
513 1.1.1.4 mrg
514 1.1.1.4 mrg /* This structure describes a target task. */
515 1.1.1.4 mrg
516 1.1.1.4 mrg struct gomp_target_task
517 1.1.1.4 mrg {
518 1.1.1.4 mrg struct gomp_device_descr *devicep;
519 1.1.1.4 mrg void (*fn) (void *);
520 1.1.1.4 mrg size_t mapnum;
521 1.1.1.4 mrg size_t *sizes;
522 1.1.1.4 mrg unsigned short *kinds;
523 1.1.1.4 mrg unsigned int flags;
524 1.1.1.4 mrg enum gomp_target_task_state state;
525 1.1.1.4 mrg struct target_mem_desc *tgt;
526 1.1.1.4 mrg struct gomp_task *task;
527 1.1.1.4 mrg struct gomp_team *team;
528 1.1.1.4 mrg /* Device-specific target arguments. */
529 1.1.1.4 mrg void **args;
530 1.1.1.4 mrg void *hostaddrs[];
531 1.1.1.4 mrg };
532 1.1.1.4 mrg
533 1.1 mrg /* This structure describes a "team" of threads. These are the threads
534 1.1 mrg that are spawned by a PARALLEL constructs, as well as the work sharing
535 1.1 mrg constructs that the team encounters. */
536 1.1 mrg
537 1.1 mrg struct gomp_team
538 1.1 mrg {
539 1.1 mrg /* This is the number of threads in the current team. */
540 1.1 mrg unsigned nthreads;
541 1.1 mrg
542 1.1 mrg /* This is number of gomp_work_share structs that have been allocated
543 1.1 mrg as a block last time. */
544 1.1 mrg unsigned work_share_chunk;
545 1.1 mrg
546 1.1 mrg /* This is the saved team state that applied to a master thread before
547 1.1 mrg the current thread was created. */
548 1.1 mrg struct gomp_team_state prev_ts;
549 1.1 mrg
550 1.1 mrg /* This semaphore should be used by the master thread instead of its
551 1.1 mrg "native" semaphore in the thread structure. Required for nested
552 1.1 mrg parallels, as the master is a member of two teams. */
553 1.1 mrg gomp_sem_t master_release;
554 1.1 mrg
555 1.1 mrg /* This points to an array with pointers to the release semaphore
556 1.1 mrg of the threads in the team. */
557 1.1 mrg gomp_sem_t **ordered_release;
558 1.1 mrg
559 1.1.1.3 mrg /* List of work shares on which gomp_fini_work_share hasn't been
560 1.1.1.3 mrg called yet. If the team hasn't been cancelled, this should be
561 1.1.1.3 mrg equal to each thr->ts.work_share, but otherwise it can be a possibly
562 1.1.1.3 mrg long list of workshares. */
563 1.1.1.3 mrg struct gomp_work_share *work_shares_to_free;
564 1.1.1.3 mrg
565 1.1 mrg /* List of gomp_work_share structs chained through next_free fields.
566 1.1 mrg This is populated and taken off only by the first thread in the
567 1.1 mrg team encountering a new work sharing construct, in a critical
568 1.1 mrg section. */
569 1.1 mrg struct gomp_work_share *work_share_list_alloc;
570 1.1 mrg
571 1.1 mrg /* List of gomp_work_share structs freed by free_work_share. New
572 1.1 mrg entries are atomically added to the start of the list, and
573 1.1 mrg alloc_work_share can safely only move all but the first entry
574 1.1 mrg to work_share_list alloc, as free_work_share can happen concurrently
575 1.1 mrg with alloc_work_share. */
576 1.1 mrg struct gomp_work_share *work_share_list_free;
577 1.1 mrg
578 1.1 mrg #ifdef HAVE_SYNC_BUILTINS
579 1.1 mrg /* Number of simple single regions encountered by threads in this
580 1.1 mrg team. */
581 1.1 mrg unsigned long single_count;
582 1.1 mrg #else
583 1.1 mrg /* Mutex protecting addition of workshares to work_share_list_free. */
584 1.1 mrg gomp_mutex_t work_share_list_free_lock;
585 1.1 mrg #endif
586 1.1 mrg
587 1.1 mrg /* This barrier is used for most synchronization of the team. */
588 1.1 mrg gomp_barrier_t barrier;
589 1.1 mrg
590 1.1 mrg /* Initial work shares, to avoid allocating any gomp_work_share
591 1.1 mrg structs in the common case. */
592 1.1 mrg struct gomp_work_share work_shares[8];
593 1.1 mrg
594 1.1 mrg gomp_mutex_t task_lock;
595 1.1.1.4 mrg /* Scheduled tasks. */
596 1.1.1.4 mrg struct priority_queue task_queue;
597 1.1.1.3 mrg /* Number of all GOMP_TASK_{WAITING,TIED} tasks in the team. */
598 1.1.1.3 mrg unsigned int task_count;
599 1.1.1.3 mrg /* Number of GOMP_TASK_WAITING tasks currently waiting to be scheduled. */
600 1.1.1.3 mrg unsigned int task_queued_count;
601 1.1.1.3 mrg /* Number of GOMP_TASK_{WAITING,TIED} tasks currently running
602 1.1.1.3 mrg directly in gomp_barrier_handle_tasks; tasks spawned
603 1.1.1.3 mrg from e.g. GOMP_taskwait or GOMP_taskgroup_end don't count, even when
604 1.1.1.3 mrg that is called from a task run from gomp_barrier_handle_tasks.
605 1.1.1.3 mrg task_running_count should be always <= team->nthreads,
606 1.1.1.3 mrg and if current task isn't in_tied_task, then it will be
607 1.1.1.3 mrg even < team->nthreads. */
608 1.1.1.3 mrg unsigned int task_running_count;
609 1.1.1.3 mrg int work_share_cancelled;
610 1.1.1.3 mrg int team_cancelled;
611 1.1 mrg
612 1.1 mrg /* This array contains structures for implicit tasks. */
613 1.1 mrg struct gomp_task implicit_task[];
614 1.1 mrg };
615 1.1 mrg
616 1.1 mrg /* This structure contains all data that is private to libgomp and is
617 1.1 mrg allocated per thread. */
618 1.1 mrg
619 1.1 mrg struct gomp_thread
620 1.1 mrg {
621 1.1 mrg /* This is the function that the thread should run upon launch. */
622 1.1 mrg void (*fn) (void *data);
623 1.1 mrg void *data;
624 1.1 mrg
625 1.1 mrg /* This is the current team state for this thread. The ts.team member
626 1.1 mrg is NULL only if the thread is idle. */
627 1.1 mrg struct gomp_team_state ts;
628 1.1 mrg
629 1.1 mrg /* This is the task that the thread is currently executing. */
630 1.1 mrg struct gomp_task *task;
631 1.1 mrg
632 1.1 mrg /* This semaphore is used for ordered loops. */
633 1.1 mrg gomp_sem_t release;
634 1.1 mrg
635 1.1.1.3 mrg /* Place this thread is bound to plus one, or zero if not bound
636 1.1.1.3 mrg to any place. */
637 1.1.1.3 mrg unsigned int place;
638 1.1.1.3 mrg
639 1.1.1.3 mrg /* User pthread thread pool */
640 1.1 mrg struct gomp_thread_pool *thread_pool;
641 1.1.1.9 mrg
642 1.1.1.9 mrg #if defined(LIBGOMP_USE_PTHREADS) \
643 1.1.1.9 mrg && (!defined(HAVE_TLS) \
644 1.1.1.9 mrg || !defined(__GLIBC__) \
645 1.1.1.9 mrg || !defined(USING_INITIAL_EXEC_TLS))
646 1.1.1.9 mrg /* pthread_t of the thread containing this gomp_thread.
647 1.1.1.9 mrg On Linux when using initial-exec TLS,
648 1.1.1.9 mrg (typeof (pthread_t)) gomp_thread () - pthread_self ()
649 1.1.1.9 mrg is constant in all threads, so we can optimize and not
650 1.1.1.9 mrg store it. */
651 1.1.1.9 mrg #define GOMP_NEEDS_THREAD_HANDLE 1
652 1.1.1.9 mrg pthread_t handle;
653 1.1.1.9 mrg #endif
654 1.1 mrg };
655 1.1 mrg
656 1.1 mrg
657 1.1 mrg struct gomp_thread_pool
658 1.1 mrg {
659 1.1 mrg /* This array manages threads spawned from the top level, which will
660 1.1 mrg return to the idle loop once the current PARALLEL construct ends. */
661 1.1 mrg struct gomp_thread **threads;
662 1.1 mrg unsigned threads_size;
663 1.1 mrg unsigned threads_used;
664 1.1.1.4 mrg /* The last team is used for non-nested teams to delay their destruction to
665 1.1.1.4 mrg make sure all the threads in the team move on to the pool's barrier before
666 1.1.1.4 mrg the team's barrier is destroyed. */
667 1.1 mrg struct gomp_team *last_team;
668 1.1.1.3 mrg /* Number of threads running in this contention group. */
669 1.1.1.3 mrg unsigned long threads_busy;
670 1.1 mrg
671 1.1.1.5 mrg /* This barrier holds and releases threads waiting in thread pools. */
672 1.1.1.5 mrg gomp_simple_barrier_t threads_dock;
673 1.1 mrg };
674 1.1 mrg
675 1.1.1.3 mrg enum gomp_cancel_kind
676 1.1.1.3 mrg {
677 1.1.1.3 mrg GOMP_CANCEL_PARALLEL = 1,
678 1.1.1.3 mrg GOMP_CANCEL_LOOP = 2,
679 1.1.1.3 mrg GOMP_CANCEL_FOR = GOMP_CANCEL_LOOP,
680 1.1.1.3 mrg GOMP_CANCEL_DO = GOMP_CANCEL_LOOP,
681 1.1.1.3 mrg GOMP_CANCEL_SECTIONS = 4,
682 1.1.1.3 mrg GOMP_CANCEL_TASKGROUP = 8
683 1.1.1.3 mrg };
684 1.1.1.3 mrg
685 1.1 mrg /* ... and here is that TLS data. */
686 1.1 mrg
687 1.1.1.5 mrg #if defined __nvptx__
688 1.1.1.5 mrg extern struct gomp_thread *nvptx_thrs __attribute__((shared));
689 1.1.1.5 mrg static inline struct gomp_thread *gomp_thread (void)
690 1.1.1.5 mrg {
691 1.1.1.5 mrg int tid;
692 1.1.1.5 mrg asm ("mov.u32 %0, %%tid.y;" : "=r" (tid));
693 1.1.1.5 mrg return nvptx_thrs + tid;
694 1.1.1.5 mrg }
695 1.1.1.5 mrg #elif defined HAVE_TLS || defined USE_EMUTLS
696 1.1 mrg extern __thread struct gomp_thread gomp_tls_data;
697 1.1 mrg static inline struct gomp_thread *gomp_thread (void)
698 1.1 mrg {
699 1.1 mrg return &gomp_tls_data;
700 1.1 mrg }
701 1.1 mrg #else
702 1.1 mrg extern pthread_key_t gomp_tls_key;
703 1.1 mrg static inline struct gomp_thread *gomp_thread (void)
704 1.1 mrg {
705 1.1 mrg return pthread_getspecific (gomp_tls_key);
706 1.1 mrg }
707 1.1 mrg #endif
708 1.1 mrg
709 1.1 mrg extern struct gomp_task_icv *gomp_new_icv (void);
710 1.1 mrg
711 1.1 mrg /* Here's how to access the current copy of the ICVs. */
712 1.1 mrg
713 1.1 mrg static inline struct gomp_task_icv *gomp_icv (bool write)
714 1.1 mrg {
715 1.1 mrg struct gomp_task *task = gomp_thread ()->task;
716 1.1 mrg if (task)
717 1.1 mrg return &task->icv;
718 1.1 mrg else if (write)
719 1.1 mrg return gomp_new_icv ();
720 1.1 mrg else
721 1.1 mrg return &gomp_global_icv;
722 1.1 mrg }
723 1.1 mrg
724 1.1.1.5 mrg #ifdef LIBGOMP_USE_PTHREADS
725 1.1 mrg /* The attributes to be used during thread creation. */
726 1.1 mrg extern pthread_attr_t gomp_thread_attr;
727 1.1 mrg
728 1.1.1.4 mrg extern pthread_key_t gomp_thread_destructor;
729 1.1.1.5 mrg #endif
730 1.1.1.4 mrg
731 1.1 mrg /* Function prototypes. */
732 1.1 mrg
733 1.1 mrg /* affinity.c */
734 1.1 mrg
735 1.1 mrg extern void gomp_init_affinity (void);
736 1.1.1.5 mrg #ifdef LIBGOMP_USE_PTHREADS
737 1.1.1.3 mrg extern void gomp_init_thread_affinity (pthread_attr_t *, unsigned int);
738 1.1.1.5 mrg #endif
739 1.1.1.3 mrg extern void **gomp_affinity_alloc (unsigned long, bool);
740 1.1.1.3 mrg extern void gomp_affinity_init_place (void *);
741 1.1.1.3 mrg extern bool gomp_affinity_add_cpus (void *, unsigned long, unsigned long,
742 1.1.1.3 mrg long, bool);
743 1.1.1.3 mrg extern bool gomp_affinity_remove_cpu (void *, unsigned long);
744 1.1.1.3 mrg extern bool gomp_affinity_copy_place (void *, void *, long);
745 1.1.1.3 mrg extern bool gomp_affinity_same_place (void *, void *);
746 1.1.1.3 mrg extern bool gomp_affinity_finalize_place_list (bool);
747 1.1.1.3 mrg extern bool gomp_affinity_init_level (int, unsigned long, bool);
748 1.1.1.3 mrg extern void gomp_affinity_print_place (void *);
749 1.1.1.4 mrg extern void gomp_get_place_proc_ids_8 (int, int64_t *);
750 1.1.1.9 mrg extern void gomp_display_affinity_place (char *, size_t, size_t *, int);
751 1.1.1.9 mrg
752 1.1.1.9 mrg /* affinity-fmt.c */
753 1.1.1.9 mrg
754 1.1.1.9 mrg extern bool gomp_print_string (const char *str, size_t len);
755 1.1.1.9 mrg extern void gomp_set_affinity_format (const char *, size_t);
756 1.1.1.9 mrg extern void gomp_display_string (char *, size_t, size_t *, const char *,
757 1.1.1.9 mrg size_t);
758 1.1.1.9 mrg #ifdef LIBGOMP_USE_PTHREADS
759 1.1.1.9 mrg typedef pthread_t gomp_thread_handle;
760 1.1.1.9 mrg #else
761 1.1.1.9 mrg typedef struct {} gomp_thread_handle;
762 1.1.1.9 mrg #endif
763 1.1.1.9 mrg extern size_t gomp_display_affinity (char *, size_t, const char *,
764 1.1.1.9 mrg gomp_thread_handle,
765 1.1.1.9 mrg struct gomp_team_state *, unsigned int);
766 1.1.1.9 mrg extern void gomp_display_affinity_thread (gomp_thread_handle,
767 1.1.1.9 mrg struct gomp_team_state *,
768 1.1.1.9 mrg unsigned int) __attribute__((cold));
769 1.1 mrg
770 1.1 mrg /* iter.c */
771 1.1 mrg
772 1.1 mrg extern int gomp_iter_static_next (long *, long *);
773 1.1 mrg extern bool gomp_iter_dynamic_next_locked (long *, long *);
774 1.1 mrg extern bool gomp_iter_guided_next_locked (long *, long *);
775 1.1 mrg
776 1.1 mrg #ifdef HAVE_SYNC_BUILTINS
777 1.1 mrg extern bool gomp_iter_dynamic_next (long *, long *);
778 1.1 mrg extern bool gomp_iter_guided_next (long *, long *);
779 1.1 mrg #endif
780 1.1 mrg
781 1.1 mrg /* iter_ull.c */
782 1.1 mrg
783 1.1 mrg extern int gomp_iter_ull_static_next (unsigned long long *,
784 1.1 mrg unsigned long long *);
785 1.1 mrg extern bool gomp_iter_ull_dynamic_next_locked (unsigned long long *,
786 1.1 mrg unsigned long long *);
787 1.1 mrg extern bool gomp_iter_ull_guided_next_locked (unsigned long long *,
788 1.1 mrg unsigned long long *);
789 1.1 mrg
790 1.1 mrg #if defined HAVE_SYNC_BUILTINS && defined __LP64__
791 1.1 mrg extern bool gomp_iter_ull_dynamic_next (unsigned long long *,
792 1.1 mrg unsigned long long *);
793 1.1 mrg extern bool gomp_iter_ull_guided_next (unsigned long long *,
794 1.1 mrg unsigned long long *);
795 1.1 mrg #endif
796 1.1 mrg
797 1.1 mrg /* ordered.c */
798 1.1 mrg
799 1.1 mrg extern void gomp_ordered_first (void);
800 1.1 mrg extern void gomp_ordered_last (void);
801 1.1 mrg extern void gomp_ordered_next (void);
802 1.1 mrg extern void gomp_ordered_static_init (void);
803 1.1 mrg extern void gomp_ordered_static_next (void);
804 1.1 mrg extern void gomp_ordered_sync (void);
805 1.1.1.9 mrg extern void gomp_doacross_init (unsigned, long *, long, size_t);
806 1.1.1.4 mrg extern void gomp_doacross_ull_init (unsigned, unsigned long long *,
807 1.1.1.9 mrg unsigned long long, size_t);
808 1.1 mrg
809 1.1 mrg /* parallel.c */
810 1.1 mrg
811 1.1 mrg extern unsigned gomp_resolve_num_threads (unsigned, unsigned);
812 1.1 mrg
813 1.1 mrg /* proc.c (in config/) */
814 1.1 mrg
815 1.1 mrg extern void gomp_init_num_threads (void);
816 1.1 mrg extern unsigned gomp_dynamic_max_threads (void);
817 1.1 mrg
818 1.1 mrg /* task.c */
819 1.1 mrg
820 1.1 mrg extern void gomp_init_task (struct gomp_task *, struct gomp_task *,
821 1.1 mrg struct gomp_task_icv *);
822 1.1 mrg extern void gomp_end_task (void);
823 1.1 mrg extern void gomp_barrier_handle_tasks (gomp_barrier_state_t);
824 1.1.1.4 mrg extern void gomp_task_maybe_wait_for_dependencies (void **);
825 1.1.1.4 mrg extern bool gomp_create_target_task (struct gomp_device_descr *,
826 1.1.1.4 mrg void (*) (void *), size_t, void **,
827 1.1.1.4 mrg size_t *, unsigned short *, unsigned int,
828 1.1.1.4 mrg void **, void **,
829 1.1.1.4 mrg enum gomp_target_task_state);
830 1.1.1.9 mrg extern struct gomp_taskgroup *gomp_parallel_reduction_register (uintptr_t *,
831 1.1.1.9 mrg unsigned);
832 1.1.1.9 mrg extern void gomp_workshare_taskgroup_start (void);
833 1.1.1.9 mrg extern void gomp_workshare_task_reduction_register (uintptr_t *, uintptr_t *);
834 1.1 mrg
835 1.1 mrg static void inline
836 1.1 mrg gomp_finish_task (struct gomp_task *task)
837 1.1 mrg {
838 1.1.1.3 mrg if (__builtin_expect (task->depend_hash != NULL, 0))
839 1.1.1.3 mrg free (task->depend_hash);
840 1.1 mrg }
841 1.1 mrg
842 1.1 mrg /* team.c */
843 1.1 mrg
844 1.1 mrg extern struct gomp_team *gomp_new_team (unsigned);
845 1.1 mrg extern void gomp_team_start (void (*) (void *), void *, unsigned,
846 1.1.1.9 mrg unsigned, struct gomp_team *,
847 1.1.1.9 mrg struct gomp_taskgroup *);
848 1.1 mrg extern void gomp_team_end (void);
849 1.1.1.3 mrg extern void gomp_free_thread (void *);
850 1.1.1.9 mrg extern int gomp_pause_host (void);
851 1.1.1.3 mrg
852 1.1.1.3 mrg /* target.c */
853 1.1.1.3 mrg
854 1.1.1.3 mrg extern void gomp_init_targets_once (void);
855 1.1.1.3 mrg extern int gomp_get_num_devices (void);
856 1.1.1.4 mrg extern bool gomp_target_task_fn (void *);
857 1.1.1.3 mrg
858 1.1.1.4 mrg /* Splay tree definitions. */
859 1.1.1.3 mrg typedef struct splay_tree_node_s *splay_tree_node;
860 1.1.1.3 mrg typedef struct splay_tree_s *splay_tree;
861 1.1.1.3 mrg typedef struct splay_tree_key_s *splay_tree_key;
862 1.1.1.3 mrg
863 1.1.1.4 mrg struct target_var_desc {
864 1.1.1.4 mrg /* Splay key. */
865 1.1.1.4 mrg splay_tree_key key;
866 1.1.1.4 mrg /* True if data should be copied from device to host at the end. */
867 1.1.1.4 mrg bool copy_from;
868 1.1.1.4 mrg /* True if data always should be copied from device to host at the end. */
869 1.1.1.4 mrg bool always_copy_from;
870 1.1.1.4 mrg /* Relative offset against key host_start. */
871 1.1.1.4 mrg uintptr_t offset;
872 1.1.1.4 mrg /* Actual length. */
873 1.1.1.4 mrg uintptr_t length;
874 1.1.1.4 mrg };
875 1.1.1.4 mrg
876 1.1.1.3 mrg struct target_mem_desc {
877 1.1.1.3 mrg /* Reference count. */
878 1.1.1.3 mrg uintptr_t refcount;
879 1.1.1.3 mrg /* All the splay nodes allocated together. */
880 1.1.1.3 mrg splay_tree_node array;
881 1.1.1.3 mrg /* Start of the target region. */
882 1.1.1.3 mrg uintptr_t tgt_start;
883 1.1.1.3 mrg /* End of the targer region. */
884 1.1.1.3 mrg uintptr_t tgt_end;
885 1.1.1.3 mrg /* Handle to free. */
886 1.1.1.3 mrg void *to_free;
887 1.1.1.3 mrg /* Previous target_mem_desc. */
888 1.1.1.3 mrg struct target_mem_desc *prev;
889 1.1.1.3 mrg /* Number of items in following list. */
890 1.1.1.3 mrg size_t list_count;
891 1.1.1.3 mrg
892 1.1.1.3 mrg /* Corresponding target device descriptor. */
893 1.1.1.3 mrg struct gomp_device_descr *device_descr;
894 1.1.1.3 mrg
895 1.1.1.4 mrg /* List of target items to remove (or decrease refcount)
896 1.1.1.3 mrg at the end of region. */
897 1.1.1.4 mrg struct target_var_desc list[];
898 1.1.1.3 mrg };
899 1.1.1.3 mrg
900 1.1.1.4 mrg /* Special value for refcount - infinity. */
901 1.1.1.4 mrg #define REFCOUNT_INFINITY (~(uintptr_t) 0)
902 1.1.1.4 mrg /* Special value for refcount - tgt_offset contains target address of the
903 1.1.1.4 mrg artificial pointer to "omp declare target link" object. */
904 1.1.1.4 mrg #define REFCOUNT_LINK (~(uintptr_t) 1)
905 1.1.1.4 mrg
906 1.1.1.3 mrg struct splay_tree_key_s {
907 1.1.1.3 mrg /* Address of the host object. */
908 1.1.1.3 mrg uintptr_t host_start;
909 1.1.1.3 mrg /* Address immediately after the host object. */
910 1.1.1.3 mrg uintptr_t host_end;
911 1.1.1.3 mrg /* Descriptor of the target memory. */
912 1.1.1.3 mrg struct target_mem_desc *tgt;
913 1.1.1.3 mrg /* Offset from tgt->tgt_start to the start of the target object. */
914 1.1.1.3 mrg uintptr_t tgt_offset;
915 1.1.1.3 mrg /* Reference count. */
916 1.1.1.3 mrg uintptr_t refcount;
917 1.1.1.9 mrg /* Dynamic reference count. */
918 1.1.1.9 mrg uintptr_t dynamic_refcount;
919 1.1.1.4 mrg /* Pointer to the original mapping of "omp declare target link" object. */
920 1.1.1.4 mrg splay_tree_key link_key;
921 1.1.1.3 mrg };
922 1.1.1.3 mrg
923 1.1.1.4 mrg /* The comparison function. */
924 1.1.1.4 mrg
925 1.1.1.4 mrg static inline int
926 1.1.1.4 mrg splay_compare (splay_tree_key x, splay_tree_key y)
927 1.1.1.4 mrg {
928 1.1.1.4 mrg if (x->host_start == x->host_end
929 1.1.1.4 mrg && y->host_start == y->host_end)
930 1.1.1.4 mrg return 0;
931 1.1.1.4 mrg if (x->host_end <= y->host_start)
932 1.1.1.4 mrg return -1;
933 1.1.1.4 mrg if (x->host_start >= y->host_end)
934 1.1.1.4 mrg return 1;
935 1.1.1.4 mrg return 0;
936 1.1.1.4 mrg }
937 1.1.1.4 mrg
938 1.1.1.3 mrg #include "splay-tree.h"
939 1.1.1.3 mrg
940 1.1.1.3 mrg typedef struct acc_dispatch_t
941 1.1.1.3 mrg {
942 1.1.1.3 mrg /* This is a linked list of data mapped using the
943 1.1.1.3 mrg acc_map_data/acc_unmap_data or "acc enter data"/"acc exit data" pragmas.
944 1.1.1.3 mrg Unlike mapped_data in the goacc_thread struct, unmapping can
945 1.1.1.3 mrg happen out-of-order with respect to mapping. */
946 1.1.1.3 mrg /* This is guarded by the lock in the "outer" struct gomp_device_descr. */
947 1.1.1.3 mrg struct target_mem_desc *data_environ;
948 1.1.1.3 mrg
949 1.1.1.3 mrg /* Execute. */
950 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_exec) *exec_func;
951 1.1.1.3 mrg
952 1.1.1.3 mrg /* Async cleanup callback registration. */
953 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_register_async_cleanup)
954 1.1.1.5 mrg *register_async_cleanup_func;
955 1.1.1.3 mrg
956 1.1.1.3 mrg /* Asynchronous routines. */
957 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_test) *async_test_func;
958 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_test_all) *async_test_all_func;
959 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_wait) *async_wait_func;
960 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_wait_async) *async_wait_async_func;
961 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_wait_all) *async_wait_all_func;
962 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_wait_all_async)
963 1.1.1.5 mrg *async_wait_all_async_func;
964 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_async_set_async) *async_set_async_func;
965 1.1.1.3 mrg
966 1.1.1.3 mrg /* Create/destroy TLS data. */
967 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_create_thread_data) *create_thread_data_func;
968 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_destroy_thread_data)
969 1.1.1.5 mrg *destroy_thread_data_func;
970 1.1.1.3 mrg
971 1.1.1.3 mrg /* NVIDIA target specific routines. */
972 1.1.1.3 mrg struct {
973 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_current_device)
974 1.1.1.5 mrg *get_current_device_func;
975 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_current_context)
976 1.1.1.5 mrg *get_current_context_func;
977 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_stream) *get_stream_func;
978 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_set_stream) *set_stream_func;
979 1.1.1.3 mrg } cuda;
980 1.1.1.3 mrg } acc_dispatch_t;
981 1.1.1.3 mrg
982 1.1.1.4 mrg /* Various state of the accelerator device. */
983 1.1.1.4 mrg enum gomp_device_state
984 1.1.1.4 mrg {
985 1.1.1.4 mrg GOMP_DEVICE_UNINITIALIZED,
986 1.1.1.4 mrg GOMP_DEVICE_INITIALIZED,
987 1.1.1.4 mrg GOMP_DEVICE_FINALIZED
988 1.1.1.4 mrg };
989 1.1.1.4 mrg
990 1.1.1.3 mrg /* This structure describes accelerator device.
991 1.1.1.3 mrg It contains name of the corresponding libgomp plugin, function handlers for
992 1.1.1.3 mrg interaction with the device, ID-number of the device, and information about
993 1.1.1.3 mrg mapped memory. */
994 1.1.1.3 mrg struct gomp_device_descr
995 1.1.1.3 mrg {
996 1.1.1.3 mrg /* Immutable data, which is only set during initialization, and which is not
997 1.1.1.3 mrg guarded by the lock. */
998 1.1.1.3 mrg
999 1.1.1.3 mrg /* The name of the device. */
1000 1.1.1.3 mrg const char *name;
1001 1.1.1.3 mrg
1002 1.1.1.3 mrg /* Capabilities of device (supports OpenACC, OpenMP). */
1003 1.1.1.3 mrg unsigned int capabilities;
1004 1.1.1.3 mrg
1005 1.1.1.3 mrg /* This is the ID number of device among devices of the same type. */
1006 1.1.1.3 mrg int target_id;
1007 1.1.1.3 mrg
1008 1.1.1.3 mrg /* This is the TYPE of device. */
1009 1.1.1.3 mrg enum offload_target_type type;
1010 1.1.1.3 mrg
1011 1.1.1.3 mrg /* Function handlers. */
1012 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_name) *get_name_func;
1013 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_caps) *get_caps_func;
1014 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_type) *get_type_func;
1015 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_num_devices) *get_num_devices_func;
1016 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_init_device) *init_device_func;
1017 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_fini_device) *fini_device_func;
1018 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_version) *version_func;
1019 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_load_image) *load_image_func;
1020 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_unload_image) *unload_image_func;
1021 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_alloc) *alloc_func;
1022 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_free) *free_func;
1023 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_dev2host) *dev2host_func;
1024 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_host2dev) *host2dev_func;
1025 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_dev2dev) *dev2dev_func;
1026 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_can_run) *can_run_func;
1027 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_run) *run_func;
1028 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_async_run) *async_run_func;
1029 1.1.1.3 mrg
1030 1.1.1.3 mrg /* Splay tree containing information about mapped memory regions. */
1031 1.1.1.3 mrg struct splay_tree_s mem_map;
1032 1.1.1.3 mrg
1033 1.1.1.3 mrg /* Mutex for the mutable data. */
1034 1.1.1.3 mrg gomp_mutex_t lock;
1035 1.1.1.3 mrg
1036 1.1.1.4 mrg /* Current state of the device. OpenACC allows to move from INITIALIZED state
1037 1.1.1.4 mrg back to UNINITIALIZED state. OpenMP allows only to move from INITIALIZED
1038 1.1.1.4 mrg to FINALIZED state (at program shutdown). */
1039 1.1.1.4 mrg enum gomp_device_state state;
1040 1.1.1.3 mrg
1041 1.1.1.3 mrg /* OpenACC-specific data and functions. */
1042 1.1.1.3 mrg /* This is mutable because of its mutable data_environ and target_data
1043 1.1.1.3 mrg members. */
1044 1.1.1.3 mrg acc_dispatch_t openacc;
1045 1.1.1.3 mrg };
1046 1.1.1.3 mrg
1047 1.1.1.4 mrg /* Kind of the pragma, for which gomp_map_vars () is called. */
1048 1.1.1.4 mrg enum gomp_map_vars_kind
1049 1.1.1.4 mrg {
1050 1.1.1.4 mrg GOMP_MAP_VARS_OPENACC,
1051 1.1.1.4 mrg GOMP_MAP_VARS_TARGET,
1052 1.1.1.4 mrg GOMP_MAP_VARS_DATA,
1053 1.1.1.4 mrg GOMP_MAP_VARS_ENTER_DATA
1054 1.1.1.4 mrg };
1055 1.1.1.4 mrg
1056 1.1.1.3 mrg extern void gomp_acc_insert_pointer (size_t, void **, size_t *, void *);
1057 1.1.1.9 mrg extern void gomp_acc_remove_pointer (void *, size_t, bool, int, int, int);
1058 1.1.1.9 mrg extern void gomp_acc_declare_allocate (bool, size_t, void **, size_t *,
1059 1.1.1.9 mrg unsigned short *);
1060 1.1.1.3 mrg
1061 1.1.1.3 mrg extern struct target_mem_desc *gomp_map_vars (struct gomp_device_descr *,
1062 1.1.1.3 mrg size_t, void **, void **,
1063 1.1.1.4 mrg size_t *, void *, bool,
1064 1.1.1.4 mrg enum gomp_map_vars_kind);
1065 1.1.1.3 mrg extern void gomp_unmap_vars (struct target_mem_desc *, bool);
1066 1.1.1.3 mrg extern void gomp_init_device (struct gomp_device_descr *);
1067 1.1.1.3 mrg extern void gomp_free_memmap (struct splay_tree_s *);
1068 1.1.1.4 mrg extern void gomp_unload_device (struct gomp_device_descr *);
1069 1.1.1.9 mrg extern bool gomp_remove_var (struct gomp_device_descr *, splay_tree_key);
1070 1.1 mrg
1071 1.1 mrg /* work.c */
1072 1.1 mrg
1073 1.1.1.9 mrg extern void gomp_init_work_share (struct gomp_work_share *, size_t, unsigned);
1074 1.1 mrg extern void gomp_fini_work_share (struct gomp_work_share *);
1075 1.1.1.9 mrg extern bool gomp_work_share_start (size_t);
1076 1.1 mrg extern void gomp_work_share_end (void);
1077 1.1.1.3 mrg extern bool gomp_work_share_end_cancel (void);
1078 1.1 mrg extern void gomp_work_share_end_nowait (void);
1079 1.1 mrg
1080 1.1 mrg static inline void
1081 1.1 mrg gomp_work_share_init_done (void)
1082 1.1 mrg {
1083 1.1 mrg struct gomp_thread *thr = gomp_thread ();
1084 1.1 mrg if (__builtin_expect (thr->ts.last_work_share != NULL, 1))
1085 1.1 mrg gomp_ptrlock_set (&thr->ts.last_work_share->next_ws, thr->ts.work_share);
1086 1.1 mrg }
1087 1.1 mrg
1088 1.1 mrg #ifdef HAVE_ATTRIBUTE_VISIBILITY
1089 1.1 mrg # pragma GCC visibility pop
1090 1.1 mrg #endif
1091 1.1 mrg
1092 1.1 mrg /* Now that we're back to default visibility, include the globals. */
1093 1.1 mrg #include "libgomp_g.h"
1094 1.1 mrg
1095 1.1 mrg /* Include omp.h by parts. */
1096 1.1 mrg #include "omp-lock.h"
1097 1.1 mrg #define _LIBGOMP_OMP_LOCK_DEFINED 1
1098 1.1 mrg #include "omp.h.in"
1099 1.1 mrg
1100 1.1 mrg #if !defined (HAVE_ATTRIBUTE_VISIBILITY) \
1101 1.1 mrg || !defined (HAVE_ATTRIBUTE_ALIAS) \
1102 1.1 mrg || !defined (HAVE_AS_SYMVER_DIRECTIVE) \
1103 1.1.1.2 mrg || !defined (PIC) \
1104 1.1.1.2 mrg || !defined (HAVE_SYMVER_SYMBOL_RENAMING_RUNTIME_SUPPORT)
1105 1.1 mrg # undef LIBGOMP_GNU_SYMBOL_VERSIONING
1106 1.1 mrg #endif
1107 1.1 mrg
1108 1.1 mrg #ifdef LIBGOMP_GNU_SYMBOL_VERSIONING
1109 1.1 mrg extern void gomp_init_lock_30 (omp_lock_t *) __GOMP_NOTHROW;
1110 1.1 mrg extern void gomp_destroy_lock_30 (omp_lock_t *) __GOMP_NOTHROW;
1111 1.1 mrg extern void gomp_set_lock_30 (omp_lock_t *) __GOMP_NOTHROW;
1112 1.1 mrg extern void gomp_unset_lock_30 (omp_lock_t *) __GOMP_NOTHROW;
1113 1.1 mrg extern int gomp_test_lock_30 (omp_lock_t *) __GOMP_NOTHROW;
1114 1.1 mrg extern void gomp_init_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW;
1115 1.1 mrg extern void gomp_destroy_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW;
1116 1.1 mrg extern void gomp_set_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW;
1117 1.1 mrg extern void gomp_unset_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW;
1118 1.1 mrg extern int gomp_test_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW;
1119 1.1 mrg
1120 1.1 mrg extern void gomp_init_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW;
1121 1.1 mrg extern void gomp_destroy_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW;
1122 1.1 mrg extern void gomp_set_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW;
1123 1.1 mrg extern void gomp_unset_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW;
1124 1.1 mrg extern int gomp_test_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW;
1125 1.1 mrg extern void gomp_init_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW;
1126 1.1 mrg extern void gomp_destroy_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW;
1127 1.1 mrg extern void gomp_set_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW;
1128 1.1 mrg extern void gomp_unset_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW;
1129 1.1 mrg extern int gomp_test_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW;
1130 1.1 mrg
1131 1.1 mrg # define omp_lock_symver(fn) \
1132 1.1 mrg __asm (".symver g" #fn "_30, " #fn "@@OMP_3.0"); \
1133 1.1 mrg __asm (".symver g" #fn "_25, " #fn "@OMP_1.0");
1134 1.1 mrg #else
1135 1.1 mrg # define gomp_init_lock_30 omp_init_lock
1136 1.1 mrg # define gomp_destroy_lock_30 omp_destroy_lock
1137 1.1 mrg # define gomp_set_lock_30 omp_set_lock
1138 1.1 mrg # define gomp_unset_lock_30 omp_unset_lock
1139 1.1 mrg # define gomp_test_lock_30 omp_test_lock
1140 1.1 mrg # define gomp_init_nest_lock_30 omp_init_nest_lock
1141 1.1 mrg # define gomp_destroy_nest_lock_30 omp_destroy_nest_lock
1142 1.1 mrg # define gomp_set_nest_lock_30 omp_set_nest_lock
1143 1.1 mrg # define gomp_unset_nest_lock_30 omp_unset_nest_lock
1144 1.1 mrg # define gomp_test_nest_lock_30 omp_test_nest_lock
1145 1.1 mrg #endif
1146 1.1 mrg
1147 1.1 mrg #ifdef HAVE_ATTRIBUTE_VISIBILITY
1148 1.1 mrg # define attribute_hidden __attribute__ ((visibility ("hidden")))
1149 1.1 mrg #else
1150 1.1 mrg # define attribute_hidden
1151 1.1 mrg #endif
1152 1.1 mrg
1153 1.1.1.9 mrg #if __GNUC__ >= 9
1154 1.1.1.9 mrg # define HAVE_ATTRIBUTE_COPY
1155 1.1.1.9 mrg #endif
1156 1.1.1.9 mrg
1157 1.1.1.9 mrg #ifdef HAVE_ATTRIBUTE_COPY
1158 1.1.1.9 mrg # define attribute_copy(arg) __attribute__ ((copy (arg)))
1159 1.1.1.9 mrg #else
1160 1.1.1.9 mrg # define attribute_copy(arg)
1161 1.1.1.9 mrg #endif
1162 1.1.1.9 mrg
1163 1.1 mrg #ifdef HAVE_ATTRIBUTE_ALIAS
1164 1.1.1.8 mrg # define strong_alias(fn, al) \
1165 1.1.1.9 mrg extern __typeof (fn) al __attribute__ ((alias (#fn))) attribute_copy (fn);
1166 1.1.1.8 mrg
1167 1.1.1.3 mrg # define ialias_ulp ialias_str1(__USER_LABEL_PREFIX__)
1168 1.1.1.3 mrg # define ialias_str1(x) ialias_str2(x)
1169 1.1.1.3 mrg # define ialias_str2(x) #x
1170 1.1 mrg # define ialias(fn) \
1171 1.1 mrg extern __typeof (fn) gomp_ialias_##fn \
1172 1.1.1.9 mrg __attribute__ ((alias (#fn))) attribute_hidden attribute_copy (fn);
1173 1.1.1.3 mrg # define ialias_redirect(fn) \
1174 1.1.1.3 mrg extern __typeof (fn) fn __asm__ (ialias_ulp "gomp_ialias_" #fn) attribute_hidden;
1175 1.1.1.3 mrg # define ialias_call(fn) gomp_ialias_ ## fn
1176 1.1 mrg #else
1177 1.1 mrg # define ialias(fn)
1178 1.1.1.3 mrg # define ialias_redirect(fn)
1179 1.1.1.3 mrg # define ialias_call(fn) fn
1180 1.1 mrg #endif
1181 1.1 mrg
1182 1.1.1.4 mrg /* Helper function for priority_node_to_task() and
1183 1.1.1.4 mrg task_to_priority_node().
1184 1.1.1.4 mrg
1185 1.1.1.4 mrg Return the offset from a task to its priority_node entry. The
1186 1.1.1.4 mrg priority_node entry is has a type of TYPE. */
1187 1.1.1.4 mrg
1188 1.1.1.4 mrg static inline size_t
1189 1.1.1.4 mrg priority_queue_offset (enum priority_queue_type type)
1190 1.1.1.4 mrg {
1191 1.1.1.4 mrg return offsetof (struct gomp_task, pnode[(int) type]);
1192 1.1.1.4 mrg }
1193 1.1.1.4 mrg
1194 1.1.1.4 mrg /* Return the task associated with a priority NODE of type TYPE. */
1195 1.1.1.4 mrg
1196 1.1.1.4 mrg static inline struct gomp_task *
1197 1.1.1.4 mrg priority_node_to_task (enum priority_queue_type type,
1198 1.1.1.4 mrg struct priority_node *node)
1199 1.1.1.4 mrg {
1200 1.1.1.4 mrg return (struct gomp_task *) ((char *) node - priority_queue_offset (type));
1201 1.1.1.4 mrg }
1202 1.1.1.4 mrg
1203 1.1.1.4 mrg /* Return the priority node of type TYPE for a given TASK. */
1204 1.1.1.4 mrg
1205 1.1.1.4 mrg static inline struct priority_node *
1206 1.1.1.4 mrg task_to_priority_node (enum priority_queue_type type,
1207 1.1.1.4 mrg struct gomp_task *task)
1208 1.1.1.4 mrg {
1209 1.1.1.4 mrg return (struct priority_node *) ((char *) task
1210 1.1.1.4 mrg + priority_queue_offset (type));
1211 1.1.1.4 mrg }
1212 1.1.1.9 mrg
1213 1.1.1.9 mrg #ifdef LIBGOMP_USE_PTHREADS
1214 1.1.1.9 mrg static inline gomp_thread_handle
1215 1.1.1.9 mrg gomp_thread_self (void)
1216 1.1.1.9 mrg {
1217 1.1.1.9 mrg return pthread_self ();
1218 1.1.1.9 mrg }
1219 1.1.1.9 mrg
1220 1.1.1.9 mrg static inline gomp_thread_handle
1221 1.1.1.9 mrg gomp_thread_to_pthread_t (struct gomp_thread *thr)
1222 1.1.1.9 mrg {
1223 1.1.1.9 mrg struct gomp_thread *this_thr = gomp_thread ();
1224 1.1.1.9 mrg if (thr == this_thr)
1225 1.1.1.9 mrg return pthread_self ();
1226 1.1.1.9 mrg #ifdef GOMP_NEEDS_THREAD_HANDLE
1227 1.1.1.9 mrg return thr->handle;
1228 1.1.1.9 mrg #else
1229 1.1.1.9 mrg /* On Linux with initial-exec TLS, the pthread_t of the thread containing
1230 1.1.1.9 mrg thr can be computed from thr, this_thr and pthread_self (),
1231 1.1.1.9 mrg as the distance between this_thr and pthread_self () is constant. */
1232 1.1.1.9 mrg return pthread_self () + ((uintptr_t) thr - (uintptr_t) this_thr);
1233 1.1.1.9 mrg #endif
1234 1.1.1.9 mrg }
1235 1.1.1.9 mrg #else
1236 1.1.1.9 mrg static inline gomp_thread_handle
1237 1.1.1.9 mrg gomp_thread_self (void)
1238 1.1.1.9 mrg {
1239 1.1.1.9 mrg return (gomp_thread_handle) {};
1240 1.1.1.9 mrg }
1241 1.1.1.9 mrg
1242 1.1.1.9 mrg static inline gomp_thread_handle
1243 1.1.1.9 mrg gomp_thread_to_pthread_t (struct gomp_thread *thr)
1244 1.1.1.9 mrg {
1245 1.1.1.9 mrg (void) thr;
1246 1.1.1.9 mrg return gomp_thread_self ();
1247 1.1.1.9 mrg }
1248 1.1.1.9 mrg #endif
1249 1.1.1.9 mrg
1250 1.1 mrg #endif /* LIBGOMP_H */
1251