1 | // RUN: %libomp-compile && env OMP_NUM_THREADS='3' %libomp-run |
2 | // RUN: %libomp-compile && env OMP_NUM_THREADS='1' %libomp-run |
3 | |
4 | #include <stdio.h> |
5 | #include <omp.h> |
6 | #include "omp_my_sleep.h" |
7 | |
8 | // detached untied |
9 | #define PTASK_FLAG_DETACHABLE 0x40 |
10 | |
11 | // OpenMP RTL interfaces |
12 | typedef unsigned long long kmp_uint64; |
13 | typedef long long kmp_int64; |
14 | |
15 | typedef struct ID { |
16 | int reserved_1; |
17 | int flags; |
18 | int reserved_2; |
19 | int reserved_3; |
20 | char *psource; |
21 | } id; |
22 | |
23 | // Compiler-generated code (emulation) |
24 | typedef struct ident { |
25 | void* dummy; // not used in the library |
26 | } ident_t; |
27 | |
28 | typedef enum kmp_event_type_t { |
29 | KMP_EVENT_UNINITIALIZED = 0, |
30 | KMP_EVENT_ALLOW_COMPLETION = 1 |
31 | } kmp_event_type_t; |
32 | |
33 | typedef struct { |
34 | kmp_event_type_t type; |
35 | union { |
36 | void *task; |
37 | } ed; |
38 | } kmp_event_t; |
39 | |
40 | typedef struct shar { // shareds used in the task |
41 | } *pshareds; |
42 | |
43 | typedef struct task { |
44 | pshareds shareds; |
45 | int(*routine)(int,struct task*); |
46 | int part_id; |
47 | // void *destructor_thunk; // optional, needs flag setting if provided |
48 | // int priority; // optional, needs flag setting if provided |
49 | // ------------------------------ |
50 | // privates used in the task: |
51 | omp_event_handle_t evt; |
52 | } *ptask, kmp_task_t; |
53 | |
54 | typedef int(*task_entry_t)(int, ptask); |
55 | #ifdef __cplusplus |
56 | extern "C" { |
57 | #endif |
58 | extern int __kmpc_global_thread_num(void *id_ref); |
59 | extern ptask __kmpc_omp_task_alloc(id *loc, int gtid, int flags, |
60 | size_t sz, size_t shar, task_entry_t rtn); |
61 | extern int __kmpc_omp_task(id *loc, int gtid, ptask task); |
62 | extern omp_event_handle_t __kmpc_task_allow_completion_event( |
63 | ident_t *loc_ref, int gtid, ptask task); |
64 | #if __cplusplus |
65 | } |
66 | #endif |
67 | |
68 | int volatile checker; |
69 | |
70 | // User's code, outlined into task entry |
71 | int task_entry(int gtid, ptask task) { |
72 | checker = 1; |
73 | return 0; |
74 | } |
75 | |
76 | int main() { |
77 | int i, j, gtid = __kmpc_global_thread_num(NULL); |
78 | int nt = omp_get_max_threads(); |
79 | ptask task; |
80 | pshareds psh; |
81 | checker = 0; |
82 | omp_set_dynamic(0); |
83 | #pragma omp parallel //num_threads(N) |
84 | { |
85 | #pragma omp master |
86 | { |
87 | int gtid = __kmpc_global_thread_num(NULL); |
88 | omp_event_handle_t evt; |
89 | /* |
90 | #pragma omp task detach(evt) |
91 | {} |
92 | */ |
93 | task = (ptask)__kmpc_omp_task_alloc(NULL,gtid,PTASK_FLAG_DETACHABLE,sz: sizeof(struct task),shar: sizeof(struct shar),rtn: &task_entry); |
94 | psh = task->shareds; |
95 | evt = (omp_event_handle_t)__kmpc_task_allow_completion_event(NULL,gtid,task); |
96 | task->evt = evt; |
97 | |
98 | __kmpc_omp_task(NULL, gtid, task); |
99 | my_sleep(2.0); |
100 | omp_fulfill_event(evt); |
101 | |
102 | } // end master |
103 | } // end parallel |
104 | |
105 | // check results |
106 | if (checker == 1) { |
107 | printf(format: "passed\n" ); |
108 | return 0; |
109 | } else { |
110 | printf(format: "failed\n" ); |
111 | return 1; |
112 | } |
113 | } |
114 | |