static_restartable.c 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  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. static unsigned ntasks = 65536;
  22. static void dummy_func(void *descr[] __attribute__ ((unused)), void *arg __attribute__ ((unused)))
  23. {
  24. }
  25. static starpu_codelet dummy_codelet =
  26. {
  27. .where = STARPU_CPU|STARPU_CUDA|STARPU_OPENCL,
  28. .cpu_func = dummy_func,
  29. .cuda_func = dummy_func,
  30. .opencl_func = dummy_func,
  31. .model = NULL,
  32. .nbuffers = 0
  33. };
  34. static void parse_args(int argc, char **argv)
  35. {
  36. int c;
  37. while ((c = getopt(argc, argv, "i:")) != -1)
  38. switch(c) {
  39. case 'i':
  40. ntasks = atoi(optarg);
  41. break;
  42. }
  43. }
  44. int main(int argc, char **argv)
  45. {
  46. unsigned i;
  47. double timing;
  48. struct timeval start;
  49. struct timeval end;
  50. parse_args(argc, argv);
  51. starpu_init(NULL);
  52. struct starpu_task task;
  53. starpu_task_init(&task);
  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. }