task_03.c 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2017,2019 CNRS
  4. * Copyright (C) 2014,2016 Inria
  5. * Copyright (C) 2017 Université de Bordeaux
  6. *
  7. * StarPU is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU Lesser General Public License as published by
  9. * the Free Software Foundation; either version 2.1 of the License, or (at
  10. * your option) any later version.
  11. *
  12. * StarPU is distributed in the hope that it will be useful, but
  13. * WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  15. *
  16. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  17. */
  18. #include <pthread.h>
  19. #include <starpu.h>
  20. #include "../helper.h"
  21. #include <stdio.h>
  22. /*
  23. * Check the OpenMP orphaned task support.
  24. */
  25. #if !defined(STARPU_OPENMP)
  26. int main(void)
  27. {
  28. return STARPU_TEST_SKIPPED;
  29. }
  30. #else
  31. __attribute__((constructor))
  32. static void omp_constructor(void)
  33. {
  34. int ret = starpu_omp_init();
  35. if (ret == -EINVAL) exit(STARPU_TEST_SKIPPED);
  36. STARPU_CHECK_RETURN_VALUE(ret, "starpu_omp_init");
  37. }
  38. __attribute__((destructor))
  39. static void omp_destructor(void)
  40. {
  41. starpu_omp_shutdown();
  42. }
  43. void task_region_f(void *buffers[], void *args)
  44. {
  45. (void) buffers;
  46. (void) args;
  47. int worker_id;
  48. pthread_t tid;
  49. tid = pthread_self();
  50. worker_id = starpu_worker_get_id();
  51. printf("[tid %p] task thread = %d: explicit task \"f\"\n", (void *)tid, worker_id);
  52. }
  53. int
  54. main (void)
  55. {
  56. struct starpu_omp_task_region_attr attr;
  57. memset(&attr, 0, sizeof(attr));
  58. #ifdef STARPU_SIMGRID
  59. attr.cl.model = &starpu_perfmodel_nop;
  60. #endif
  61. attr.cl.flags = STARPU_CODELET_SIMGRID_EXECUTE;
  62. attr.cl.cpu_funcs[0] = task_region_f;
  63. attr.cl.where = STARPU_CPU;
  64. attr.if_clause = 1;
  65. attr.final_clause = 0;
  66. attr.untied_clause = 1;
  67. attr.mergeable_clause = 0;
  68. starpu_omp_task_region(&attr);
  69. starpu_omp_task_region(&attr);
  70. starpu_omp_task_region(&attr);
  71. starpu_omp_task_region(&attr);
  72. return 0;
  73. }
  74. #endif