diff options
Diffstat (limited to 'openmp/testsuite/c/omp_task_untied.c')
| -rw-r--r-- | openmp/testsuite/c/omp_task_untied.c | 69 |
1 files changed, 69 insertions, 0 deletions
diff --git a/openmp/testsuite/c/omp_task_untied.c b/openmp/testsuite/c/omp_task_untied.c new file mode 100644 index 00000000000..3d6ebe25fe6 --- /dev/null +++ b/openmp/testsuite/c/omp_task_untied.c @@ -0,0 +1,69 @@ +<ompts:test> +<ompts:testdescription>Test for untied clause. First generate a set of tasks and pause it immediately. Then we resume half of them and check whether they are scheduled by different threads</ompts:testdescription> +<ompts:ompversion>3.0</ompts:ompversion> +<ompts:directive>omp task untied</ompts:directive> +<ompts:dependences>omp taskwait</ompts:dependences> +<ompts:testcode> +#include <stdio.h> +#include <math.h> +#include "omp_testsuite.h" +#include "omp_my_sleep.h" + +int <ompts:testcode:functionname>omp_task_untied</ompts:testcode:functionname>(FILE * logFile){ + + <ompts:orphan:vars> + int i; + int count; + int start_tid[NUM_TASKS]; + int current_tid[NUM_TASKS]; + </ompts:orphan:vars> + count = 0; + + /*initialization*/ + for (i=0; i< NUM_TASKS; i++){ + start_tid[i]=0; + current_tid[i]=0; + } + + #pragma omp parallel firstprivate(i) + { + #pragma omp single + { + for (i = 0; i < NUM_TASKS; i++) { + <ompts:orphan> + int myi = i; + #pragma omp task <ompts:check>untied</ompts:check> + { + my_sleep(SLEEPTIME); + start_tid[myi] = omp_get_thread_num(); + current_tid[myi] = omp_get_thread_num(); + + #pragma omp taskwait + + <ompts:check>if((start_tid[myi] %2) !=0){</ompts:check> + my_sleep(SLEEPTIME); + current_tid[myi] = omp_get_thread_num(); + <ompts:check> + } /* end of if */ + else { + current_tid[myi] = omp_get_thread_num(); + } + </ompts:check> + + } /*end of omp task */ + </ompts:orphan> + } /* end of for */ + } /* end of single */ + } /* end of parallel */ + + for (i=0;i<NUM_TASKS; i++) + { + printf("start_tid[%d]=%d, current_tid[%d]=%d\n",i, start_tid[i], i , current_tid[i]); + if (current_tid[i] == start_tid[i]) + count++; + } + return (count<NUM_TASKS); +} +</ompts:testcode> + +</ompts:test> |

