1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495 |
- #include <config.h>
- #include <stdio.h>
- #include <unistd.h>
- #include <errno.h>
- #include <starpu.h>
- #include <stdlib.h>
- #include "../helper.h"
- starpu_data_handle_t void_handle;
- int critical_var;
- static void critical_section(void *descr[], __attribute__ ((unused)) void *_args)
- {
- STARPU_SKIP_IF_VALGRIND;
-
- critical_var++;
- }
- static struct starpu_codelet cl =
- {
- .where = STARPU_CPU|STARPU_CUDA|STARPU_OPENCL,
- .cpu_funcs = {critical_section, NULL},
- .cuda_funcs = {critical_section, NULL},
- .opencl_funcs = {critical_section, NULL},
- .nbuffers = 1,
- .modes = {STARPU_RW}
- };
- int main(int argc, char **argv)
- {
- #ifdef STARPU_QUICK_CHECK
- int ntasks = 10;
- #else
- int ntasks = 1000;
- #endif
- int ret;
- ret = starpu_init(NULL);
- if (ret == -ENODEV) return STARPU_TEST_SKIPPED;
- STARPU_CHECK_RETURN_VALUE(ret, "starpu_init");
- critical_var = 0;
-
- starpu_void_data_register(&void_handle);
- int i;
- for (i = 0; i < ntasks; i++)
- {
- struct starpu_task *task = starpu_task_create();
- task->cl = &cl;
- task->handles[0] = void_handle;
- ret = starpu_task_submit(task);
- if (ret == -ENODEV) goto enodev;
- STARPU_CHECK_RETURN_VALUE(ret, "starpu_task_submit");
- }
- starpu_data_unregister(void_handle);
- ret = (critical_var == ntasks) ? EXIT_SUCCESS : EXIT_FAILURE;
- starpu_shutdown();
- STARPU_RETURN(ret);
- enodev:
- fprintf(stderr, "WARNING: No one can execute this task\n");
-
- starpu_shutdown();
- return STARPU_TEST_SKIPPED;
- }
|