static_restartable_using_initializer.c 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2009, 2010 Université de Bordeaux 1
  4. * Copyright (C) 2010 Centre National de la Recherche Scientifique
  5. *
  6. * StarPU is free software; you can redistribute it and/or modify
  7. * it under the terms of the GNU Lesser General Public License as published by
  8. * the Free Software Foundation; either version 2.1 of the License, or (at
  9. * your option) any later version.
  10. *
  11. * StarPU is distributed in the hope that it will be useful, but
  12. * WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  14. *
  15. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  16. */
  17. #include <sys/time.h>
  18. #include <stdio.h>
  19. #include <unistd.h>
  20. #include <starpu.h>
  21. /* This is equivalent to calling starpu_task_init later on */
  22. struct starpu_task task = STARPU_TASK_INITIALIZER;
  23. static unsigned ntasks = 65536;
  24. static void dummy_func(void *descr[] __attribute__ ((unused)), void *arg __attribute__ ((unused)))
  25. {
  26. }
  27. static starpu_codelet dummy_codelet =
  28. {
  29. .where = STARPU_CPU|STARPU_CUDA|STARPU_OPENCL,
  30. .cpu_func = dummy_func,
  31. .cuda_func = dummy_func,
  32. .opencl_func = dummy_func,
  33. .model = NULL,
  34. .nbuffers = 0
  35. };
  36. static void parse_args(int argc, char **argv)
  37. {
  38. int c;
  39. while ((c = getopt(argc, argv, "i:")) != -1)
  40. switch(c) {
  41. case 'i':
  42. ntasks = atoi(optarg);
  43. break;
  44. }
  45. }
  46. int main(int argc, char **argv)
  47. {
  48. unsigned i;
  49. double timing;
  50. struct timeval start;
  51. struct timeval end;
  52. parse_args(argc, argv);
  53. starpu_init(NULL);
  54. task.cl = &dummy_codelet;
  55. task.detach = 0;
  56. fprintf(stderr, "#tasks : %d\n", ntasks);
  57. gettimeofday(&start, NULL);
  58. for (i = 0; i < ntasks; i++)
  59. {
  60. starpu_task_submit(&task);
  61. starpu_task_wait(&task);
  62. }
  63. gettimeofday(&end, NULL);
  64. timing = (double)((end.tv_sec - start.tv_sec)*1000000
  65. + (end.tv_usec - start.tv_usec));
  66. fprintf(stderr, "Total: %lf secs\n", timing/1000000);
  67. fprintf(stderr, "Per task: %lf usecs\n", timing/ntasks);
  68. starpu_shutdown();
  69. return 0;
  70. }