1 1.1.1.12 mrg /* Copyright (C) 2005-2024 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.1.10 mrg #include <stdint.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_POSIX_MEMALIGN) \ 91 1.1.1.9 mrg || defined(HAVE_MEMALIGN) 92 1.1.1.9 mrg /* Defined if gomp_aligned_alloc doesn't use fallback version 93 1.1.1.9 mrg and free can be used instead of gomp_aligned_free. */ 94 1.1.1.9 mrg #define GOMP_HAVE_EFFICIENT_ALIGNED_ALLOC 1 95 1.1.1.9 mrg #endif 96 1.1.1.9 mrg 97 1.1.1.11 mrg #if defined(GOMP_HAVE_EFFICIENT_ALIGNED_ALLOC) && !defined(__AMDGCN__) 98 1.1.1.11 mrg #define GOMP_USE_ALIGNED_WORK_SHARES 1 99 1.1.1.11 mrg #endif 100 1.1.1.11 mrg 101 1.1.1.4 mrg extern void *gomp_malloc (size_t) __attribute__((malloc)); 102 1.1.1.4 mrg extern void *gomp_malloc_cleared (size_t) __attribute__((malloc)); 103 1.1.1.4 mrg extern void *gomp_realloc (void *, size_t); 104 1.1.1.9 mrg extern void *gomp_aligned_alloc (size_t, size_t) 105 1.1.1.9 mrg __attribute__((malloc, alloc_size (2))); 106 1.1.1.9 mrg extern void gomp_aligned_free (void *); 107 1.1.1.4 mrg 108 1.1.1.4 mrg /* Avoid conflicting prototypes of alloca() in system headers by using 109 1.1.1.4 mrg GCC's builtin alloca(). */ 110 1.1.1.4 mrg #define gomp_alloca(x) __builtin_alloca(x) 111 1.1.1.4 mrg 112 1.1.1.10 mrg /* Optimized allocators for team-specific data that will die with the team. */ 113 1.1.1.10 mrg 114 1.1.1.10 mrg #ifdef __AMDGCN__ 115 1.1.1.12 mrg #include "libgomp-gcn.h" 116 1.1.1.10 mrg /* The arena is initialized in config/gcn/team.c. */ 117 1.1.1.10 mrg 118 1.1.1.10 mrg static inline void * __attribute__((malloc)) 119 1.1.1.10 mrg team_malloc (size_t size) 120 1.1.1.10 mrg { 121 1.1.1.10 mrg /* 4-byte align the size. */ 122 1.1.1.10 mrg size = (size + 3) & ~3; 123 1.1.1.10 mrg 124 1.1.1.10 mrg /* Allocate directly from the arena. 125 1.1.1.10 mrg The compiler does not support DS atomics, yet. */ 126 1.1.1.10 mrg void *result; 127 1.1.1.10 mrg asm ("ds_add_rtn_u64 %0, %1, %2\n\ts_waitcnt 0" 128 1.1.1.10 mrg : "=v"(result) : "v"(TEAM_ARENA_FREE), "v"(size), "e"(1L) : "memory"); 129 1.1.1.10 mrg 130 1.1.1.10 mrg /* Handle OOM. */ 131 1.1.1.10 mrg if (result + size > *(void * __lds *)TEAM_ARENA_END) 132 1.1.1.10 mrg { 133 1.1.1.10 mrg /* While this is experimental, let's make sure we know when OOM 134 1.1.1.10 mrg happens. */ 135 1.1.1.12 mrg const char msg[] = "GCN team arena exhausted;" 136 1.1.1.12 mrg " configure with GCN_TEAM_ARENA_SIZE=bytes\n"; 137 1.1.1.10 mrg write (2, msg, sizeof(msg)-1); 138 1.1.1.10 mrg 139 1.1.1.10 mrg /* Fall back to using the heap (slowly). */ 140 1.1.1.10 mrg result = gomp_malloc (size); 141 1.1.1.10 mrg } 142 1.1.1.10 mrg return result; 143 1.1.1.10 mrg } 144 1.1.1.10 mrg 145 1.1.1.10 mrg static inline void * __attribute__((malloc)) 146 1.1.1.10 mrg team_malloc_cleared (size_t size) 147 1.1.1.10 mrg { 148 1.1.1.10 mrg char *result = team_malloc (size); 149 1.1.1.10 mrg 150 1.1.1.10 mrg /* Clear the allocated memory. */ 151 1.1.1.10 mrg __builtin_memset (result, 0, size); 152 1.1.1.10 mrg 153 1.1.1.10 mrg return result; 154 1.1.1.10 mrg } 155 1.1.1.10 mrg 156 1.1.1.10 mrg static inline void 157 1.1.1.10 mrg team_free (void *ptr) 158 1.1.1.10 mrg { 159 1.1.1.10 mrg /* The whole arena is freed when the kernel exits. 160 1.1.1.10 mrg However, if we fell back to using heap then we should free it. 161 1.1.1.10 mrg It would be better if this function could be a no-op, but at least 162 1.1.1.10 mrg LDS loads are cheap. */ 163 1.1.1.10 mrg if (ptr < *(void * __lds *)TEAM_ARENA_START 164 1.1.1.10 mrg || ptr >= *(void * __lds *)TEAM_ARENA_END) 165 1.1.1.10 mrg free (ptr); 166 1.1.1.10 mrg } 167 1.1.1.10 mrg #else 168 1.1.1.10 mrg #define team_malloc(...) gomp_malloc (__VA_ARGS__) 169 1.1.1.10 mrg #define team_malloc_cleared(...) gomp_malloc_cleared (__VA_ARGS__) 170 1.1.1.10 mrg #define team_free(...) free (__VA_ARGS__) 171 1.1.1.10 mrg #endif 172 1.1.1.10 mrg 173 1.1.1.4 mrg /* error.c */ 174 1.1.1.4 mrg 175 1.1.1.4 mrg extern void gomp_vdebug (int, const char *, va_list); 176 1.1.1.4 mrg extern void gomp_debug (int, const char *, ...) 177 1.1.1.4 mrg __attribute__ ((format (printf, 2, 3))); 178 1.1.1.4 mrg #define gomp_vdebug(KIND, FMT, VALIST) \ 179 1.1.1.4 mrg do { \ 180 1.1.1.4 mrg if (__builtin_expect (gomp_debug_var, 0)) \ 181 1.1.1.4 mrg (gomp_vdebug) ((KIND), (FMT), (VALIST)); \ 182 1.1.1.4 mrg } while (0) 183 1.1.1.4 mrg #define gomp_debug(KIND, ...) \ 184 1.1.1.4 mrg do { \ 185 1.1.1.4 mrg if (__builtin_expect (gomp_debug_var, 0)) \ 186 1.1.1.4 mrg (gomp_debug) ((KIND), __VA_ARGS__); \ 187 1.1.1.4 mrg } while (0) 188 1.1.1.4 mrg extern void gomp_verror (const char *, va_list); 189 1.1.1.4 mrg extern void gomp_error (const char *, ...) 190 1.1.1.4 mrg __attribute__ ((format (printf, 1, 2))); 191 1.1.1.4 mrg extern void gomp_vfatal (const char *, va_list) 192 1.1.1.4 mrg __attribute__ ((noreturn)); 193 1.1.1.4 mrg extern void gomp_fatal (const char *, ...) 194 1.1.1.4 mrg __attribute__ ((noreturn, format (printf, 1, 2))); 195 1.1.1.4 mrg 196 1.1.1.4 mrg struct gomp_task; 197 1.1.1.4 mrg struct gomp_taskgroup; 198 1.1.1.4 mrg struct htab; 199 1.1.1.4 mrg 200 1.1.1.4 mrg #include "priority_queue.h" 201 1.1 mrg #include "sem.h" 202 1.1 mrg #include "mutex.h" 203 1.1 mrg #include "bar.h" 204 1.1.1.5 mrg #include "simple-bar.h" 205 1.1 mrg #include "ptrlock.h" 206 1.1 mrg 207 1.1 mrg 208 1.1 mrg /* This structure contains the data to control one work-sharing construct, 209 1.1 mrg either a LOOP (FOR/DO) or a SECTIONS. */ 210 1.1 mrg 211 1.1 mrg enum gomp_schedule_type 212 1.1 mrg { 213 1.1 mrg GFS_RUNTIME, 214 1.1 mrg GFS_STATIC, 215 1.1 mrg GFS_DYNAMIC, 216 1.1 mrg GFS_GUIDED, 217 1.1.1.9 mrg GFS_AUTO, 218 1.1.1.9 mrg GFS_MONOTONIC = 0x80000000U 219 1.1 mrg }; 220 1.1 mrg 221 1.1.1.4 mrg struct gomp_doacross_work_share 222 1.1.1.4 mrg { 223 1.1.1.4 mrg union { 224 1.1.1.4 mrg /* chunk_size copy, as ws->chunk_size is multiplied by incr for 225 1.1.1.4 mrg GFS_DYNAMIC. */ 226 1.1.1.4 mrg long chunk_size; 227 1.1.1.4 mrg /* Likewise, but for ull implementation. */ 228 1.1.1.4 mrg unsigned long long chunk_size_ull; 229 1.1.1.4 mrg /* For schedule(static,0) this is the number 230 1.1.1.4 mrg of iterations assigned to the last thread, i.e. number of 231 1.1.1.4 mrg iterations / number of threads. */ 232 1.1.1.4 mrg long q; 233 1.1.1.4 mrg /* Likewise, but for ull implementation. */ 234 1.1.1.4 mrg unsigned long long q_ull; 235 1.1.1.4 mrg }; 236 1.1.1.4 mrg /* Size of each array entry (padded to cache line size). */ 237 1.1.1.4 mrg unsigned long elt_sz; 238 1.1.1.4 mrg /* Number of dimensions in sink vectors. */ 239 1.1.1.4 mrg unsigned int ncounts; 240 1.1.1.4 mrg /* True if the iterations can be flattened. */ 241 1.1.1.4 mrg bool flattened; 242 1.1.1.4 mrg /* Actual array (of elt_sz sized units), aligned to cache line size. 243 1.1.1.4 mrg This is indexed by team_id for GFS_STATIC and outermost iteration 244 1.1.1.4 mrg / chunk_size for other schedules. */ 245 1.1.1.4 mrg unsigned char *array; 246 1.1.1.4 mrg /* These two are only used for schedule(static,0). */ 247 1.1.1.4 mrg /* This one is number of iterations % number of threads. */ 248 1.1.1.4 mrg long t; 249 1.1.1.4 mrg union { 250 1.1.1.4 mrg /* And this one is cached t * (q + 1). */ 251 1.1.1.4 mrg long boundary; 252 1.1.1.4 mrg /* Likewise, but for the ull implementation. */ 253 1.1.1.4 mrg unsigned long long boundary_ull; 254 1.1.1.4 mrg }; 255 1.1.1.9 mrg /* Pointer to extra memory if needed for lastprivate(conditional). */ 256 1.1.1.9 mrg void *extra; 257 1.1.1.4 mrg /* Array of shift counts for each dimension if they can be flattened. */ 258 1.1.1.4 mrg unsigned int shift_counts[]; 259 1.1.1.4 mrg }; 260 1.1.1.4 mrg 261 1.1.1.11 mrg /* Like struct gomp_work_share, but only the 1st cacheline of it plus 262 1.1.1.11 mrg flexible array at the end. 263 1.1.1.11 mrg Keep in sync with struct gomp_work_share. */ 264 1.1.1.11 mrg struct gomp_work_share_1st_cacheline 265 1.1.1.11 mrg { 266 1.1.1.11 mrg enum gomp_schedule_type sched; 267 1.1.1.11 mrg int mode; 268 1.1.1.11 mrg union { 269 1.1.1.11 mrg struct { 270 1.1.1.11 mrg long chunk_size, end, incr; 271 1.1.1.11 mrg }; 272 1.1.1.11 mrg struct { 273 1.1.1.11 mrg unsigned long long chunk_size_ull, end_ull, incr_ull; 274 1.1.1.11 mrg }; 275 1.1.1.11 mrg }; 276 1.1.1.11 mrg union { 277 1.1.1.11 mrg unsigned *ordered_team_ids; 278 1.1.1.11 mrg struct gomp_doacross_work_share *doacross; 279 1.1.1.11 mrg }; 280 1.1.1.11 mrg unsigned ordered_num_used, ordered_owner, ordered_cur; 281 1.1.1.11 mrg struct gomp_work_share *next_alloc; 282 1.1.1.11 mrg char pad[]; 283 1.1.1.11 mrg }; 284 1.1.1.11 mrg 285 1.1 mrg struct gomp_work_share 286 1.1 mrg { 287 1.1 mrg /* This member records the SCHEDULE clause to be used for this construct. 288 1.1 mrg The user specification of "runtime" will already have been resolved. 289 1.1 mrg If this is a SECTIONS construct, this value will always be DYNAMIC. */ 290 1.1 mrg enum gomp_schedule_type sched; 291 1.1 mrg 292 1.1 mrg int mode; 293 1.1 mrg 294 1.1 mrg union { 295 1.1 mrg struct { 296 1.1 mrg /* This is the chunk_size argument to the SCHEDULE clause. */ 297 1.1 mrg long chunk_size; 298 1.1 mrg 299 1.1 mrg /* This is the iteration end point. If this is a SECTIONS construct, 300 1.1 mrg this is the number of contained sections. */ 301 1.1 mrg long end; 302 1.1 mrg 303 1.1 mrg /* This is the iteration step. If this is a SECTIONS construct, this 304 1.1 mrg is always 1. */ 305 1.1 mrg long incr; 306 1.1 mrg }; 307 1.1 mrg 308 1.1 mrg struct { 309 1.1 mrg /* The same as above, but for the unsigned long long loop variants. */ 310 1.1 mrg unsigned long long chunk_size_ull; 311 1.1 mrg unsigned long long end_ull; 312 1.1 mrg unsigned long long incr_ull; 313 1.1 mrg }; 314 1.1 mrg }; 315 1.1 mrg 316 1.1.1.4 mrg union { 317 1.1.1.4 mrg /* This is a circular queue that details which threads will be allowed 318 1.1.1.4 mrg into the ordered region and in which order. When a thread allocates 319 1.1.1.4 mrg iterations on which it is going to work, it also registers itself at 320 1.1.1.4 mrg the end of the array. When a thread reaches the ordered region, it 321 1.1.1.4 mrg checks to see if it is the one at the head of the queue. If not, it 322 1.1.1.4 mrg blocks on its RELEASE semaphore. */ 323 1.1.1.4 mrg unsigned *ordered_team_ids; 324 1.1.1.4 mrg 325 1.1.1.4 mrg /* This is a pointer to DOACROSS work share data. */ 326 1.1.1.4 mrg struct gomp_doacross_work_share *doacross; 327 1.1.1.4 mrg }; 328 1.1 mrg 329 1.1 mrg /* This is the number of threads that have registered themselves in 330 1.1 mrg the circular queue ordered_team_ids. */ 331 1.1 mrg unsigned ordered_num_used; 332 1.1 mrg 333 1.1 mrg /* This is the team_id of the currently acknowledged owner of the ordered 334 1.1 mrg section, or -1u if the ordered section has not been acknowledged by 335 1.1 mrg any thread. This is distinguished from the thread that is *allowed* 336 1.1 mrg to take the section next. */ 337 1.1 mrg unsigned ordered_owner; 338 1.1 mrg 339 1.1 mrg /* This is the index into the circular queue ordered_team_ids of the 340 1.1 mrg current thread that's allowed into the ordered reason. */ 341 1.1 mrg unsigned ordered_cur; 342 1.1 mrg 343 1.1 mrg /* This is a chain of allocated gomp_work_share blocks, valid only 344 1.1 mrg in the first gomp_work_share struct in the block. */ 345 1.1 mrg struct gomp_work_share *next_alloc; 346 1.1 mrg 347 1.1 mrg /* The above fields are written once during workshare initialization, 348 1.1 mrg or related to ordered worksharing. Make sure the following fields 349 1.1 mrg are in a different cache line. */ 350 1.1 mrg 351 1.1 mrg /* This lock protects the update of the following members. */ 352 1.1.1.11 mrg #ifdef GOMP_USE_ALIGNED_WORK_SHARES 353 1.1 mrg gomp_mutex_t lock __attribute__((aligned (64))); 354 1.1.1.11 mrg #else 355 1.1.1.11 mrg char pad[64 - offsetof (struct gomp_work_share_1st_cacheline, pad)]; 356 1.1.1.11 mrg gomp_mutex_t lock; 357 1.1.1.11 mrg #endif 358 1.1 mrg 359 1.1 mrg /* This is the count of the number of threads that have exited the work 360 1.1 mrg share construct. If the construct was marked nowait, they have moved on 361 1.1 mrg to other work; otherwise they're blocked on a barrier. The last member 362 1.1 mrg of the team to exit the work share construct must deallocate it. */ 363 1.1 mrg unsigned threads_completed; 364 1.1 mrg 365 1.1 mrg union { 366 1.1 mrg /* This is the next iteration value to be allocated. In the case of 367 1.1 mrg GFS_STATIC loops, this the iteration start point and never changes. */ 368 1.1 mrg long next; 369 1.1 mrg 370 1.1 mrg /* The same, but with unsigned long long type. */ 371 1.1 mrg unsigned long long next_ull; 372 1.1 mrg 373 1.1 mrg /* This is the returned data structure for SINGLE COPYPRIVATE. */ 374 1.1 mrg void *copyprivate; 375 1.1 mrg }; 376 1.1 mrg 377 1.1 mrg union { 378 1.1 mrg /* Link to gomp_work_share struct for next work sharing construct 379 1.1 mrg encountered after this one. */ 380 1.1 mrg gomp_ptrlock_t next_ws; 381 1.1 mrg 382 1.1 mrg /* gomp_work_share structs are chained in the free work share cache 383 1.1 mrg through this. */ 384 1.1 mrg struct gomp_work_share *next_free; 385 1.1 mrg }; 386 1.1 mrg 387 1.1.1.9 mrg /* Task reductions for this work-sharing construct. */ 388 1.1.1.9 mrg uintptr_t *task_reductions; 389 1.1.1.9 mrg 390 1.1 mrg /* If only few threads are in the team, ordered_team_ids can point 391 1.1 mrg to this array which fills the padding at the end of this struct. */ 392 1.1 mrg unsigned inline_ordered_team_ids[0]; 393 1.1 mrg }; 394 1.1 mrg 395 1.1.1.11 mrg extern char gomp_workshare_struct_check1 396 1.1.1.11 mrg [offsetof (struct gomp_work_share_1st_cacheline, next_alloc) 397 1.1.1.11 mrg == offsetof (struct gomp_work_share, next_alloc) ? 1 : -1]; 398 1.1.1.11 mrg extern char gomp_workshare_struct_check2 399 1.1.1.11 mrg [offsetof (struct gomp_work_share, lock) == 64 ? 1 : -1]; 400 1.1.1.11 mrg 401 1.1 mrg /* This structure contains all of the thread-local data associated with 402 1.1 mrg a thread team. This is the data that must be saved when a thread 403 1.1 mrg encounters a nested PARALLEL construct. */ 404 1.1 mrg 405 1.1 mrg struct gomp_team_state 406 1.1 mrg { 407 1.1 mrg /* This is the team of which the thread is currently a member. */ 408 1.1 mrg struct gomp_team *team; 409 1.1 mrg 410 1.1 mrg /* This is the work share construct which this thread is currently 411 1.1 mrg processing. Recall that with NOWAIT, not all threads may be 412 1.1 mrg processing the same construct. */ 413 1.1 mrg struct gomp_work_share *work_share; 414 1.1 mrg 415 1.1 mrg /* This is the previous work share construct or NULL if there wasn't any. 416 1.1 mrg When all threads are done with the current work sharing construct, 417 1.1 mrg the previous one can be freed. The current one can't, as its 418 1.1 mrg next_ws field is used. */ 419 1.1 mrg struct gomp_work_share *last_work_share; 420 1.1 mrg 421 1.1 mrg /* This is the ID of this thread within the team. This value is 422 1.1 mrg guaranteed to be between 0 and N-1, where N is the number of 423 1.1 mrg threads in the team. */ 424 1.1 mrg unsigned team_id; 425 1.1 mrg 426 1.1 mrg /* Nesting level. */ 427 1.1 mrg unsigned level; 428 1.1 mrg 429 1.1 mrg /* Active nesting level. Only active parallel regions are counted. */ 430 1.1 mrg unsigned active_level; 431 1.1 mrg 432 1.1.1.3 mrg /* Place-partition-var, offset and length into gomp_places_list array. */ 433 1.1.1.3 mrg unsigned place_partition_off; 434 1.1.1.3 mrg unsigned place_partition_len; 435 1.1.1.3 mrg 436 1.1.1.11 mrg /* Def-allocator-var ICV. */ 437 1.1.1.11 mrg uintptr_t def_allocator; 438 1.1.1.11 mrg 439 1.1 mrg #ifdef HAVE_SYNC_BUILTINS 440 1.1 mrg /* Number of single stmts encountered. */ 441 1.1 mrg unsigned long single_count; 442 1.1 mrg #endif 443 1.1 mrg 444 1.1 mrg /* For GFS_RUNTIME loops that resolved to GFS_STATIC, this is the 445 1.1 mrg trip number through the loop. So first time a particular loop 446 1.1 mrg is encountered this number is 0, the second time through the loop 447 1.1 mrg is 1, etc. This is unused when the compiler knows in advance that 448 1.1 mrg the loop is statically scheduled. */ 449 1.1 mrg unsigned long static_trip; 450 1.1 mrg }; 451 1.1 mrg 452 1.1.1.3 mrg struct target_mem_desc; 453 1.1.1.3 mrg 454 1.1.1.12 mrg enum gomp_icvs 455 1.1.1.12 mrg { 456 1.1.1.12 mrg GOMP_ICV_NTEAMS = 1, 457 1.1.1.12 mrg GOMP_ICV_SCHEDULE = 2, 458 1.1.1.12 mrg GOMP_ICV_SCHEDULE_CHUNK_SIZE = 3, 459 1.1.1.12 mrg GOMP_ICV_DYNAMIC = 4, 460 1.1.1.12 mrg GOMP_ICV_TEAMS_THREAD_LIMIT = 5, 461 1.1.1.12 mrg GOMP_ICV_THREAD_LIMIT = 6, 462 1.1.1.12 mrg GOMP_ICV_NTHREADS = 7, 463 1.1.1.12 mrg GOMP_ICV_NTHREADS_LIST = 8, 464 1.1.1.12 mrg GOMP_ICV_NTHREADS_LIST_LEN = 9, 465 1.1.1.12 mrg GOMP_ICV_BIND = 10, 466 1.1.1.12 mrg GOMP_ICV_BIND_LIST = 11, 467 1.1.1.12 mrg GOMP_ICV_BIND_LIST_LEN = 12, 468 1.1.1.12 mrg GOMP_ICV_MAX_ACTIVE_LEVELS = 13, 469 1.1.1.12 mrg GOMP_ICV_WAIT_POLICY = 14, 470 1.1.1.12 mrg GOMP_ICV_STACKSIZE = 15, 471 1.1.1.12 mrg GOMP_ICV_DEFAULT_DEVICE = 16, 472 1.1.1.12 mrg GOMP_ICV_CANCELLATION = 17, 473 1.1.1.12 mrg GOMP_ICV_DISPLAY_AFFINITY = 18, 474 1.1.1.12 mrg GOMP_ICV_TARGET_OFFLOAD = 19, 475 1.1.1.12 mrg GOMP_ICV_MAX_TASK_PRIORITY = 20, 476 1.1.1.12 mrg GOMP_ICV_ALLOCATOR = 21 477 1.1.1.12 mrg }; 478 1.1.1.12 mrg 479 1.1.1.12 mrg enum gomp_device_num 480 1.1.1.12 mrg { 481 1.1.1.12 mrg GOMP_DEVICE_NUM_FOR_DEV = -1, 482 1.1.1.12 mrg GOMP_DEVICE_NUM_FOR_ALL = -2, 483 1.1.1.12 mrg GOMP_DEVICE_NUM_FOR_NO_SUFFIX = -3 484 1.1.1.12 mrg }; 485 1.1.1.12 mrg 486 1.1.1.3 mrg /* These are the OpenMP 4.0 Internal Control Variables described in 487 1.1 mrg section 2.3.1. Those described as having one copy per task are 488 1.1 mrg stored within the structure; those described as having one copy 489 1.1 mrg for the whole program are (naturally) global variables. */ 490 1.1.1.3 mrg 491 1.1 mrg struct gomp_task_icv 492 1.1 mrg { 493 1.1 mrg unsigned long nthreads_var; 494 1.1 mrg enum gomp_schedule_type run_sched_var; 495 1.1.1.4 mrg int run_sched_chunk_size; 496 1.1.1.3 mrg int default_device_var; 497 1.1.1.3 mrg unsigned int thread_limit_var; 498 1.1 mrg bool dyn_var; 499 1.1.1.11 mrg unsigned char max_active_levels_var; 500 1.1.1.3 mrg char bind_var; 501 1.1.1.3 mrg /* Internal ICV. */ 502 1.1.1.3 mrg struct target_mem_desc *target_data; 503 1.1 mrg }; 504 1.1 mrg 505 1.1.1.12 mrg enum gomp_env_suffix 506 1.1.1.12 mrg { 507 1.1.1.12 mrg GOMP_ENV_SUFFIX_UNKNOWN = 0, 508 1.1.1.12 mrg GOMP_ENV_SUFFIX_NONE = 1, 509 1.1.1.12 mrg GOMP_ENV_SUFFIX_DEV = 2, 510 1.1.1.12 mrg GOMP_ENV_SUFFIX_ALL = 4, 511 1.1.1.12 mrg GOMP_ENV_SUFFIX_DEV_X = 8 512 1.1.1.12 mrg }; 513 1.1.1.12 mrg 514 1.1.1.12 mrg /* Struct that contains all ICVs for which we need to store initial values. 515 1.1.1.12 mrg Keeping the initial values is needed for omp_display_env. Moreover initial 516 1.1.1.12 mrg _DEV and _ALL variants of environment variables are also used to determine 517 1.1.1.12 mrg actually used values for devices and for the host. */ 518 1.1.1.12 mrg struct gomp_initial_icvs 519 1.1.1.12 mrg { 520 1.1.1.12 mrg unsigned long *nthreads_var_list; 521 1.1.1.12 mrg char *bind_var_list; 522 1.1.1.12 mrg unsigned long nthreads_var; 523 1.1.1.12 mrg unsigned long nthreads_var_list_len; 524 1.1.1.12 mrg unsigned long bind_var_list_len; 525 1.1.1.12 mrg unsigned long stacksize; 526 1.1.1.12 mrg int run_sched_chunk_size; 527 1.1.1.12 mrg int default_device_var; 528 1.1.1.12 mrg int nteams_var; 529 1.1.1.12 mrg int teams_thread_limit_var; 530 1.1.1.12 mrg int wait_policy; 531 1.1.1.12 mrg unsigned int thread_limit_var; 532 1.1.1.12 mrg enum gomp_schedule_type run_sched_var; 533 1.1.1.12 mrg bool dyn_var; 534 1.1.1.12 mrg unsigned char max_active_levels_var; 535 1.1.1.12 mrg char bind_var; 536 1.1.1.12 mrg }; 537 1.1.1.12 mrg 538 1.1.1.12 mrg struct gomp_default_icv 539 1.1.1.12 mrg { 540 1.1.1.12 mrg unsigned long nthreads_var; 541 1.1.1.12 mrg enum gomp_schedule_type run_sched_var; 542 1.1.1.12 mrg int run_sched_chunk_size; 543 1.1.1.12 mrg int default_device_var; 544 1.1.1.12 mrg unsigned int thread_limit_var; 545 1.1.1.12 mrg int nteams_var; 546 1.1.1.12 mrg int teams_thread_limit_var; 547 1.1.1.12 mrg bool dyn_var; 548 1.1.1.12 mrg unsigned char max_active_levels_var; 549 1.1.1.12 mrg char bind_var; 550 1.1.1.12 mrg }; 551 1.1.1.12 mrg 552 1.1.1.12 mrg /* DEVICE_NUM "-1" is reserved for "_DEV" icvs. 553 1.1.1.12 mrg DEVICE_NUM "-2" is reserved for "_ALL" icvs. 554 1.1.1.12 mrg DEVICE_NUM "-3" is reserved for ICVs without suffix. 555 1.1.1.12 mrg Non-negative DEVICE_NUM is for "_DEV_X" icvs. */ 556 1.1.1.12 mrg struct gomp_icv_list 557 1.1.1.12 mrg { 558 1.1.1.12 mrg int device_num; 559 1.1.1.12 mrg uint32_t flags; 560 1.1.1.12 mrg struct gomp_initial_icvs icvs; 561 1.1.1.12 mrg struct gomp_icv_list *next; 562 1.1.1.12 mrg }; 563 1.1.1.12 mrg 564 1.1.1.12 mrg struct gomp_offload_icvs 565 1.1.1.12 mrg { 566 1.1.1.12 mrg int device_num; 567 1.1.1.12 mrg int default_device; 568 1.1.1.12 mrg int nteams; 569 1.1.1.12 mrg int teams_thread_limit; 570 1.1.1.12 mrg }; 571 1.1.1.12 mrg 572 1.1.1.12 mrg struct gomp_offload_icv_list 573 1.1.1.12 mrg { 574 1.1.1.12 mrg int device_num; 575 1.1.1.12 mrg struct gomp_offload_icvs icvs; 576 1.1.1.12 mrg struct gomp_offload_icv_list *next; 577 1.1.1.12 mrg }; 578 1.1.1.12 mrg 579 1.1.1.11 mrg enum gomp_target_offload_t 580 1.1.1.11 mrg { 581 1.1.1.11 mrg GOMP_TARGET_OFFLOAD_DEFAULT, 582 1.1.1.11 mrg GOMP_TARGET_OFFLOAD_MANDATORY, 583 1.1.1.11 mrg GOMP_TARGET_OFFLOAD_DISABLED 584 1.1.1.11 mrg }; 585 1.1.1.11 mrg 586 1.1.1.11 mrg #define gomp_supported_active_levels UCHAR_MAX 587 1.1.1.11 mrg 588 1.1 mrg extern struct gomp_task_icv gomp_global_icv; 589 1.1 mrg #ifndef HAVE_SYNC_BUILTINS 590 1.1.1.3 mrg extern gomp_mutex_t gomp_managed_threads_lock; 591 1.1 mrg #endif 592 1.1.1.3 mrg extern bool gomp_cancel_var; 593 1.1.1.11 mrg extern enum gomp_target_offload_t gomp_target_offload_var; 594 1.1.1.4 mrg extern int gomp_max_task_priority_var; 595 1.1 mrg extern unsigned long long gomp_spin_count_var, gomp_throttled_spin_count_var; 596 1.1 mrg extern unsigned long gomp_available_cpus, gomp_managed_threads; 597 1.1.1.2 mrg extern unsigned long *gomp_nthreads_var_list, gomp_nthreads_var_list_len; 598 1.1.1.3 mrg extern char *gomp_bind_var_list; 599 1.1.1.3 mrg extern unsigned long gomp_bind_var_list_len; 600 1.1.1.3 mrg extern void **gomp_places_list; 601 1.1.1.3 mrg extern unsigned long gomp_places_list_len; 602 1.1.1.5 mrg extern unsigned int gomp_num_teams_var; 603 1.1.1.11 mrg extern int gomp_nteams_var; 604 1.1.1.11 mrg extern int gomp_teams_thread_limit_var; 605 1.1.1.3 mrg extern int gomp_debug_var; 606 1.1.1.9 mrg extern bool gomp_display_affinity_var; 607 1.1.1.9 mrg extern char *gomp_affinity_format_var; 608 1.1.1.9 mrg extern size_t gomp_affinity_format_len; 609 1.1.1.11 mrg extern uintptr_t gomp_def_allocator; 610 1.1.1.12 mrg extern const struct gomp_default_icv gomp_default_icv_values; 611 1.1.1.12 mrg extern struct gomp_icv_list *gomp_initial_icv_list; 612 1.1.1.12 mrg extern struct gomp_offload_icv_list *gomp_offload_icv_list; 613 1.1.1.3 mrg extern int goacc_device_num; 614 1.1.1.3 mrg extern char *goacc_device_type; 615 1.1.1.9 mrg extern int goacc_default_dims[GOMP_DIM_MAX]; 616 1.1 mrg 617 1.1 mrg enum gomp_task_kind 618 1.1 mrg { 619 1.1.1.4 mrg /* Implicit task. */ 620 1.1 mrg GOMP_TASK_IMPLICIT, 621 1.1.1.4 mrg /* Undeferred task. */ 622 1.1.1.4 mrg GOMP_TASK_UNDEFERRED, 623 1.1.1.4 mrg /* Task created by GOMP_task and waiting to be run. */ 624 1.1 mrg GOMP_TASK_WAITING, 625 1.1.1.4 mrg /* Task currently executing or scheduled and about to execute. */ 626 1.1.1.4 mrg GOMP_TASK_TIED, 627 1.1.1.4 mrg /* Used for target tasks that have vars mapped and async run started, 628 1.1.1.4 mrg but not yet completed. Once that completes, they will be readded 629 1.1.1.4 mrg into the queues as GOMP_TASK_WAITING in order to perform the var 630 1.1.1.4 mrg unmapping. */ 631 1.1.1.11 mrg GOMP_TASK_ASYNC_RUNNING, 632 1.1.1.11 mrg /* Task that has finished executing but is waiting for its 633 1.1.1.11 mrg completion event to be fulfilled. */ 634 1.1.1.11 mrg GOMP_TASK_DETACHED 635 1.1 mrg }; 636 1.1 mrg 637 1.1.1.3 mrg struct gomp_task_depend_entry 638 1.1.1.3 mrg { 639 1.1.1.4 mrg /* Address of dependency. */ 640 1.1.1.3 mrg void *addr; 641 1.1.1.3 mrg struct gomp_task_depend_entry *next; 642 1.1.1.3 mrg struct gomp_task_depend_entry *prev; 643 1.1.1.4 mrg /* Task that provides the dependency in ADDR. */ 644 1.1.1.3 mrg struct gomp_task *task; 645 1.1.1.12 mrg /* Depend entry is of type "IN" (1) or "INOUTSET" (2). */ 646 1.1.1.12 mrg unsigned char is_in; 647 1.1.1.3 mrg bool redundant; 648 1.1.1.3 mrg bool redundant_out; 649 1.1.1.3 mrg }; 650 1.1.1.3 mrg 651 1.1.1.3 mrg struct gomp_dependers_vec 652 1.1.1.3 mrg { 653 1.1.1.3 mrg size_t n_elem; 654 1.1.1.3 mrg size_t allocated; 655 1.1.1.3 mrg struct gomp_task *elem[]; 656 1.1.1.3 mrg }; 657 1.1.1.3 mrg 658 1.1.1.3 mrg /* Used when in GOMP_taskwait or in gomp_task_maybe_wait_for_dependencies. */ 659 1.1.1.3 mrg 660 1.1.1.3 mrg struct gomp_taskwait 661 1.1.1.3 mrg { 662 1.1.1.3 mrg bool in_taskwait; 663 1.1.1.3 mrg bool in_depend_wait; 664 1.1.1.4 mrg /* Number of tasks we are waiting for. */ 665 1.1.1.3 mrg size_t n_depend; 666 1.1.1.3 mrg gomp_sem_t taskwait_sem; 667 1.1.1.3 mrg }; 668 1.1.1.3 mrg 669 1.1 mrg /* This structure describes a "task" to be run by a thread. */ 670 1.1 mrg 671 1.1 mrg struct gomp_task 672 1.1 mrg { 673 1.1.1.4 mrg /* Parent of this task. */ 674 1.1 mrg struct gomp_task *parent; 675 1.1.1.4 mrg /* Children of this task. */ 676 1.1.1.4 mrg struct priority_queue children_queue; 677 1.1.1.4 mrg /* Taskgroup this task belongs in. */ 678 1.1.1.3 mrg struct gomp_taskgroup *taskgroup; 679 1.1.1.4 mrg /* Tasks that depend on this task. */ 680 1.1.1.3 mrg struct gomp_dependers_vec *dependers; 681 1.1.1.3 mrg struct htab *depend_hash; 682 1.1.1.3 mrg struct gomp_taskwait *taskwait; 683 1.1.1.12 mrg /* Last depend({,in}out:omp_all_memory) child if any. */ 684 1.1.1.12 mrg struct gomp_task *depend_all_memory; 685 1.1.1.4 mrg /* Number of items in DEPEND. */ 686 1.1.1.3 mrg size_t depend_count; 687 1.1.1.4 mrg /* Number of tasks this task depends on. Once this counter reaches 688 1.1.1.4 mrg 0, we have no unsatisfied dependencies, and this task can be put 689 1.1.1.4 mrg into the various queues to be scheduled. */ 690 1.1.1.3 mrg size_t num_dependees; 691 1.1.1.4 mrg 692 1.1.1.11 mrg union { 693 1.1.1.11 mrg /* Valid only if deferred_p is false. */ 694 1.1.1.11 mrg gomp_sem_t *completion_sem; 695 1.1.1.11 mrg /* Valid only if deferred_p is true. Set to the team that executes the 696 1.1.1.11 mrg task if the task is detached and the completion event has yet to be 697 1.1.1.11 mrg fulfilled. */ 698 1.1.1.11 mrg struct gomp_team *detach_team; 699 1.1.1.11 mrg }; 700 1.1.1.11 mrg bool deferred_p; 701 1.1.1.11 mrg 702 1.1.1.4 mrg /* Priority of this task. */ 703 1.1.1.4 mrg int priority; 704 1.1.1.4 mrg /* The priority node for this task in each of the different queues. 705 1.1.1.4 mrg We put this here to avoid allocating space for each priority 706 1.1.1.4 mrg node. Then we play offsetof() games to convert between pnode[] 707 1.1.1.4 mrg entries and the gomp_task in which they reside. */ 708 1.1.1.4 mrg struct priority_node pnode[3]; 709 1.1.1.4 mrg 710 1.1 mrg struct gomp_task_icv icv; 711 1.1 mrg void (*fn) (void *); 712 1.1 mrg void *fn_data; 713 1.1 mrg enum gomp_task_kind kind; 714 1.1 mrg bool in_tied_task; 715 1.1.1.2 mrg bool final_task; 716 1.1.1.3 mrg bool copy_ctors_done; 717 1.1.1.4 mrg /* Set for undeferred tasks with unsatisfied dependencies which 718 1.1.1.4 mrg block further execution of their parent until the dependencies 719 1.1.1.4 mrg are satisfied. */ 720 1.1.1.3 mrg bool parent_depends_on; 721 1.1.1.4 mrg /* Dependencies provided and/or needed for this task. DEPEND_COUNT 722 1.1.1.4 mrg is the number of items available. */ 723 1.1.1.3 mrg struct gomp_task_depend_entry depend[]; 724 1.1.1.3 mrg }; 725 1.1.1.3 mrg 726 1.1.1.4 mrg /* This structure describes a single #pragma omp taskgroup. */ 727 1.1.1.4 mrg 728 1.1.1.3 mrg struct gomp_taskgroup 729 1.1.1.3 mrg { 730 1.1.1.3 mrg struct gomp_taskgroup *prev; 731 1.1.1.4 mrg /* Queue of tasks that belong in this taskgroup. */ 732 1.1.1.4 mrg struct priority_queue taskgroup_queue; 733 1.1.1.9 mrg uintptr_t *reductions; 734 1.1.1.3 mrg bool in_taskgroup_wait; 735 1.1.1.3 mrg bool cancelled; 736 1.1.1.9 mrg bool workshare; 737 1.1.1.3 mrg gomp_sem_t taskgroup_sem; 738 1.1.1.3 mrg size_t num_children; 739 1.1 mrg }; 740 1.1 mrg 741 1.1.1.4 mrg /* Various state of OpenMP async offloading tasks. */ 742 1.1.1.4 mrg enum gomp_target_task_state 743 1.1.1.4 mrg { 744 1.1.1.4 mrg GOMP_TARGET_TASK_DATA, 745 1.1.1.4 mrg GOMP_TARGET_TASK_BEFORE_MAP, 746 1.1.1.4 mrg GOMP_TARGET_TASK_FALLBACK, 747 1.1.1.4 mrg GOMP_TARGET_TASK_READY_TO_RUN, 748 1.1.1.4 mrg GOMP_TARGET_TASK_RUNNING, 749 1.1.1.4 mrg GOMP_TARGET_TASK_FINISHED 750 1.1.1.4 mrg }; 751 1.1.1.4 mrg 752 1.1.1.4 mrg /* This structure describes a target task. */ 753 1.1.1.4 mrg 754 1.1.1.4 mrg struct gomp_target_task 755 1.1.1.4 mrg { 756 1.1.1.4 mrg struct gomp_device_descr *devicep; 757 1.1.1.4 mrg void (*fn) (void *); 758 1.1.1.4 mrg size_t mapnum; 759 1.1.1.4 mrg size_t *sizes; 760 1.1.1.4 mrg unsigned short *kinds; 761 1.1.1.4 mrg unsigned int flags; 762 1.1.1.4 mrg enum gomp_target_task_state state; 763 1.1.1.4 mrg struct target_mem_desc *tgt; 764 1.1.1.4 mrg struct gomp_task *task; 765 1.1.1.4 mrg struct gomp_team *team; 766 1.1.1.4 mrg /* Device-specific target arguments. */ 767 1.1.1.4 mrg void **args; 768 1.1.1.4 mrg void *hostaddrs[]; 769 1.1.1.4 mrg }; 770 1.1.1.4 mrg 771 1.1 mrg /* This structure describes a "team" of threads. These are the threads 772 1.1 mrg that are spawned by a PARALLEL constructs, as well as the work sharing 773 1.1 mrg constructs that the team encounters. */ 774 1.1 mrg 775 1.1 mrg struct gomp_team 776 1.1 mrg { 777 1.1 mrg /* This is the number of threads in the current team. */ 778 1.1 mrg unsigned nthreads; 779 1.1 mrg 780 1.1 mrg /* This is number of gomp_work_share structs that have been allocated 781 1.1 mrg as a block last time. */ 782 1.1 mrg unsigned work_share_chunk; 783 1.1 mrg 784 1.1 mrg /* This is the saved team state that applied to a master thread before 785 1.1 mrg the current thread was created. */ 786 1.1 mrg struct gomp_team_state prev_ts; 787 1.1 mrg 788 1.1 mrg /* This semaphore should be used by the master thread instead of its 789 1.1 mrg "native" semaphore in the thread structure. Required for nested 790 1.1 mrg parallels, as the master is a member of two teams. */ 791 1.1 mrg gomp_sem_t master_release; 792 1.1 mrg 793 1.1 mrg /* This points to an array with pointers to the release semaphore 794 1.1 mrg of the threads in the team. */ 795 1.1 mrg gomp_sem_t **ordered_release; 796 1.1 mrg 797 1.1.1.3 mrg /* List of work shares on which gomp_fini_work_share hasn't been 798 1.1.1.3 mrg called yet. If the team hasn't been cancelled, this should be 799 1.1.1.3 mrg equal to each thr->ts.work_share, but otherwise it can be a possibly 800 1.1.1.3 mrg long list of workshares. */ 801 1.1.1.3 mrg struct gomp_work_share *work_shares_to_free; 802 1.1.1.3 mrg 803 1.1 mrg /* List of gomp_work_share structs chained through next_free fields. 804 1.1 mrg This is populated and taken off only by the first thread in the 805 1.1 mrg team encountering a new work sharing construct, in a critical 806 1.1 mrg section. */ 807 1.1 mrg struct gomp_work_share *work_share_list_alloc; 808 1.1 mrg 809 1.1 mrg /* List of gomp_work_share structs freed by free_work_share. New 810 1.1 mrg entries are atomically added to the start of the list, and 811 1.1 mrg alloc_work_share can safely only move all but the first entry 812 1.1 mrg to work_share_list alloc, as free_work_share can happen concurrently 813 1.1 mrg with alloc_work_share. */ 814 1.1 mrg struct gomp_work_share *work_share_list_free; 815 1.1 mrg 816 1.1 mrg #ifdef HAVE_SYNC_BUILTINS 817 1.1 mrg /* Number of simple single regions encountered by threads in this 818 1.1 mrg team. */ 819 1.1 mrg unsigned long single_count; 820 1.1 mrg #else 821 1.1 mrg /* Mutex protecting addition of workshares to work_share_list_free. */ 822 1.1 mrg gomp_mutex_t work_share_list_free_lock; 823 1.1 mrg #endif 824 1.1 mrg 825 1.1 mrg /* This barrier is used for most synchronization of the team. */ 826 1.1 mrg gomp_barrier_t barrier; 827 1.1 mrg 828 1.1 mrg /* Initial work shares, to avoid allocating any gomp_work_share 829 1.1 mrg structs in the common case. */ 830 1.1 mrg struct gomp_work_share work_shares[8]; 831 1.1 mrg 832 1.1 mrg gomp_mutex_t task_lock; 833 1.1.1.4 mrg /* Scheduled tasks. */ 834 1.1.1.4 mrg struct priority_queue task_queue; 835 1.1.1.3 mrg /* Number of all GOMP_TASK_{WAITING,TIED} tasks in the team. */ 836 1.1.1.3 mrg unsigned int task_count; 837 1.1.1.3 mrg /* Number of GOMP_TASK_WAITING tasks currently waiting to be scheduled. */ 838 1.1.1.3 mrg unsigned int task_queued_count; 839 1.1.1.3 mrg /* Number of GOMP_TASK_{WAITING,TIED} tasks currently running 840 1.1.1.3 mrg directly in gomp_barrier_handle_tasks; tasks spawned 841 1.1.1.3 mrg from e.g. GOMP_taskwait or GOMP_taskgroup_end don't count, even when 842 1.1.1.3 mrg that is called from a task run from gomp_barrier_handle_tasks. 843 1.1.1.3 mrg task_running_count should be always <= team->nthreads, 844 1.1.1.3 mrg and if current task isn't in_tied_task, then it will be 845 1.1.1.3 mrg even < team->nthreads. */ 846 1.1.1.3 mrg unsigned int task_running_count; 847 1.1.1.3 mrg int work_share_cancelled; 848 1.1.1.3 mrg int team_cancelled; 849 1.1 mrg 850 1.1.1.11 mrg /* Number of tasks waiting for their completion event to be fulfilled. */ 851 1.1.1.11 mrg unsigned int task_detach_count; 852 1.1.1.11 mrg 853 1.1 mrg /* This array contains structures for implicit tasks. */ 854 1.1 mrg struct gomp_task implicit_task[]; 855 1.1 mrg }; 856 1.1 mrg 857 1.1 mrg /* This structure contains all data that is private to libgomp and is 858 1.1 mrg allocated per thread. */ 859 1.1 mrg 860 1.1 mrg struct gomp_thread 861 1.1 mrg { 862 1.1 mrg /* This is the function that the thread should run upon launch. */ 863 1.1 mrg void (*fn) (void *data); 864 1.1 mrg void *data; 865 1.1 mrg 866 1.1 mrg /* This is the current team state for this thread. The ts.team member 867 1.1 mrg is NULL only if the thread is idle. */ 868 1.1 mrg struct gomp_team_state ts; 869 1.1 mrg 870 1.1 mrg /* This is the task that the thread is currently executing. */ 871 1.1 mrg struct gomp_task *task; 872 1.1 mrg 873 1.1 mrg /* This semaphore is used for ordered loops. */ 874 1.1 mrg gomp_sem_t release; 875 1.1 mrg 876 1.1.1.3 mrg /* Place this thread is bound to plus one, or zero if not bound 877 1.1.1.3 mrg to any place. */ 878 1.1.1.3 mrg unsigned int place; 879 1.1.1.3 mrg 880 1.1.1.3 mrg /* User pthread thread pool */ 881 1.1 mrg struct gomp_thread_pool *thread_pool; 882 1.1.1.9 mrg 883 1.1.1.11 mrg #ifdef LIBGOMP_USE_PTHREADS 884 1.1.1.11 mrg /* omp_get_num_teams () - 1. */ 885 1.1.1.11 mrg unsigned int num_teams; 886 1.1.1.11 mrg 887 1.1.1.11 mrg /* omp_get_team_num (). */ 888 1.1.1.11 mrg unsigned int team_num; 889 1.1.1.11 mrg #endif 890 1.1.1.11 mrg 891 1.1.1.9 mrg #if defined(LIBGOMP_USE_PTHREADS) \ 892 1.1.1.9 mrg && (!defined(HAVE_TLS) \ 893 1.1.1.9 mrg || !defined(__GLIBC__) \ 894 1.1.1.9 mrg || !defined(USING_INITIAL_EXEC_TLS)) 895 1.1.1.9 mrg /* pthread_t of the thread containing this gomp_thread. 896 1.1.1.9 mrg On Linux when using initial-exec TLS, 897 1.1.1.9 mrg (typeof (pthread_t)) gomp_thread () - pthread_self () 898 1.1.1.9 mrg is constant in all threads, so we can optimize and not 899 1.1.1.9 mrg store it. */ 900 1.1.1.9 mrg #define GOMP_NEEDS_THREAD_HANDLE 1 901 1.1.1.9 mrg pthread_t handle; 902 1.1.1.9 mrg #endif 903 1.1 mrg }; 904 1.1 mrg 905 1.1 mrg 906 1.1 mrg struct gomp_thread_pool 907 1.1 mrg { 908 1.1 mrg /* This array manages threads spawned from the top level, which will 909 1.1 mrg return to the idle loop once the current PARALLEL construct ends. */ 910 1.1 mrg struct gomp_thread **threads; 911 1.1 mrg unsigned threads_size; 912 1.1 mrg unsigned threads_used; 913 1.1.1.4 mrg /* The last team is used for non-nested teams to delay their destruction to 914 1.1.1.4 mrg make sure all the threads in the team move on to the pool's barrier before 915 1.1.1.4 mrg the team's barrier is destroyed. */ 916 1.1 mrg struct gomp_team *last_team; 917 1.1.1.3 mrg /* Number of threads running in this contention group. */ 918 1.1.1.3 mrg unsigned long threads_busy; 919 1.1 mrg 920 1.1.1.5 mrg /* This barrier holds and releases threads waiting in thread pools. */ 921 1.1.1.5 mrg gomp_simple_barrier_t threads_dock; 922 1.1 mrg }; 923 1.1 mrg 924 1.1.1.3 mrg enum gomp_cancel_kind 925 1.1.1.3 mrg { 926 1.1.1.3 mrg GOMP_CANCEL_PARALLEL = 1, 927 1.1.1.3 mrg GOMP_CANCEL_LOOP = 2, 928 1.1.1.3 mrg GOMP_CANCEL_FOR = GOMP_CANCEL_LOOP, 929 1.1.1.3 mrg GOMP_CANCEL_DO = GOMP_CANCEL_LOOP, 930 1.1.1.3 mrg GOMP_CANCEL_SECTIONS = 4, 931 1.1.1.3 mrg GOMP_CANCEL_TASKGROUP = 8 932 1.1.1.3 mrg }; 933 1.1.1.3 mrg 934 1.1 mrg /* ... and here is that TLS data. */ 935 1.1 mrg 936 1.1.1.5 mrg #if defined __nvptx__ 937 1.1.1.5 mrg extern struct gomp_thread *nvptx_thrs __attribute__((shared)); 938 1.1.1.5 mrg static inline struct gomp_thread *gomp_thread (void) 939 1.1.1.5 mrg { 940 1.1.1.5 mrg int tid; 941 1.1.1.5 mrg asm ("mov.u32 %0, %%tid.y;" : "=r" (tid)); 942 1.1.1.5 mrg return nvptx_thrs + tid; 943 1.1.1.5 mrg } 944 1.1.1.10 mrg #elif defined __AMDGCN__ 945 1.1.1.10 mrg static inline struct gomp_thread *gcn_thrs (void) 946 1.1.1.10 mrg { 947 1.1.1.10 mrg /* The value is at the bottom of LDS. */ 948 1.1.1.10 mrg struct gomp_thread * __lds *thrs = (struct gomp_thread * __lds *)4; 949 1.1.1.10 mrg return *thrs; 950 1.1.1.10 mrg } 951 1.1.1.10 mrg static inline void set_gcn_thrs (struct gomp_thread *val) 952 1.1.1.10 mrg { 953 1.1.1.10 mrg /* The value is at the bottom of LDS. */ 954 1.1.1.10 mrg struct gomp_thread * __lds *thrs = (struct gomp_thread * __lds *)4; 955 1.1.1.10 mrg *thrs = val; 956 1.1.1.10 mrg } 957 1.1.1.10 mrg static inline struct gomp_thread *gomp_thread (void) 958 1.1.1.10 mrg { 959 1.1.1.10 mrg int tid = __builtin_gcn_dim_pos(1); 960 1.1.1.10 mrg return gcn_thrs () + tid; 961 1.1.1.10 mrg } 962 1.1.1.5 mrg #elif defined HAVE_TLS || defined USE_EMUTLS 963 1.1 mrg extern __thread struct gomp_thread gomp_tls_data; 964 1.1 mrg static inline struct gomp_thread *gomp_thread (void) 965 1.1 mrg { 966 1.1 mrg return &gomp_tls_data; 967 1.1 mrg } 968 1.1 mrg #else 969 1.1 mrg extern pthread_key_t gomp_tls_key; 970 1.1 mrg static inline struct gomp_thread *gomp_thread (void) 971 1.1 mrg { 972 1.1 mrg return pthread_getspecific (gomp_tls_key); 973 1.1 mrg } 974 1.1 mrg #endif 975 1.1 mrg 976 1.1 mrg extern struct gomp_task_icv *gomp_new_icv (void); 977 1.1 mrg 978 1.1 mrg /* Here's how to access the current copy of the ICVs. */ 979 1.1 mrg 980 1.1 mrg static inline struct gomp_task_icv *gomp_icv (bool write) 981 1.1 mrg { 982 1.1 mrg struct gomp_task *task = gomp_thread ()->task; 983 1.1 mrg if (task) 984 1.1 mrg return &task->icv; 985 1.1 mrg else if (write) 986 1.1 mrg return gomp_new_icv (); 987 1.1 mrg else 988 1.1 mrg return &gomp_global_icv; 989 1.1 mrg } 990 1.1 mrg 991 1.1.1.5 mrg #ifdef LIBGOMP_USE_PTHREADS 992 1.1 mrg /* The attributes to be used during thread creation. */ 993 1.1 mrg extern pthread_attr_t gomp_thread_attr; 994 1.1 mrg 995 1.1.1.4 mrg extern pthread_key_t gomp_thread_destructor; 996 1.1.1.5 mrg #endif 997 1.1.1.4 mrg 998 1.1 mrg /* Function prototypes. */ 999 1.1 mrg 1000 1.1 mrg /* affinity.c */ 1001 1.1 mrg 1002 1.1 mrg extern void gomp_init_affinity (void); 1003 1.1.1.5 mrg #ifdef LIBGOMP_USE_PTHREADS 1004 1.1.1.3 mrg extern void gomp_init_thread_affinity (pthread_attr_t *, unsigned int); 1005 1.1.1.5 mrg #endif 1006 1.1.1.3 mrg extern void **gomp_affinity_alloc (unsigned long, bool); 1007 1.1.1.3 mrg extern void gomp_affinity_init_place (void *); 1008 1.1.1.3 mrg extern bool gomp_affinity_add_cpus (void *, unsigned long, unsigned long, 1009 1.1.1.3 mrg long, bool); 1010 1.1.1.3 mrg extern bool gomp_affinity_remove_cpu (void *, unsigned long); 1011 1.1.1.3 mrg extern bool gomp_affinity_copy_place (void *, void *, long); 1012 1.1.1.3 mrg extern bool gomp_affinity_same_place (void *, void *); 1013 1.1.1.3 mrg extern bool gomp_affinity_finalize_place_list (bool); 1014 1.1.1.3 mrg extern bool gomp_affinity_init_level (int, unsigned long, bool); 1015 1.1.1.3 mrg extern void gomp_affinity_print_place (void *); 1016 1.1.1.4 mrg extern void gomp_get_place_proc_ids_8 (int, int64_t *); 1017 1.1.1.9 mrg extern void gomp_display_affinity_place (char *, size_t, size_t *, int); 1018 1.1.1.9 mrg 1019 1.1.1.9 mrg /* affinity-fmt.c */ 1020 1.1.1.9 mrg 1021 1.1.1.9 mrg extern bool gomp_print_string (const char *str, size_t len); 1022 1.1.1.9 mrg extern void gomp_set_affinity_format (const char *, size_t); 1023 1.1.1.9 mrg extern void gomp_display_string (char *, size_t, size_t *, const char *, 1024 1.1.1.9 mrg size_t); 1025 1.1.1.9 mrg #ifdef LIBGOMP_USE_PTHREADS 1026 1.1.1.9 mrg typedef pthread_t gomp_thread_handle; 1027 1.1.1.9 mrg #else 1028 1.1.1.9 mrg typedef struct {} gomp_thread_handle; 1029 1.1.1.9 mrg #endif 1030 1.1.1.9 mrg extern size_t gomp_display_affinity (char *, size_t, const char *, 1031 1.1.1.9 mrg gomp_thread_handle, 1032 1.1.1.9 mrg struct gomp_team_state *, unsigned int); 1033 1.1.1.9 mrg extern void gomp_display_affinity_thread (gomp_thread_handle, 1034 1.1.1.9 mrg struct gomp_team_state *, 1035 1.1.1.9 mrg unsigned int) __attribute__((cold)); 1036 1.1 mrg 1037 1.1.1.12 mrg /* env.c */ 1038 1.1.1.12 mrg 1039 1.1.1.12 mrg extern struct gomp_icv_list *gomp_get_initial_icv_item (int dev_num); 1040 1.1.1.12 mrg extern bool gomp_get_icv_flag (uint32_t value, enum gomp_icvs icv); 1041 1.1.1.12 mrg 1042 1.1 mrg /* iter.c */ 1043 1.1 mrg 1044 1.1 mrg extern int gomp_iter_static_next (long *, long *); 1045 1.1 mrg extern bool gomp_iter_dynamic_next_locked (long *, long *); 1046 1.1 mrg extern bool gomp_iter_guided_next_locked (long *, long *); 1047 1.1 mrg 1048 1.1 mrg #ifdef HAVE_SYNC_BUILTINS 1049 1.1 mrg extern bool gomp_iter_dynamic_next (long *, long *); 1050 1.1 mrg extern bool gomp_iter_guided_next (long *, long *); 1051 1.1 mrg #endif 1052 1.1 mrg 1053 1.1 mrg /* iter_ull.c */ 1054 1.1 mrg 1055 1.1 mrg extern int gomp_iter_ull_static_next (unsigned long long *, 1056 1.1 mrg unsigned long long *); 1057 1.1 mrg extern bool gomp_iter_ull_dynamic_next_locked (unsigned long long *, 1058 1.1 mrg unsigned long long *); 1059 1.1 mrg extern bool gomp_iter_ull_guided_next_locked (unsigned long long *, 1060 1.1 mrg unsigned long long *); 1061 1.1 mrg 1062 1.1 mrg #if defined HAVE_SYNC_BUILTINS && defined __LP64__ 1063 1.1 mrg extern bool gomp_iter_ull_dynamic_next (unsigned long long *, 1064 1.1 mrg unsigned long long *); 1065 1.1 mrg extern bool gomp_iter_ull_guided_next (unsigned long long *, 1066 1.1 mrg unsigned long long *); 1067 1.1 mrg #endif 1068 1.1 mrg 1069 1.1 mrg /* ordered.c */ 1070 1.1 mrg 1071 1.1 mrg extern void gomp_ordered_first (void); 1072 1.1 mrg extern void gomp_ordered_last (void); 1073 1.1 mrg extern void gomp_ordered_next (void); 1074 1.1 mrg extern void gomp_ordered_static_init (void); 1075 1.1 mrg extern void gomp_ordered_static_next (void); 1076 1.1 mrg extern void gomp_ordered_sync (void); 1077 1.1.1.9 mrg extern void gomp_doacross_init (unsigned, long *, long, size_t); 1078 1.1.1.4 mrg extern void gomp_doacross_ull_init (unsigned, unsigned long long *, 1079 1.1.1.9 mrg unsigned long long, size_t); 1080 1.1 mrg 1081 1.1 mrg /* parallel.c */ 1082 1.1 mrg 1083 1.1 mrg extern unsigned gomp_resolve_num_threads (unsigned, unsigned); 1084 1.1 mrg 1085 1.1 mrg /* proc.c (in config/) */ 1086 1.1 mrg 1087 1.1 mrg extern void gomp_init_num_threads (void); 1088 1.1 mrg extern unsigned gomp_dynamic_max_threads (void); 1089 1.1 mrg 1090 1.1 mrg /* task.c */ 1091 1.1 mrg 1092 1.1 mrg extern void gomp_init_task (struct gomp_task *, struct gomp_task *, 1093 1.1 mrg struct gomp_task_icv *); 1094 1.1 mrg extern void gomp_end_task (void); 1095 1.1 mrg extern void gomp_barrier_handle_tasks (gomp_barrier_state_t); 1096 1.1.1.4 mrg extern void gomp_task_maybe_wait_for_dependencies (void **); 1097 1.1.1.4 mrg extern bool gomp_create_target_task (struct gomp_device_descr *, 1098 1.1.1.4 mrg void (*) (void *), size_t, void **, 1099 1.1.1.4 mrg size_t *, unsigned short *, unsigned int, 1100 1.1.1.4 mrg void **, void **, 1101 1.1.1.4 mrg enum gomp_target_task_state); 1102 1.1.1.9 mrg extern struct gomp_taskgroup *gomp_parallel_reduction_register (uintptr_t *, 1103 1.1.1.9 mrg unsigned); 1104 1.1.1.9 mrg extern void gomp_workshare_taskgroup_start (void); 1105 1.1.1.9 mrg extern void gomp_workshare_task_reduction_register (uintptr_t *, uintptr_t *); 1106 1.1 mrg 1107 1.1 mrg static void inline 1108 1.1 mrg gomp_finish_task (struct gomp_task *task) 1109 1.1 mrg { 1110 1.1.1.3 mrg if (__builtin_expect (task->depend_hash != NULL, 0)) 1111 1.1.1.3 mrg free (task->depend_hash); 1112 1.1 mrg } 1113 1.1 mrg 1114 1.1 mrg /* team.c */ 1115 1.1 mrg 1116 1.1 mrg extern struct gomp_team *gomp_new_team (unsigned); 1117 1.1 mrg extern void gomp_team_start (void (*) (void *), void *, unsigned, 1118 1.1.1.9 mrg unsigned, struct gomp_team *, 1119 1.1.1.9 mrg struct gomp_taskgroup *); 1120 1.1 mrg extern void gomp_team_end (void); 1121 1.1.1.3 mrg extern void gomp_free_thread (void *); 1122 1.1.1.9 mrg extern int gomp_pause_host (void); 1123 1.1.1.3 mrg 1124 1.1.1.3 mrg /* target.c */ 1125 1.1.1.3 mrg 1126 1.1.1.3 mrg extern void gomp_init_targets_once (void); 1127 1.1.1.3 mrg extern int gomp_get_num_devices (void); 1128 1.1.1.4 mrg extern bool gomp_target_task_fn (void *); 1129 1.1.1.12 mrg extern void gomp_target_rev (uint64_t, uint64_t, uint64_t, uint64_t, uint64_t, 1130 1.1.1.12 mrg int, struct goacc_asyncqueue *); 1131 1.1.1.3 mrg 1132 1.1.1.4 mrg /* Splay tree definitions. */ 1133 1.1.1.3 mrg typedef struct splay_tree_node_s *splay_tree_node; 1134 1.1.1.3 mrg typedef struct splay_tree_s *splay_tree; 1135 1.1.1.3 mrg typedef struct splay_tree_key_s *splay_tree_key; 1136 1.1.1.3 mrg 1137 1.1.1.4 mrg struct target_var_desc { 1138 1.1.1.4 mrg /* Splay key. */ 1139 1.1.1.4 mrg splay_tree_key key; 1140 1.1.1.4 mrg /* True if data should be copied from device to host at the end. */ 1141 1.1.1.4 mrg bool copy_from; 1142 1.1.1.4 mrg /* True if data always should be copied from device to host at the end. */ 1143 1.1.1.4 mrg bool always_copy_from; 1144 1.1.1.10 mrg /* True if this is for OpenACC 'attach'. */ 1145 1.1.1.10 mrg bool is_attach; 1146 1.1.1.11 mrg /* If GOMP_MAP_TO_PSET had a NULL pointer; used for Fortran descriptors, 1147 1.1.1.11 mrg which were initially unallocated. */ 1148 1.1.1.11 mrg bool has_null_ptr_assoc; 1149 1.1.1.4 mrg /* Relative offset against key host_start. */ 1150 1.1.1.4 mrg uintptr_t offset; 1151 1.1.1.4 mrg /* Actual length. */ 1152 1.1.1.4 mrg uintptr_t length; 1153 1.1.1.4 mrg }; 1154 1.1.1.4 mrg 1155 1.1.1.12 mrg struct target_mem_desc; 1156 1.1.1.3 mrg 1157 1.1.1.11 mrg /* Special value for refcount - mask to indicate existence of special 1158 1.1.1.11 mrg values. Right now we allocate 3 bits. */ 1159 1.1.1.11 mrg #define REFCOUNT_SPECIAL (~(uintptr_t) 0x7) 1160 1.1.1.11 mrg 1161 1.1.1.4 mrg /* Special value for refcount - infinity. */ 1162 1.1.1.11 mrg #define REFCOUNT_INFINITY (REFCOUNT_SPECIAL | 0) 1163 1.1.1.4 mrg /* Special value for refcount - tgt_offset contains target address of the 1164 1.1.1.4 mrg artificial pointer to "omp declare target link" object. */ 1165 1.1.1.11 mrg #define REFCOUNT_LINK (REFCOUNT_SPECIAL | 1) 1166 1.1.1.12 mrg /* Special value for refcount - created through acc_map_data. */ 1167 1.1.1.12 mrg #define REFCOUNT_ACC_MAP_DATA (REFCOUNT_SPECIAL | 2) 1168 1.1.1.11 mrg 1169 1.1.1.11 mrg /* Special value for refcount - structure element sibling list items. 1170 1.1.1.11 mrg All such key refounts have REFCOUNT_STRUCTELEM bits set, with _FLAG_FIRST 1171 1.1.1.11 mrg and _FLAG_LAST indicating first and last in the created sibling sequence. */ 1172 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM (REFCOUNT_SPECIAL | 4) 1173 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM_P(V) \ 1174 1.1.1.11 mrg (((V) & REFCOUNT_STRUCTELEM) == REFCOUNT_STRUCTELEM) 1175 1.1.1.11 mrg /* The first leading key with _FLAG_FIRST set houses the actual reference count 1176 1.1.1.11 mrg in the structelem_refcount field. Other siblings point to this counter value 1177 1.1.1.11 mrg through its structelem_refcount_ptr field. */ 1178 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM_FLAG_FIRST (1) 1179 1.1.1.11 mrg /* The last key in the sibling sequence has this set. This is required to 1180 1.1.1.11 mrg indicate the sequence boundary, when we remove the structure sibling list 1181 1.1.1.11 mrg from the map. */ 1182 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM_FLAG_LAST (2) 1183 1.1.1.11 mrg 1184 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM_FIRST_P(V) \ 1185 1.1.1.11 mrg (REFCOUNT_STRUCTELEM_P (V) && ((V) & REFCOUNT_STRUCTELEM_FLAG_FIRST)) 1186 1.1.1.11 mrg #define REFCOUNT_STRUCTELEM_LAST_P(V) \ 1187 1.1.1.11 mrg (REFCOUNT_STRUCTELEM_P (V) && ((V) & REFCOUNT_STRUCTELEM_FLAG_LAST)) 1188 1.1.1.4 mrg 1189 1.1.1.10 mrg /* Special offset values. */ 1190 1.1.1.10 mrg #define OFFSET_INLINED (~(uintptr_t) 0) 1191 1.1.1.10 mrg #define OFFSET_POINTER (~(uintptr_t) 1) 1192 1.1.1.10 mrg #define OFFSET_STRUCT (~(uintptr_t) 2) 1193 1.1.1.10 mrg 1194 1.1.1.10 mrg /* Auxiliary structure for infrequently-used or API-specific data. */ 1195 1.1.1.10 mrg 1196 1.1.1.10 mrg struct splay_tree_aux { 1197 1.1.1.10 mrg /* Pointer to the original mapping of "omp declare target link" object. */ 1198 1.1.1.10 mrg splay_tree_key link_key; 1199 1.1.1.10 mrg /* For a block with attached pointers, the attachment counters for each. 1200 1.1.1.10 mrg Only used for OpenACC. */ 1201 1.1.1.10 mrg uintptr_t *attach_count; 1202 1.1.1.10 mrg }; 1203 1.1.1.10 mrg 1204 1.1.1.3 mrg struct splay_tree_key_s { 1205 1.1.1.3 mrg /* Address of the host object. */ 1206 1.1.1.3 mrg uintptr_t host_start; 1207 1.1.1.3 mrg /* Address immediately after the host object. */ 1208 1.1.1.3 mrg uintptr_t host_end; 1209 1.1.1.3 mrg /* Descriptor of the target memory. */ 1210 1.1.1.3 mrg struct target_mem_desc *tgt; 1211 1.1.1.3 mrg /* Offset from tgt->tgt_start to the start of the target object. */ 1212 1.1.1.3 mrg uintptr_t tgt_offset; 1213 1.1.1.3 mrg /* Reference count. */ 1214 1.1.1.3 mrg uintptr_t refcount; 1215 1.1.1.11 mrg union { 1216 1.1.1.11 mrg /* Dynamic reference count. */ 1217 1.1.1.11 mrg uintptr_t dynamic_refcount; 1218 1.1.1.11 mrg 1219 1.1.1.11 mrg /* Unified reference count for structure element siblings, this is used 1220 1.1.1.11 mrg when REFCOUNT_STRUCTELEM_FIRST_P(k->refcount) == true, the first sibling 1221 1.1.1.11 mrg in a structure element sibling list item sequence. */ 1222 1.1.1.11 mrg uintptr_t structelem_refcount; 1223 1.1.1.11 mrg 1224 1.1.1.11 mrg /* When REFCOUNT_STRUCTELEM_P (k->refcount) == true, this field points 1225 1.1.1.11 mrg into the (above) structelem_refcount field of the _FIRST splay_tree_key, 1226 1.1.1.11 mrg the first key in the created sequence. All structure element siblings 1227 1.1.1.11 mrg share a single refcount in this manner. Since these two fields won't be 1228 1.1.1.11 mrg used at the same time, they are stashed in a union. */ 1229 1.1.1.11 mrg uintptr_t *structelem_refcount_ptr; 1230 1.1.1.11 mrg }; 1231 1.1.1.10 mrg struct splay_tree_aux *aux; 1232 1.1.1.3 mrg }; 1233 1.1.1.3 mrg 1234 1.1.1.4 mrg /* The comparison function. */ 1235 1.1.1.4 mrg 1236 1.1.1.4 mrg static inline int 1237 1.1.1.4 mrg splay_compare (splay_tree_key x, splay_tree_key y) 1238 1.1.1.4 mrg { 1239 1.1.1.4 mrg if (x->host_start == x->host_end 1240 1.1.1.4 mrg && y->host_start == y->host_end) 1241 1.1.1.4 mrg return 0; 1242 1.1.1.4 mrg if (x->host_end <= y->host_start) 1243 1.1.1.4 mrg return -1; 1244 1.1.1.4 mrg if (x->host_start >= y->host_end) 1245 1.1.1.4 mrg return 1; 1246 1.1.1.4 mrg return 0; 1247 1.1.1.4 mrg } 1248 1.1.1.4 mrg 1249 1.1.1.3 mrg #include "splay-tree.h" 1250 1.1.1.3 mrg 1251 1.1.1.12 mrg /* Reverse offload splay-tree handling (functions only). */ 1252 1.1.1.12 mrg 1253 1.1.1.12 mrg struct reverse_splay_tree_key_s { 1254 1.1.1.12 mrg /* Address of the device object. */ 1255 1.1.1.12 mrg uint64_t dev; 1256 1.1.1.12 mrg splay_tree_key k; 1257 1.1.1.12 mrg }; 1258 1.1.1.12 mrg 1259 1.1.1.12 mrg typedef struct reverse_splay_tree_node_s *reverse_splay_tree_node; 1260 1.1.1.12 mrg typedef struct reverse_splay_tree_s *reverse_splay_tree; 1261 1.1.1.12 mrg typedef struct reverse_splay_tree_key_s *reverse_splay_tree_key; 1262 1.1.1.12 mrg 1263 1.1.1.12 mrg static inline int 1264 1.1.1.12 mrg reverse_splay_compare (reverse_splay_tree_key x, reverse_splay_tree_key y) 1265 1.1.1.12 mrg { 1266 1.1.1.12 mrg if (x->dev < y->dev) 1267 1.1.1.12 mrg return -1; 1268 1.1.1.12 mrg if (x->dev > y->dev) 1269 1.1.1.12 mrg return 1; 1270 1.1.1.12 mrg return 0; 1271 1.1.1.12 mrg } 1272 1.1.1.12 mrg 1273 1.1.1.12 mrg #define splay_tree_prefix reverse 1274 1.1.1.12 mrg #define splay_tree_static 1275 1.1.1.12 mrg #include "splay-tree.h" 1276 1.1.1.12 mrg 1277 1.1.1.12 mrg /* Indirect target function splay-tree handling. */ 1278 1.1.1.12 mrg 1279 1.1.1.12 mrg struct indirect_splay_tree_key_s { 1280 1.1.1.12 mrg uint64_t host_addr, target_addr; 1281 1.1.1.12 mrg }; 1282 1.1.1.12 mrg 1283 1.1.1.12 mrg typedef struct indirect_splay_tree_node_s *indirect_splay_tree_node; 1284 1.1.1.12 mrg typedef struct indirect_splay_tree_s *indirect_splay_tree; 1285 1.1.1.12 mrg typedef struct indirect_splay_tree_key_s *indirect_splay_tree_key; 1286 1.1.1.12 mrg 1287 1.1.1.12 mrg static inline int 1288 1.1.1.12 mrg indirect_splay_compare (indirect_splay_tree_key x, indirect_splay_tree_key y) 1289 1.1.1.12 mrg { 1290 1.1.1.12 mrg if (x->host_addr < y->host_addr) 1291 1.1.1.12 mrg return -1; 1292 1.1.1.12 mrg if (x->host_addr > y->host_addr) 1293 1.1.1.12 mrg return 1; 1294 1.1.1.12 mrg return 0; 1295 1.1.1.12 mrg } 1296 1.1.1.12 mrg 1297 1.1.1.12 mrg #define splay_tree_prefix indirect 1298 1.1.1.12 mrg #include "splay-tree.h" 1299 1.1.1.12 mrg 1300 1.1.1.12 mrg struct target_mem_desc { 1301 1.1.1.12 mrg /* Reference count. */ 1302 1.1.1.12 mrg uintptr_t refcount; 1303 1.1.1.12 mrg /* All the splay nodes allocated together. */ 1304 1.1.1.12 mrg splay_tree_node array; 1305 1.1.1.12 mrg /* Likewise for the reverse lookup device->host for reverse offload. */ 1306 1.1.1.12 mrg reverse_splay_tree_node rev_array; 1307 1.1.1.12 mrg /* Start of the target region. */ 1308 1.1.1.12 mrg uintptr_t tgt_start; 1309 1.1.1.12 mrg /* End of the targer region. */ 1310 1.1.1.12 mrg uintptr_t tgt_end; 1311 1.1.1.12 mrg /* Handle to free. */ 1312 1.1.1.12 mrg void *to_free; 1313 1.1.1.12 mrg /* Previous target_mem_desc. */ 1314 1.1.1.12 mrg struct target_mem_desc *prev; 1315 1.1.1.12 mrg /* Number of items in following list. */ 1316 1.1.1.12 mrg size_t list_count; 1317 1.1.1.12 mrg 1318 1.1.1.12 mrg /* Corresponding target device descriptor. */ 1319 1.1.1.12 mrg struct gomp_device_descr *device_descr; 1320 1.1.1.12 mrg 1321 1.1.1.12 mrg /* List of target items to remove (or decrease refcount) 1322 1.1.1.12 mrg at the end of region. */ 1323 1.1.1.12 mrg struct target_var_desc list[]; 1324 1.1.1.12 mrg }; 1325 1.1.1.12 mrg 1326 1.1.1.12 mrg 1327 1.1.1.3 mrg typedef struct acc_dispatch_t 1328 1.1.1.3 mrg { 1329 1.1.1.3 mrg /* Execute. */ 1330 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_exec) *exec_func; 1331 1.1.1.3 mrg 1332 1.1.1.3 mrg /* Create/destroy TLS data. */ 1333 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_create_thread_data) *create_thread_data_func; 1334 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_destroy_thread_data) 1335 1.1.1.5 mrg *destroy_thread_data_func; 1336 1.1.1.10 mrg 1337 1.1.1.10 mrg struct { 1338 1.1.1.10 mrg /* Once created and put into the "active" list, asyncqueues are then never 1339 1.1.1.10 mrg destructed and removed from the "active" list, other than if the TODO 1340 1.1.1.10 mrg device is shut down. */ 1341 1.1.1.10 mrg gomp_mutex_t lock; 1342 1.1.1.10 mrg int nasyncqueue; 1343 1.1.1.10 mrg struct goacc_asyncqueue **asyncqueue; 1344 1.1.1.10 mrg struct goacc_asyncqueue_list *active; 1345 1.1.1.10 mrg 1346 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_construct) *construct_func; 1347 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_destruct) *destruct_func; 1348 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_test) *test_func; 1349 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_synchronize) *synchronize_func; 1350 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_serialize) *serialize_func; 1351 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_queue_callback) *queue_callback_func; 1352 1.1.1.10 mrg 1353 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_exec) *exec_func; 1354 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_dev2host) *dev2host_func; 1355 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_async_host2dev) *host2dev_func; 1356 1.1.1.10 mrg } async; 1357 1.1.1.10 mrg 1358 1.1.1.10 mrg __typeof (GOMP_OFFLOAD_openacc_get_property) *get_property_func; 1359 1.1.1.3 mrg 1360 1.1.1.3 mrg /* NVIDIA target specific routines. */ 1361 1.1.1.3 mrg struct { 1362 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_current_device) 1363 1.1.1.5 mrg *get_current_device_func; 1364 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_current_context) 1365 1.1.1.5 mrg *get_current_context_func; 1366 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_get_stream) *get_stream_func; 1367 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_openacc_cuda_set_stream) *set_stream_func; 1368 1.1.1.3 mrg } cuda; 1369 1.1.1.3 mrg } acc_dispatch_t; 1370 1.1.1.3 mrg 1371 1.1.1.4 mrg /* Various state of the accelerator device. */ 1372 1.1.1.4 mrg enum gomp_device_state 1373 1.1.1.4 mrg { 1374 1.1.1.4 mrg GOMP_DEVICE_UNINITIALIZED, 1375 1.1.1.4 mrg GOMP_DEVICE_INITIALIZED, 1376 1.1.1.4 mrg GOMP_DEVICE_FINALIZED 1377 1.1.1.4 mrg }; 1378 1.1.1.4 mrg 1379 1.1.1.3 mrg /* This structure describes accelerator device. 1380 1.1.1.3 mrg It contains name of the corresponding libgomp plugin, function handlers for 1381 1.1.1.3 mrg interaction with the device, ID-number of the device, and information about 1382 1.1.1.3 mrg mapped memory. */ 1383 1.1.1.3 mrg struct gomp_device_descr 1384 1.1.1.3 mrg { 1385 1.1.1.3 mrg /* Immutable data, which is only set during initialization, and which is not 1386 1.1.1.3 mrg guarded by the lock. */ 1387 1.1.1.3 mrg 1388 1.1.1.3 mrg /* The name of the device. */ 1389 1.1.1.3 mrg const char *name; 1390 1.1.1.3 mrg 1391 1.1.1.3 mrg /* Capabilities of device (supports OpenACC, OpenMP). */ 1392 1.1.1.3 mrg unsigned int capabilities; 1393 1.1.1.3 mrg 1394 1.1.1.3 mrg /* This is the ID number of device among devices of the same type. */ 1395 1.1.1.3 mrg int target_id; 1396 1.1.1.3 mrg 1397 1.1.1.3 mrg /* This is the TYPE of device. */ 1398 1.1.1.3 mrg enum offload_target_type type; 1399 1.1.1.3 mrg 1400 1.1.1.3 mrg /* Function handlers. */ 1401 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_name) *get_name_func; 1402 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_caps) *get_caps_func; 1403 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_type) *get_type_func; 1404 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_get_num_devices) *get_num_devices_func; 1405 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_init_device) *init_device_func; 1406 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_fini_device) *fini_device_func; 1407 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_version) *version_func; 1408 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_load_image) *load_image_func; 1409 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_unload_image) *unload_image_func; 1410 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_alloc) *alloc_func; 1411 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_free) *free_func; 1412 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_dev2host) *dev2host_func; 1413 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_host2dev) *host2dev_func; 1414 1.1.1.12 mrg __typeof (GOMP_OFFLOAD_memcpy2d) *memcpy2d_func; 1415 1.1.1.12 mrg __typeof (GOMP_OFFLOAD_memcpy3d) *memcpy3d_func; 1416 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_dev2dev) *dev2dev_func; 1417 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_can_run) *can_run_func; 1418 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_run) *run_func; 1419 1.1.1.5 mrg __typeof (GOMP_OFFLOAD_async_run) *async_run_func; 1420 1.1.1.3 mrg 1421 1.1.1.3 mrg /* Splay tree containing information about mapped memory regions. */ 1422 1.1.1.3 mrg struct splay_tree_s mem_map; 1423 1.1.1.12 mrg struct reverse_splay_tree_s mem_map_rev; 1424 1.1.1.3 mrg 1425 1.1.1.3 mrg /* Mutex for the mutable data. */ 1426 1.1.1.3 mrg gomp_mutex_t lock; 1427 1.1.1.3 mrg 1428 1.1.1.4 mrg /* Current state of the device. OpenACC allows to move from INITIALIZED state 1429 1.1.1.4 mrg back to UNINITIALIZED state. OpenMP allows only to move from INITIALIZED 1430 1.1.1.4 mrg to FINALIZED state (at program shutdown). */ 1431 1.1.1.4 mrg enum gomp_device_state state; 1432 1.1.1.3 mrg 1433 1.1.1.3 mrg /* OpenACC-specific data and functions. */ 1434 1.1.1.10 mrg /* This is mutable because of its mutable target_data member. */ 1435 1.1.1.3 mrg acc_dispatch_t openacc; 1436 1.1.1.3 mrg }; 1437 1.1.1.3 mrg 1438 1.1.1.4 mrg /* Kind of the pragma, for which gomp_map_vars () is called. */ 1439 1.1.1.4 mrg enum gomp_map_vars_kind 1440 1.1.1.4 mrg { 1441 1.1.1.11 mrg GOMP_MAP_VARS_OPENACC = 1, 1442 1.1.1.11 mrg GOMP_MAP_VARS_TARGET = 2, 1443 1.1.1.11 mrg GOMP_MAP_VARS_DATA = 4, 1444 1.1.1.11 mrg GOMP_MAP_VARS_ENTER_DATA = 8 1445 1.1.1.4 mrg }; 1446 1.1.1.4 mrg 1447 1.1.1.9 mrg extern void gomp_acc_declare_allocate (bool, size_t, void **, size_t *, 1448 1.1.1.9 mrg unsigned short *); 1449 1.1.1.10 mrg struct gomp_coalesce_buf; 1450 1.1.1.10 mrg extern void gomp_copy_host2dev (struct gomp_device_descr *, 1451 1.1.1.10 mrg struct goacc_asyncqueue *, void *, const void *, 1452 1.1.1.11 mrg size_t, bool, struct gomp_coalesce_buf *); 1453 1.1.1.10 mrg extern void gomp_copy_dev2host (struct gomp_device_descr *, 1454 1.1.1.10 mrg struct goacc_asyncqueue *, void *, const void *, 1455 1.1.1.10 mrg size_t); 1456 1.1.1.10 mrg extern uintptr_t gomp_map_val (struct target_mem_desc *, void **, size_t); 1457 1.1.1.10 mrg extern void gomp_attach_pointer (struct gomp_device_descr *, 1458 1.1.1.10 mrg struct goacc_asyncqueue *, splay_tree, 1459 1.1.1.10 mrg splay_tree_key, uintptr_t, size_t, 1460 1.1.1.11 mrg struct gomp_coalesce_buf *, bool); 1461 1.1.1.10 mrg extern void gomp_detach_pointer (struct gomp_device_descr *, 1462 1.1.1.10 mrg struct goacc_asyncqueue *, splay_tree_key, 1463 1.1.1.10 mrg uintptr_t, bool, struct gomp_coalesce_buf *); 1464 1.1.1.11 mrg extern struct target_mem_desc *goacc_map_vars (struct gomp_device_descr *, 1465 1.1.1.11 mrg struct goacc_asyncqueue *, 1466 1.1.1.11 mrg size_t, void **, void **, 1467 1.1.1.11 mrg size_t *, void *, bool, 1468 1.1.1.11 mrg enum gomp_map_vars_kind); 1469 1.1.1.11 mrg extern void goacc_unmap_vars (struct target_mem_desc *, bool, 1470 1.1.1.11 mrg struct goacc_asyncqueue *); 1471 1.1.1.3 mrg extern void gomp_init_device (struct gomp_device_descr *); 1472 1.1.1.10 mrg extern bool gomp_fini_device (struct gomp_device_descr *); 1473 1.1.1.4 mrg extern void gomp_unload_device (struct gomp_device_descr *); 1474 1.1.1.9 mrg extern bool gomp_remove_var (struct gomp_device_descr *, splay_tree_key); 1475 1.1.1.10 mrg extern void gomp_remove_var_async (struct gomp_device_descr *, splay_tree_key, 1476 1.1.1.10 mrg struct goacc_asyncqueue *); 1477 1.1 mrg 1478 1.1 mrg /* work.c */ 1479 1.1 mrg 1480 1.1.1.9 mrg extern void gomp_init_work_share (struct gomp_work_share *, size_t, unsigned); 1481 1.1 mrg extern void gomp_fini_work_share (struct gomp_work_share *); 1482 1.1.1.9 mrg extern bool gomp_work_share_start (size_t); 1483 1.1 mrg extern void gomp_work_share_end (void); 1484 1.1.1.3 mrg extern bool gomp_work_share_end_cancel (void); 1485 1.1 mrg extern void gomp_work_share_end_nowait (void); 1486 1.1 mrg 1487 1.1 mrg static inline void 1488 1.1 mrg gomp_work_share_init_done (void) 1489 1.1 mrg { 1490 1.1 mrg struct gomp_thread *thr = gomp_thread (); 1491 1.1 mrg if (__builtin_expect (thr->ts.last_work_share != NULL, 1)) 1492 1.1 mrg gomp_ptrlock_set (&thr->ts.last_work_share->next_ws, thr->ts.work_share); 1493 1.1 mrg } 1494 1.1 mrg 1495 1.1 mrg #ifdef HAVE_ATTRIBUTE_VISIBILITY 1496 1.1 mrg # pragma GCC visibility pop 1497 1.1 mrg #endif 1498 1.1 mrg 1499 1.1 mrg /* Now that we're back to default visibility, include the globals. */ 1500 1.1 mrg #include "libgomp_g.h" 1501 1.1 mrg 1502 1.1 mrg /* Include omp.h by parts. */ 1503 1.1 mrg #include "omp-lock.h" 1504 1.1 mrg #define _LIBGOMP_OMP_LOCK_DEFINED 1 1505 1.1 mrg #include "omp.h.in" 1506 1.1 mrg 1507 1.1 mrg #if !defined (HAVE_ATTRIBUTE_VISIBILITY) \ 1508 1.1 mrg || !defined (HAVE_ATTRIBUTE_ALIAS) \ 1509 1.1 mrg || !defined (HAVE_AS_SYMVER_DIRECTIVE) \ 1510 1.1.1.2 mrg || !defined (PIC) \ 1511 1.1.1.2 mrg || !defined (HAVE_SYMVER_SYMBOL_RENAMING_RUNTIME_SUPPORT) 1512 1.1 mrg # undef LIBGOMP_GNU_SYMBOL_VERSIONING 1513 1.1 mrg #endif 1514 1.1 mrg 1515 1.1 mrg #ifdef LIBGOMP_GNU_SYMBOL_VERSIONING 1516 1.1 mrg extern void gomp_init_lock_30 (omp_lock_t *) __GOMP_NOTHROW; 1517 1.1 mrg extern void gomp_destroy_lock_30 (omp_lock_t *) __GOMP_NOTHROW; 1518 1.1 mrg extern void gomp_set_lock_30 (omp_lock_t *) __GOMP_NOTHROW; 1519 1.1 mrg extern void gomp_unset_lock_30 (omp_lock_t *) __GOMP_NOTHROW; 1520 1.1 mrg extern int gomp_test_lock_30 (omp_lock_t *) __GOMP_NOTHROW; 1521 1.1 mrg extern void gomp_init_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW; 1522 1.1 mrg extern void gomp_destroy_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW; 1523 1.1 mrg extern void gomp_set_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW; 1524 1.1 mrg extern void gomp_unset_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW; 1525 1.1 mrg extern int gomp_test_nest_lock_30 (omp_nest_lock_t *) __GOMP_NOTHROW; 1526 1.1 mrg 1527 1.1 mrg extern void gomp_init_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW; 1528 1.1 mrg extern void gomp_destroy_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW; 1529 1.1 mrg extern void gomp_set_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW; 1530 1.1 mrg extern void gomp_unset_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW; 1531 1.1 mrg extern int gomp_test_lock_25 (omp_lock_25_t *) __GOMP_NOTHROW; 1532 1.1 mrg extern void gomp_init_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW; 1533 1.1 mrg extern void gomp_destroy_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW; 1534 1.1 mrg extern void gomp_set_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW; 1535 1.1 mrg extern void gomp_unset_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW; 1536 1.1 mrg extern int gomp_test_nest_lock_25 (omp_nest_lock_25_t *) __GOMP_NOTHROW; 1537 1.1 mrg 1538 1.1 mrg # define omp_lock_symver(fn) \ 1539 1.1 mrg __asm (".symver g" #fn "_30, " #fn "@@OMP_3.0"); \ 1540 1.1 mrg __asm (".symver g" #fn "_25, " #fn "@OMP_1.0"); 1541 1.1 mrg #else 1542 1.1 mrg # define gomp_init_lock_30 omp_init_lock 1543 1.1 mrg # define gomp_destroy_lock_30 omp_destroy_lock 1544 1.1 mrg # define gomp_set_lock_30 omp_set_lock 1545 1.1 mrg # define gomp_unset_lock_30 omp_unset_lock 1546 1.1 mrg # define gomp_test_lock_30 omp_test_lock 1547 1.1 mrg # define gomp_init_nest_lock_30 omp_init_nest_lock 1548 1.1 mrg # define gomp_destroy_nest_lock_30 omp_destroy_nest_lock 1549 1.1 mrg # define gomp_set_nest_lock_30 omp_set_nest_lock 1550 1.1 mrg # define gomp_unset_nest_lock_30 omp_unset_nest_lock 1551 1.1 mrg # define gomp_test_nest_lock_30 omp_test_nest_lock 1552 1.1 mrg #endif 1553 1.1 mrg 1554 1.1 mrg #ifdef HAVE_ATTRIBUTE_VISIBILITY 1555 1.1 mrg # define attribute_hidden __attribute__ ((visibility ("hidden"))) 1556 1.1 mrg #else 1557 1.1 mrg # define attribute_hidden 1558 1.1 mrg #endif 1559 1.1 mrg 1560 1.1.1.9 mrg #if __GNUC__ >= 9 1561 1.1.1.9 mrg # define HAVE_ATTRIBUTE_COPY 1562 1.1.1.9 mrg #endif 1563 1.1.1.9 mrg 1564 1.1.1.9 mrg #ifdef HAVE_ATTRIBUTE_COPY 1565 1.1.1.9 mrg # define attribute_copy(arg) __attribute__ ((copy (arg))) 1566 1.1.1.9 mrg #else 1567 1.1.1.9 mrg # define attribute_copy(arg) 1568 1.1.1.9 mrg #endif 1569 1.1.1.9 mrg 1570 1.1 mrg #ifdef HAVE_ATTRIBUTE_ALIAS 1571 1.1.1.8 mrg # define strong_alias(fn, al) \ 1572 1.1.1.9 mrg extern __typeof (fn) al __attribute__ ((alias (#fn))) attribute_copy (fn); 1573 1.1.1.8 mrg 1574 1.1.1.3 mrg # define ialias_ulp ialias_str1(__USER_LABEL_PREFIX__) 1575 1.1.1.3 mrg # define ialias_str1(x) ialias_str2(x) 1576 1.1.1.3 mrg # define ialias_str2(x) #x 1577 1.1 mrg # define ialias(fn) \ 1578 1.1 mrg extern __typeof (fn) gomp_ialias_##fn \ 1579 1.1.1.9 mrg __attribute__ ((alias (#fn))) attribute_hidden attribute_copy (fn); 1580 1.1.1.3 mrg # define ialias_redirect(fn) \ 1581 1.1.1.3 mrg extern __typeof (fn) fn __asm__ (ialias_ulp "gomp_ialias_" #fn) attribute_hidden; 1582 1.1.1.3 mrg # define ialias_call(fn) gomp_ialias_ ## fn 1583 1.1 mrg #else 1584 1.1 mrg # define ialias(fn) 1585 1.1.1.3 mrg # define ialias_redirect(fn) 1586 1.1.1.3 mrg # define ialias_call(fn) fn 1587 1.1 mrg #endif 1588 1.1 mrg 1589 1.1.1.4 mrg /* Helper function for priority_node_to_task() and 1590 1.1.1.4 mrg task_to_priority_node(). 1591 1.1.1.4 mrg 1592 1.1.1.4 mrg Return the offset from a task to its priority_node entry. The 1593 1.1.1.4 mrg priority_node entry is has a type of TYPE. */ 1594 1.1.1.4 mrg 1595 1.1.1.4 mrg static inline size_t 1596 1.1.1.4 mrg priority_queue_offset (enum priority_queue_type type) 1597 1.1.1.4 mrg { 1598 1.1.1.4 mrg return offsetof (struct gomp_task, pnode[(int) type]); 1599 1.1.1.4 mrg } 1600 1.1.1.4 mrg 1601 1.1.1.4 mrg /* Return the task associated with a priority NODE of type TYPE. */ 1602 1.1.1.4 mrg 1603 1.1.1.4 mrg static inline struct gomp_task * 1604 1.1.1.4 mrg priority_node_to_task (enum priority_queue_type type, 1605 1.1.1.4 mrg struct priority_node *node) 1606 1.1.1.4 mrg { 1607 1.1.1.4 mrg return (struct gomp_task *) ((char *) node - priority_queue_offset (type)); 1608 1.1.1.4 mrg } 1609 1.1.1.4 mrg 1610 1.1.1.4 mrg /* Return the priority node of type TYPE for a given TASK. */ 1611 1.1.1.4 mrg 1612 1.1.1.4 mrg static inline struct priority_node * 1613 1.1.1.4 mrg task_to_priority_node (enum priority_queue_type type, 1614 1.1.1.4 mrg struct gomp_task *task) 1615 1.1.1.4 mrg { 1616 1.1.1.4 mrg return (struct priority_node *) ((char *) task 1617 1.1.1.4 mrg + priority_queue_offset (type)); 1618 1.1.1.4 mrg } 1619 1.1.1.9 mrg 1620 1.1.1.9 mrg #ifdef LIBGOMP_USE_PTHREADS 1621 1.1.1.9 mrg static inline gomp_thread_handle 1622 1.1.1.9 mrg gomp_thread_self (void) 1623 1.1.1.9 mrg { 1624 1.1.1.9 mrg return pthread_self (); 1625 1.1.1.9 mrg } 1626 1.1.1.9 mrg 1627 1.1.1.9 mrg static inline gomp_thread_handle 1628 1.1.1.9 mrg gomp_thread_to_pthread_t (struct gomp_thread *thr) 1629 1.1.1.9 mrg { 1630 1.1.1.9 mrg struct gomp_thread *this_thr = gomp_thread (); 1631 1.1.1.9 mrg if (thr == this_thr) 1632 1.1.1.9 mrg return pthread_self (); 1633 1.1.1.9 mrg #ifdef GOMP_NEEDS_THREAD_HANDLE 1634 1.1.1.9 mrg return thr->handle; 1635 1.1.1.9 mrg #else 1636 1.1.1.9 mrg /* On Linux with initial-exec TLS, the pthread_t of the thread containing 1637 1.1.1.9 mrg thr can be computed from thr, this_thr and pthread_self (), 1638 1.1.1.9 mrg as the distance between this_thr and pthread_self () is constant. */ 1639 1.1.1.9 mrg return pthread_self () + ((uintptr_t) thr - (uintptr_t) this_thr); 1640 1.1.1.9 mrg #endif 1641 1.1.1.9 mrg } 1642 1.1.1.9 mrg #else 1643 1.1.1.9 mrg static inline gomp_thread_handle 1644 1.1.1.9 mrg gomp_thread_self (void) 1645 1.1.1.9 mrg { 1646 1.1.1.9 mrg return (gomp_thread_handle) {}; 1647 1.1.1.9 mrg } 1648 1.1.1.9 mrg 1649 1.1.1.9 mrg static inline gomp_thread_handle 1650 1.1.1.9 mrg gomp_thread_to_pthread_t (struct gomp_thread *thr) 1651 1.1.1.9 mrg { 1652 1.1.1.9 mrg (void) thr; 1653 1.1.1.9 mrg return gomp_thread_self (); 1654 1.1.1.9 mrg } 1655 1.1.1.9 mrg #endif 1656 1.1.1.9 mrg 1657 1.1 mrg #endif /* LIBGOMP_H */ 1658